Commits

Branch selector

 master

User selector

StephanEwen

Datepicker

All time

Commit History

Commits on May 26, 2015

• [tez] Fix initialization of MemoryManager.

  Show description for b68049b
  StephanEwen

  committed
  b68049b

  Copy full SHA for b68049b

• [tez] Fix Flink-on-Tez use of pre-allocating MemoryManager

  StephanEwen

  committed
  eba6f9a

  Copy full SHA for eba6f9a

• [tests] Adjust tests for dedicated streaming mode and clean up test bases.

  Show description for 0437722
  StephanEwen

  committed
  0437722

  Copy full SHA for 0437722

• [FLINK-2084] [core] Add an option to start Flink in streaming mode

  Show description for efec229
  StephanEwen

  committed
  efec229

  Copy full SHA for efec229

• [FLINK-2085] [runtime] Add an option to let the MemoryManager allocate and release memory as needed.

  Show description for ea60678
  StephanEwen

  committed
  ea60678

  Copy full SHA for ea60678

Commits on May 21, 2015

• [runtime] Extend memory and GC monitor logging.

  StephanEwen

  committed
  35ea650

  Copy full SHA for 35ea650

• [examples] Fix remaining examples to properly handle eager print() execution.

  StephanEwen

  committed
  b92ff12

  Copy full SHA for b92ff12

• [FLINK-2071] [java api] Fix serializability issue with projectsion function.

  Show description for ad1d936
  StephanEwen

  committed
  ad1d936

  Copy full SHA for ad1d936

• [FLINK-1418] [apis] Minor cleanups for eager on-client print() statement.

  StephanEwen

  committed
  6220f34

  Copy full SHA for 6220f34

• [FLINK-2062] [core] Fix names of memory size config parameter

  Show description for 939e3fc
  StephanEwen

  committed
  939e3fc

  Copy full SHA for 939e3fc

• [FLINK-2063] [streaming] Add a streaming exactly once processing test with stateful operators.

  Show description for 7bd7b05
  StephanEwen

  committed
  7bd7b05

  Copy full SHA for 7bd7b05

Commits on May 20, 2015

• [FLINK-2063] [streaming] Configure checkpoint coordinator to treat all vertices as stateful.

  StephanEwen

  committed
  85453b6

  Copy full SHA for 85453b6

• [streaming] Fixed error logging in streaming tasks.

  StephanEwen

  committed
  68f41a0

  Copy full SHA for 68f41a0

• [FLINK-2057] [FLINK-2058] [core] Fix hadoop input split class loading and remove IOReadableWritable from InputSplits

  StephanEwen

  committed
  f27025b

  Copy full SHA for f27025b

• [runtime] Improve error message for failed network connections due to limited number of file handles

  StephanEwen

  committed
  89209a4

  Copy full SHA for 89209a4

Commits on May 19, 2015

• [runtime] Fix for task canceling the order of (1) resource deregistration (2) completeness notification

  StephanEwen

  committed
  3cd36a5

  Copy full SHA for 3cd36a5

• [FLINK-1952] [tests] Add a test that runs an iterative job after a failure in another iterative job.

  Show description for 8e6bb9a
  StephanEwen

  committed
  8e6bb9a

  Copy full SHA for 8e6bb9a

• [FLINK-2040] [runtime] Tolerate out-of-order CANCELING and CANCELED messages.

  StephanEwen

  committed
  8aad7af

  Copy full SHA for 8aad7af

Commits on May 18, 2015

• [FLINK-2041] [optimizer] Remove pipeline breakers where they are subsumed by batch data exchanges.

  StephanEwen

  committed
  c12403e

  Copy full SHA for c12403e

• [core] Miscellaneous cleanups in the FileInputFormat

  StephanEwen

  committed
  ebc8d20

  Copy full SHA for ebc8d20

• [FLINK-2006] [tests] Fix "TaskManagerTest.testRunJobWithForwardChannel()" by properly deploying receiver only after sender is running.

  StephanEwen

  committed
  a6f6a67

  Copy full SHA for a6f6a67

Commits on May 13, 2015

• [FLINK-2011] [runtime] Improve error message when user-defined serialization logic is erroneous

  StephanEwen

  committed
  113b20b

  Copy full SHA for 113b20b

• [FLINK-2006] [runtime] Fix testing TaskManager task status request to stabilize tests.

  StephanEwen

  committed
  9da2f1f

  Copy full SHA for 9da2f1f

Commits on May 12, 2015

• [FLINK-1959] [runtime] Support accumulators in chained functions after a non-UDF operation

  StephanEwen

  committed
  7349333

  Copy full SHA for 7349333

• [tests] Consolidate miscellaneous tests into one IntegrationTestCase to reuse minicluster and speed up tests

  StephanEwen

  committed
  cf4f22e

  Copy full SHA for cf4f22e

• [tests] Adapted CoGroupITCase to use "collect()" rather than writing temp files (increases robustness)

  StephanEwen

  committed
  e79ff4e

  Copy full SHA for e79ff4e

• [tests] Add test that checkes canceling against a failed TaskManager process

  StephanEwen

  committed
  4bd3525

  Copy full SHA for 4bd3525

• [tests] Fix ProcessFailureRecovery tests by aligning restart delay parameter with heartbeat pause.

  StephanEwen

  committed
  959d227

  Copy full SHA for 959d227

• [streaming] Integrate new checkpointed interface with StreamTask, StreamOperator, and PersistentKafkaSource

  StephanEwen

  committed
  3b2ee23

  Copy full SHA for 3b2ee23

• [FLINK-1973] [jobmanager] Task execution state messages are logged on INFO level, rather than on DEBUG level

  StephanEwen

  committed
  ededb6b

  Copy full SHA for ededb6b

• [FLINK-1953] [runtime] Integrate new snapshot checkpoint coordinator with jobgraph and execution graph

  Show description for 9b7f8aa
  StephanEwen

  committed
  9b7f8aa

  Copy full SHA for 9b7f8aa

• [FLINK-1928] [hbase] Fix license header for HBase tests

  StephanEwen

  committed
  a771cfb

  Copy full SHA for a771cfb

Commits on May 11, 2015

• [readme] Update links to IDE setup guide

  StephanEwen

  committed
  c1dba08

  Copy full SHA for c1dba08

• [FLINK-1969] [runtime] Remove deprecated profiler code

  StephanEwen

  committed
  fbea2da

  Copy full SHA for fbea2da

• Update build target path in README.md

  StephanEwen

  committed
  59faf46

  Copy full SHA for 59faf46

Pagination

Previous

Next