Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 4, 2016

• [FLINK-4732] remove maven junction plugin

  Show description for 5a573c6
  mxm

  committed
  5a573c6

  Copy full SHA for 5a573c6

• [hotfix] [kafka] Fix NPE in Kafka09Fetcher

  fhueske

  committed
  eece0dd

  Copy full SHA for eece0dd

• [FLINK-4546] [table] Remove STREAM keyword in Stream SQL

  Show description for 72e6b76
  

  wuchong

  authored and

  twalthr

  committed
  72e6b76

  Copy full SHA for 72e6b76

• [FLINK-4068] [table] Reduce expression also for filter/project

  twalthr

  committed
  f00e1e7

  Copy full SHA for f00e1e7

• [FLINK-4068] [table] Move constant computations out of code-generated

  Show description for a711339
  

  wuchong

  authored and

  twalthr

  committed
  a711339

  Copy full SHA for a711339

• [FLINK-3656] [table] Convert expression tests to unit tests

  Show description for 171d109
  twalthr

  committed
  171d109

  Copy full SHA for 171d109

Commits on Oct 3, 2016

• [FLINK-4643] [gelly] Average Clustering Coefficient

  Show description for 95c08ea
  greghogan

  committed
  95c08ea

  Copy full SHA for 95c08ea

• [FLINK-4624] [gelly] Support null values in Graph Summarization

  Show description for a79efdc
  

  Martin Junghanns

  authored and

  greghogan

  committed
  a79efdc

  Copy full SHA for a79efdc

Commits on Oct 1, 2016

• [FLINK-4618] [kafka-connector] Minor improvements to comment and variable naming

  Show description for 9dbd1e3
  tzulitai

  committed
  9dbd1e3

  Copy full SHA for 9dbd1e3

• [FLINK-4618] [kafka-connector] Incremented the commited offset by one to avoid duplicate read message.

  

  static-max

  authored and

  tzulitai

  committed
  ae219a8

  Copy full SHA for ae219a8

Commits on Sep 30, 2016

• [FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls

  Show description for 92f4539
  StephanEwen

  committed
  92f4539

  Copy full SHA for 92f4539

• [FLINK-4379] [checkpoints] Fix minor bug and improve debug logging

  StephanEwen

  committed
  6f8f5eb

  Copy full SHA for 6f8f5eb

• [FLINK-4379] [checkpoints] Introduce rescalable operator state

  Show description for 53ed6ad
  

  StefanRRichter

  authored and

  StephanEwen

  committed
  53ed6ad

  Copy full SHA for 53ed6ad

• [FLINK-4573] [web dashboard] Fix potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

  Show description for 2afc092
  

  lw-lin

  authored and

  StephanEwen

  committed
  2afc092

  Copy full SHA for 2afc092

• [FLINK-4711] Let the Task trigger partition state requests and handle their responses

  Show description for 477d1c5
  tillrohrmann

  committed
  477d1c5

  Copy full SHA for 477d1c5

Commits on Sep 29, 2016

• [FLINK-3656] [table] Consolidate ITCases

  Show description for 7758571
  twalthr

  committed
  7758571

  Copy full SHA for 7758571

• [FLINK-4708] [build] Properly scope Kerberos Test Cluster dependency for tests

  StephanEwen

  committed
  8243138

  Copy full SHA for 8243138

• [FLINK-4710] [build] Remove Guice Dependency from Hadoop2

  Show description for 84af0b9
  StephanEwen

  committed
  84af0b9

  Copy full SHA for 84af0b9

• [FLINK-3656] [table] Reduce number of ITCases

  Show description for 62d4af8
  twalthr

  committed
  62d4af8

  Copy full SHA for 62d4af8

Commits on Sep 27, 2016

• [FLINK-4543] [network] Fix potential deadlock in SpilledSubpartitionViewAsyncIO.

  Show description for 9090291
  StephanEwen

  committed
  9090291

  Copy full SHA for 9090291

• [FLINK-4560] [build] Enforcer Java version >= 1.7 via Maven enforcer plugin

  Show description for b928935
  

  shijinkui

  authored and

  StephanEwen

  committed
  b928935

  Copy full SHA for b928935

• [FLINK-4695] Introduce MetricRegistryConfiguration to encapsulate MetricRegistry parameters

  Show description for f1b5b35
  tillrohrmann

  committed
  f1b5b35

  Copy full SHA for f1b5b35

• [FLINK-4690] Use direct executor to run slot allocation future handler

  tillrohrmann

  committed
  84672c2

  Copy full SHA for 84672c2

• [FLINK-4690] Replace SlotAllocationFuture with flink's own future

  Show description for 7b88f1a
  

  KurtYoung

  authored and

  tillrohrmann

  committed
  7b88f1a

  Copy full SHA for 7b88f1a

• [FLINK-4361] Introduce Flink's own future abstraction

  Show description for f8138f4
  tillrohrmann

  committed
  f8138f4

  Copy full SHA for f8138f4

• [hotfix] [tests] Speed up streaming state tests by skipping default retry delay.

  StephanEwen

  committed
  6e123d2

  Copy full SHA for 6e123d2

• [FLINK-4685] [checkpoints] Gather sync/async duration and alignment information for task checkpoints

  Show description for b1642e3
  StephanEwen

  committed
  b1642e3

  Copy full SHA for b1642e3

• [FLINK-4696] [core] Limit number of Akka threads in local minicluster setups

  Show description for 6ea9284
  StephanEwen

  committed
  6ea9284

  Copy full SHA for 6ea9284

• [FLINK-4671] [table] Table API can not be built

  Show description for e5d62da
  twalthr

  committed
  e5d62da

  Copy full SHA for e5d62da

Commits on Sep 26, 2016

• [FLINK-4241] [table] Cryptic expression parser exceptions

  Show description for ef15984
  twalthr

  committed
  ef15984

  Copy full SHA for ef15984

• [FLINK-4252] [table] Validate input and output classes of Table API

  Show description for f150f98
  twalthr

  committed
  f150f98

  Copy full SHA for f150f98

• [FLINK-4590] [table] Some Table API tests are failing when debug lvl is set to DEBUG

  Show description for 7eb45c1
  twalthr

  committed
  7eb45c1

  Copy full SHA for 7eb45c1

• [FLINK-4684] [checkpoints] Remove redundant class loader from CheckpointCoordinator

  StephanEwen

  committed
  70e71c1

  Copy full SHA for 70e71c1

• [FLINK-4662] Bump Calcite version up to 1.9

  Show description for 8fa313c
  

  wuchong

  authored and

  twalthr

  committed
  8fa313c

  Copy full SHA for 8fa313c

• [FLINK-4218] [checkpoints] Do not rely on FileSystem to determing state sizes

  Show description for 95e9004
  StephanEwen

  committed
  95e9004

  Copy full SHA for 95e9004

Pagination

Previous

Next