Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 24, 2016

• [FLINK-3907] [gelly] Directed Clustering Coefficient

  Show description for d34bdaf
  

  greghogan

  authored and

  EC2 Default User

  committed
  d34bdaf

  Copy full SHA for d34bdaf

• [FLINK-3864][yarn] check for prohibited strings in log output

  Show description for d92aeb7
  mxm

  committed
  d92aeb7

  Copy full SHA for d92aeb7

• [FLINK-4041] reduce log level for JobManager->ResourceManager timeouts

  Show description for a5aa4e1
  mxm

  committed
  a5aa4e1

  Copy full SHA for a5aa4e1

• [FLINK-3757] clarify JavaDoc for addAccumulator method

  Show description for 9c15406
  mxm

  committed
  9c15406

  Copy full SHA for 9c15406

• [FLINK-3838] upgrade commons-cli to fix parsing of jar args

  Show description for dfecca7
  mxm

  committed
  dfecca7

  Copy full SHA for dfecca7

• [FLINK-1946] reduce verbosity of Yarn cluster setup

  Show description for 5b2ad7f
  mxm

  committed
  5b2ad7f

  Copy full SHA for 5b2ad7f

• [FLINK-3667] additional cleanups in YarnClusterClient

  Show description for 3b59363
  mxm

  committed
  3b59363

  Copy full SHA for 3b59363

Commits on Jun 23, 2016

• [FLINK-3800] [runtime] Introduce SUSPENDED job status

  Show description for 6420c1c
  tillrohrmann

  committed
  6420c1c

  Copy full SHA for 6420c1c

• [FLINK-4046] [runtime] Add direct state transition from RESTARTING to FAILED

  Show description for cfe6293
  tillrohrmann

  committed
  cfe6293

  Copy full SHA for cfe6293

• [FLINK-3859] [table] Add BigDecimal/BigInteger support to Table API

  Show description for 37defbb
  twalthr

  committed
  37defbb

  Copy full SHA for 37defbb

• [FLINK-4040] [dist] Allow JobManager/TaskManager-specific JVM args

  Show description for b6e6b81
  uce

  committed
  b6e6b81

  Copy full SHA for b6e6b81

• [FLINK-3872] [table, connector-kafka] Add KafkaTableSource

  Show description for 479be14
  uce

  committed
  479be14

  Copy full SHA for 479be14

• [FLINK-3872] [table, connector-kafka] Add JsonRowDeserializationSchema

  Show description for 3ac080f
  uce

  committed
  3ac080f

  Copy full SHA for 3ac080f

• [FLINK-3919] [ml] Implement DistributedRowMatrix

  Show description for 63504a3
  

  chobeat

  authored and

  chiwanpark

  committed
  63504a3

  Copy full SHA for 63504a3

Commits on Jun 22, 2016

• [FLINK-3868] [core] Specialized CopyableValue serializers and comparators

  Show description for 08b075a
  greghogan

  committed
  08b075a

  Copy full SHA for 08b075a

• [FLINK-3752] Add Per-Kafka-Partition Watermark Generation to the docs

  Show description for 7ec6d7b
  

  kl0u

  authored and

  rmetzger

  committed
  7ec6d7b

  Copy full SHA for 7ec6d7b

• [FLINK-4097] Fix NullPointerException on CassandraSinkBase and CassandraTupleWriteAheadSink's close()

  Show description for a973d84
  

  Andrea Sella

  authored and

  zentol

  committed
  a973d84

  Copy full SHA for a973d84

• [FLINK-4076] BoltWrapper calls super.dispose()

  Show description for e7dfa28
  

  biaoma-ty

  authored and

  zentol

  committed
  e7dfa28

  Copy full SHA for e7dfa28

• [FLINK-3626] [py] Add zipWithIndex()

  Show description for 93c61c0
  

  magsol

  authored and

  zentol

  committed
  93c61c0

  Copy full SHA for 93c61c0

• [FLINK-4092] [py] Fix Stringify function's implicit string type conversion problem

  Show description for e04239d
  

  Shahin

  authored and

  zentol

  committed
  e04239d

  Copy full SHA for e04239d

• [FLINK-4091] Fix Guava shading in Cassandra connector

  Show description for 7e206f4
  zentol

  committed
  7e206f4

  Copy full SHA for 7e206f4

Commits on Jun 21, 2016

• [FLINK-4082] Add Setting for enabling/disabling LargeRecordHandler

  Show description for bce3a68
  aljoscha

  committed
  bce3a68

  Copy full SHA for bce3a68

• [FLINK-4038] [dist] Escape JVM arguments in TaskManager startup script

  uce

  committed
  bc427d5

  Copy full SHA for bc427d5

• [FLINK-3973] [docs] Emphasize Table/SQL links

  uce

  committed
  a4d35d7

  Copy full SHA for a4d35d7

• [hotfix] [docs] Fix link to ResultTypeQueryable

  uce

  committed
  56216d5

  Copy full SHA for 56216d5

• [FLINK-4012] [docs] Fix link to Iterations in Basic Concepts page

  uce

  committed
  d2d37cd

  Copy full SHA for d2d37cd

• [hotfix] Remove "initialTime" in WindowOperatorTest

  Show description for 09e2810
  aljoscha

  committed
  09e2810

  Copy full SHA for 09e2810

• [FLINK-3714] Extend comments in WindowOperatorTest

  Show description for 87195a8
  aljoscha

  committed
  87195a8

  Copy full SHA for 87195a8

• [FLINK-3714] Rename getCleanupTimeForWindow to cleanupTime in WindowOperator

  aljoscha

  committed
  62c5a3c

  Copy full SHA for 62c5a3c

• [FLINK-3714] Remove Unneccesary Timer in EventTimeTrigger

  Show description for 0104a92
  aljoscha

  committed
  0104a92

  Copy full SHA for 0104a92

• [FLINK-3714] Add Support for "Allowed Lateness"

  Show description for 34a8b03
  

  kl0u

  authored and

  aljoscha

  committed
  34a8b03

  Copy full SHA for 34a8b03

Commits on Jun 20, 2016

• [FLINK-4090] Close of OutputStream should be in finally clause

  Show description for f2e9c52
  

  biaoma-ty

  authored and

  mxm

  committed
  f2e9c52

  Copy full SHA for f2e9c52

• [FLINK-4089][yarn] fix null check in Yarn client

  mxm

  committed
  e6320a4

  Copy full SHA for e6320a4

• [FLINK-4078] [dataSet] Introduce closure cleaning in CoGroup.where() and equaltTo()

  Show description for 78d3c61
  

  StefanRRichter

  authored and

  uce

  committed
  78d3c61

  Copy full SHA for 78d3c61

• [FLINK-4083] [dataSet] Introduce closure cleaning in Join.where() and equaltTo()

  Show description for 6a1144e
  

  StefanRRichter

  authored and

  uce

  committed
  6a1144e

  Copy full SHA for 6a1144e

Pagination

Previous

Next