Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 27, 2016

• [FLINK-3898] [gelly] Adamic-Adar Similarity

  Show description for f9552d8
  greghogan

  committed
  f9552d8

  Copy full SHA for f9552d8

• Fix test formatting and move WindowAssignerContext to WindowAssigner

  aljoscha

  committed
  90cfe0a

  Copy full SHA for 90cfe0a

• Fixing typos in the javadocs.

  

  kl0u

  authored and

  aljoscha

  committed
  8803d15

  Copy full SHA for 8803d15

• [FLINK-3647] Change StreamSource to use Processing-Time Clock Service

  

  kl0u

  authored and

  aljoscha

  committed
  819fb27

  Copy full SHA for 819fb27

• [FLINK-3464] Use Processing-Time Clock in Window Assigners/Triggers

  Show description for 4b5a789
  

  kl0u

  authored and

  aljoscha

  committed
  4b5a789

  Copy full SHA for 4b5a789

• [FLINK-3974] Fix object reuse with multi-chaining

  Show description for cb2b76d
  aljoscha

  committed
  cb2b76d

  Copy full SHA for cb2b76d

• [FLINK-3951] Add Histogram metric type

  Show description for ee3c7a8
  

  tillrohrmann

  authored and

  zentol

  committed
  ee3c7a8

  Copy full SHA for ee3c7a8

• [FLINK-4093] Expose metric interfaces

  Show description for d43bf8d
  zentol

  committed
  d43bf8d

  Copy full SHA for d43bf8d

• [FLINK-4087] [metrics] Improved JMX port handling

  Show description for 62cb954
  zentol

  committed
  62cb954

  Copy full SHA for 62cb954

• [hotfix] [metrics] Prevent registration exceptions

  zentol

  committed
  19ff8db

  Copy full SHA for 19ff8db

• [FLINK-4074] Make metric reporters less blocking

  Show description for 56cdec7
  zentol

  committed
  56cdec7

  Copy full SHA for 56cdec7

• [FLINK-4119] Refactor null checks in Cassandra IOF

  Show description for 9487fcb
  

  Andrea Sella

  authored and

  zentol

  committed
  9487fcb

  Copy full SHA for 9487fcb

• [hotfix][docs] Add warning to Cassandra documentation

  

  rmetzger

  authored and

  zentol

  committed
  6744b85

  Copy full SHA for 6744b85

• [FLINK-4121] Add timeunit (ms) to docs for timestamps and watermarks

  Show description for 35b4da2
  

  powibol

  authored and

  aljoscha

  committed
  35b4da2

  Copy full SHA for 35b4da2

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

Pagination

Previous

Next