Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 1, 2017

• [FLINK-5893] [RM] Fix the bug of race condition for removing previous JobManagerRegistration in ResourceManager

  Show description for 750325e
  

  淘江

  authored and

  tillrohrmann

  committed
  750325e

• [FLINK-7046] [travis] Hide download logging messages

  Show description for 6e3f839
  zentol

  committed
  6e3f839

• [FLINK-7048] [travis] Define javadoc skipping in travis watchdog script

  Show description for 95d70db
  zentol

  committed
  95d70db

• [FLINK-7030] Build with scala-2.11 by default

  Show description for caf149e
  

  pnowojski

  authored and

  zentol

  committed
  caf149e

• [FLINK-6908] Remove batch/streaming arg from start-cluster.sh

  Show description for 90a6407
  zentol

  committed
  90a6407

• [FLINK-6655] Add validateAndNormalizeUri method to MemoryArchivist

  Show description for 3956269
  

  zhangminglei

  authored and

  zentol

  committed
  3956269

• [FLINK-5918] [runtime] port range support for taskmanager.rpc.port

  Show description for 3f0ac26
  

  fengyelei

  authored and

  zentol

  committed
  3f0ac26

• [FLINK-6987] Fix TextInputFormatTest for paths with spaces

  Show description for c84a828
  

  zhangminglei

  authored and

  zentol

  committed
  c84a828

• [FLINK-6221] Add PrometheusReporter

  Show description for bb9505d
  

  mbode

  authored and

  zentol

  committed
  bb9505d

• [FLINK-6742] Add eager checks for parallelism/chain-length change

  Show description for cd45825
  zentol

  committed
  cd45825

• [FLINK-6638] Allow overriding default for primitive ConfigOption

  Show description for 60a59d2
  zentol

  committed
  60a59d2

• [FLINK-6498] Migrate Zookeeper configuration options

  Show description for f839018
  

  FangYongs

  authored and

  zentol

  committed
  f839018

• [FLINK-5488] Close YarnClient on error in AbstractYarnClusterDescriptor

  Show description for 3d2f3f6
  

  FangYongs

  authored and

  zentol

  committed
  3d2f3f6

• [FLINK-7000] Add custom configuration local environment in Scala StreamExecutionEnvironment

  Show description for acc2e34
  

  ch33hau

  authored and

  zentol

  committed
  acc2e34

• [FLINK-6461] Replace usages of deprecated web port key

  Show description for 80b2805
  zentol

  committed
  80b2805

• [FLINK-6898] [metrics] Limit size of operator component in metric name

  Show description for edb79b0
  zentol

  committed
  edb79b0

• [FLINK-6785] [metrics] Fix ineffective asserts in MetricRegistryTest

  Show description for 0858076
  zentol

  committed
  0858076

• [FLINK-6680] [docs] Update "Upgrading Applications and Flink Versions" for 1.3

  Show description for daed460
  tzulitai

  committed
  daed460

• [FLINK-6674] [docs] Bootstrap API Migration docs update for 1.2 -> 1.3

  tzulitai

  committed
  da74980

• [FLINK-6575] [tests] Disable tests on Windows that use HDFS

  Show description for 4cac6f4
  

  zentol

  authored and

  tzulitai

  committed
  4cac6f4

• [FLINK-6376] [yarn] Improve inline code comments related to HDFS delegation token inclusion

  Show description for e575c6c
  tzulitai

  committed
  e575c6c

• [FLINK-6376] [yarn] Always upload HDFS delegation token for secured YARN deployments

  Show description for b1f3408
  

  z00376786

  authored and

  tzulitai

  committed
  b1f3408

• [FLINK-6496] [security] Port SSL config parameters to ConfigOptions

  Show description for 67bf467
  

  zentol

  authored and

  tzulitai

  committed
  67bf467

• [FLINK-6789] [optimizer] Remove duplicated test utility reducer in optimizer

  Show description for 9ed9ea6
  

  zhangminglei

  authored and

  tzulitai

  committed
  9ed9ea6

• [FLINK-6867] [elasticsearch] Fix instable Elasticsearch 1.x ITCases

  Show description for 2d275e0
  tzulitai

  committed
  2d275e0

• [FLINK-7011] [kafka] Remove Kafka testStartFromKafkaCommitOffsets ITCases

  Show description for ba75bde
  tzulitai

  committed
  ba75bde

• [FLINK-4022] [kafka] Partition / topic discovery for FlinkKafkaConsumer

  Show description for 085d4db
  tzulitai

  committed
  085d4db

Commits on Jun 30, 2017

• [FLINK-6075] [table] Add ORDER BY support for streaming table.

  Show description for b8c8f20
  

  rtudoran

  authored and

  fhueske

  committed
  b8c8f20

• [FLINK-6710] Remove Twitter-InputFormat

  zentol

  committed
  d7d10a1

Commits on Jun 29, 2017

• [FLINK-7025] [table] Port non-partitioned unbounded proctime Over window to keyed state.

  Show description for 55ab34f
  

  sunjincheng121

  authored and

  fhueske

  committed
  55ab34f

• [FLINK-3551] [examples] Sync Scala streaming examples with Java examples.

  Show description for 1cf1620
  

  ch33hau

  authored and

  fhueske

  committed
  1cf1620

• [FLINK-7008] [cep] Update NFA state only when the NFA changes

  Show description for e3bef55
  

  dianfu

  authored and

  dawidwys

  committed
  e3bef55

• [FLINK-6989] [gelly] Refactor examples with Output interface

  Show description for f8842f6
  greghogan

  committed
  f8842f6

• [FLINK-6379] Remove internal methods from MesosResourceManagerGateway

  Show description for 901a9ca
  tillrohrmann

  committed
  901a9ca

• [FLINK-6379] [tests] Fix race condition in MesosResourceManagerTest

  Show description for 4bb488c
  tillrohrmann

  committed
  4bb488c

Pagination

PreviousNext