Commits

Branch selector

 master

User selector

uce

Datepicker

All time

Commit History

Commits on Aug 26, 2015

• [FLINK-2356] Add shutdown hook to CheckpointCoordinator to prevent resource leaks

  Show description for 366d937
  uce

  committed
  366d937

  Copy full SHA for 366d937

• [FLINK-2460] [runtime] Check parent state in isReleased() check of partition view

  Show description for a17d4e8
  uce

  committed
  a17d4e8

  Copy full SHA for a17d4e8

• [FLINK-2270] [docs] Fix typo in docs (enableMonitoring => enableCheckpointing)

  uce

  committed
  5a9daca

  Copy full SHA for 5a9daca

• [FLINK-2538] Close created JarFile in ClassLoaderUtil

  uce

  committed
  5322e87

  Copy full SHA for 5322e87

• [FLINK-2089] [runtime] Fix illegal state in RecordWriter after partition write failure

  Show description for b2f8e30
  uce

  committed
  b2f8e30

  Copy full SHA for b2f8e30

Commits on Aug 21, 2015

• [FLINK-2540] [optimizer] [runtime] Propagate union batch exchanges to union inputs

  Show description for 58421b8
  

  uce

  authored and

  StephanEwen

  committed
  58421b8

  Copy full SHA for 58421b8

Commits on Aug 11, 2015

• [FLINK-2511] [runtime] Make sure to close FileInputStream in FlinkZooKeeperQuorumPeer

  uce

  committed
  d8d0748

  Copy full SHA for d8d0748

Commits on Jul 31, 2015

• [FLINK-2412] [runtime] Check if parent released before querying in-memory buffer in SpillableSubpartitionView

  uce

  committed
  a56aad7

  Copy full SHA for a56aad7

Commits on Jul 29, 2015

• [FLINK-2424] [core] Close output stream in serialization utility

  uce

  committed
  7bd57d7

  Copy full SHA for 7bd57d7

Commits on Jul 24, 2015

• [FLINK-2384] [runtime] Move blocking I/O call outside of synchronized block

  Show description for efca79c
  uce

  committed
  efca79c

  Copy full SHA for efca79c

• [FLINK-2381] Stringify cause of ProducerFailedExceptions

  uce

  committed
  9b1343d

  Copy full SHA for 9b1343d

Commits on Jul 23, 2015

• [FLINK-2400] [tests] Improve error message on unexpected TaskTest message

  uce

  committed
  fa78be6

  Copy full SHA for fa78be6

Commits on Jul 16, 2015

• [docs] Fix Javadocs of RuntimeContext parallel subtask index

  uce

  committed
  c062137

  Copy full SHA for c062137

Commits on Jul 8, 2015

• [FLINK-2288] [docs] Add docs for HA/ZooKeeper setup

  Show description for 9c0dd97
  

  uce

  authored and

  StephanEwen

  committed
  9c0dd97

  Copy full SHA for 9c0dd97

• [FLINK-2288] [FLINK-2302] Setup ZooKeeper for distributed coordination

  Show description for 8c72b50
  

  uce

  authored and

  StephanEwen

  committed
  8c72b50

  Copy full SHA for 8c72b50

Commits on Jul 1, 2015

• [runtime] Properly set cause of ProducerFailedException

  uce

  committed
  e19ed78

  Copy full SHA for e19ed78

Commits on Jun 22, 2015

• [FLINK-1877] [FLINK-2204] Ignore frequently failing Flink-On-Tez tests

  Show description for bacf447
  uce

  committed
  bacf447

  Copy full SHA for bacf447

• [scala-shell] [tests] Remove unnecessary output check

  Show description for 391f966
  uce

  committed
  391f966

  Copy full SHA for 391f966

• [core] Use instanceof for equality check in Value types

  Show description for a42c641
  uce

  committed
  a42c641

  Copy full SHA for a42c641

Commits on Jun 17, 2015

• [core] Fix typo in DataSinkTask error message

  uce

  committed
  20a464f

  Copy full SHA for 20a464f

• [streaming] Fix out-of-sync class-level docs of SourceFunction

  uce

  committed
  b7945bf

  Copy full SHA for b7945bf

Commits on Jun 16, 2015

• [FLINK-2219] [webfrontend] Fix IllegalArgumentException and decrease log level

  Show description for f916819
  uce

  committed
  f916819

  Copy full SHA for f916819

Commits on Jun 15, 2015

• [FLINK-2224] Log error cause in JobStatusChange

  uce

  committed
  b14ec17

  Copy full SHA for b14ec17

• [FLINK-2216] Exclude javadoc jar from examples

  uce

  committed
  5317a1e

  Copy full SHA for 5317a1e

• [readme] Synchronize tagline with intro, fix typos

  uce

  committed
  37ceb8d

  Copy full SHA for 37ceb8d

Commits on Jun 12, 2015

• [FLINK-2195] Configure Configurable Hadoop InputFormats

  Show description for 1e7d0bb
  uce

  committed
  1e7d0bb

  Copy full SHA for 1e7d0bb

Commits on Jun 8, 2015

• [FLINK-2177] [runtime] Fix possible NPE when closing Netty channel, before it is active

  uce

  committed
  d433ba9

  Copy full SHA for d433ba9

Commits on Jun 4, 2015

• [FLINK-2134] Close Netty channel via CloseRequest msg

  Show description for 0dea359
  uce

  committed
  0dea359

  Copy full SHA for 0dea359

Commits on Jun 2, 2015

• [FLINK-2132] [scripts] Fix java version extraction

  uce

  committed
  d22e9f8

  Copy full SHA for d22e9f8

Commits on Jun 1, 2015

• [runtime] Rename internal field of Netty error message

  Show description for 93e960d
  uce

  committed
  93e960d

  Copy full SHA for 93e960d

• [runtime] Fix uncaught exception in Netty server pipeline

  uce

  committed
  6182180

  Copy full SHA for 6182180

• [FLINK-1954] [FLINK-1955] [runtime] Set task failure cause for produced result partitions

  uce

  committed
  f75c16b

  Copy full SHA for f75c16b

• [FLINK-1954] [FLINK-1958] [runtime] Cancel transfers of failed receiver tasks

  uce

  committed
  dce1be1

  Copy full SHA for dce1be1

Commits on May 29, 2015

• [runtime] Clear serializer state when clearing RecordWriter

  uce

  committed
  5a7ceda

  Copy full SHA for 5a7ceda

• [FLINK-2109] [runtime] Fix CancelTaskException handling

  Show description for d594d02
  uce

  committed
  d594d02

  Copy full SHA for d594d02

Pagination

Previous

Next