Commits

Branch selector

 master

User selector

StephanEwen

Datepicker

All time

Commit History

Commits on Aug 27, 2015

• [FLINK-2582] [docs] Add documentation how to build Flink against different Scala versions

  Show description for bc63ef2
  StephanEwen

  committed
  bc63ef2

  Copy full SHA for bc63ef2

• [FLINK-2587] [streaming] Make sure that close() is not called while checkpoint methods are in progress.

  StephanEwen

  committed
  74ed714

  Copy full SHA for 74ed714

• [FLINK-2584] [java api] Downgrade version of javakaffee kryo serializers, for compatibility with kryo 2.4

  StephanEwen

  committed
  f501643

  Copy full SHA for f501643

• [tests] Move manual test 'RecordsAndWidthsCombinationCheck' to proper tests scope

  StephanEwen

  committed
  38098cf

  Copy full SHA for 38098cf

• [FLINK-2386] [kafka connector] Move Kafka connector classes to 'org.apache.flink.streaming.connectors.kafka'

  StephanEwen

  committed
  844e0b2

  Copy full SHA for 844e0b2

• [FLINK-2386] [kafka connector] Refactor, cleanup, and fix kafka consumers

  StephanEwen

  committed
  b9892a0

  Copy full SHA for b9892a0

• [FLINK-2386] [kafka connector] Add comments to all backported kafka sources and move them to 'org.apache.flink.kafka_backport'

  StephanEwen

  committed
  33f4c81

  Copy full SHA for 33f4c81

• [streaming] Cleanup de-/serialization schema, add TypeInformationSerializationSchema prominent, add tests.

  StephanEwen

  committed
  fb5aac2

  Copy full SHA for fb5aac2

• [FLINK-2276] [tests] Fix stability of TaskTest

  StephanEwen

  committed
  2c40ea8

  Copy full SHA for 2c40ea8

• [FLINK-2578] [tests] Fix stability of TaskAsyncCallTest

  StephanEwen

  committed
  8ab89e8

  Copy full SHA for 8ab89e8

Commits on Aug 26, 2015

• [FLINK-2189] [runtime] Fix various issues in hash table

  Show description for 4a5fe4e
  StephanEwen

  committed
  4a5fe4e

  Copy full SHA for 4a5fe4e

• [FLINK-2575] [runtime] Deactivate join bloom filters by default

  StephanEwen

  committed
  ced6a19

  Copy full SHA for ced6a19

Commits on Aug 25, 2015

• [FLINK-2528] [tests] Increase robustness and error reporting of MatchTaskTest

  StephanEwen

  committed
  6f07c5f

  Copy full SHA for 6f07c5f

Commits on Aug 24, 2015

• [FLINK-2468] [tests] Make sure StateCheckpoinedITCase tolerates errors before first checkpoint

  StephanEwen

  committed
  5aa70f7

  Copy full SHA for 5aa70f7

Commits on Aug 21, 2015

• [tests] Move UnionClosedBranchingTest to optimizer tests

  StephanEwen

  committed
  a82bd43

  Copy full SHA for a82bd43

• [hotfix] Some Java 7 cleanups in InstantiationUtil

  StephanEwen

  committed
  d05d386

  Copy full SHA for d05d386

Commits on Aug 18, 2015

• [tests] Minor cleanup removing duplicate mock invokables in various tests.

  StephanEwen

  committed
  8602b7a

  Copy full SHA for 8602b7a

• [tests] Rename 'compiler' tests to 'optimizer' tests for consistent naming

  StephanEwen

  committed
  09fdfda

  Copy full SHA for 09fdfda

Commits on Aug 17, 2015

• [tests] Reinforce StateCheckpoinedITCase to make sure actual checkpointing has happened before a failure.

  StephanEwen

  committed
  3fcc04a

  Copy full SHA for 3fcc04a

• [FLINK-2462] [streaming] Major cleanup of operator structure for exception handling and code simplication

  Show description for 92b1e47
  StephanEwen

  committed
  92b1e47

  Copy full SHA for 92b1e47

Commits on Aug 16, 2015

• [tests] Make timeout discarding checks in CheckpointCoordinatorTest more robust.

  StephanEwen

  committed
  e4e44be

  Copy full SHA for e4e44be

Commits on Aug 14, 2015

• [FLINK-2457] [core] Slight adjustedments to Tuple0 singleton names to match naming scheme.

  StephanEwen

  committed
  c34af20

  Copy full SHA for c34af20

• [FLINK-2523] [taskmanager] Increase interrupt timeout in TaskManager task.

  StephanEwen

  committed
  852d19c

  Copy full SHA for 852d19c

• [FLINK-2393] [docs] Updates docs to describe switch between exactly-once and at-least-once

  StephanEwen

  committed
  21a0c94

  Copy full SHA for 21a0c94

• [FLINK-2519] [streaming] Make checkpoint alignment aware of finished partitions.

  StephanEwen

  committed
  e1d1bd0

  Copy full SHA for e1d1bd0

• [FLINK-2515] [job manager] Checkpoint coordinator triggers checkpoints only when tasks are running.

  StephanEwen

  committed
  06e2da3

  Copy full SHA for 06e2da3

• [FLINK-2509] [hotfix] Address pull request comments for ClassLoaderUtils

  Show description for 4cc8d66
  StephanEwen

  committed
  4cc8d66

  Copy full SHA for 4cc8d66

Commits on Aug 12, 2015

• [FLINK-2509] [runtime] Add class loader info into the exception message when user code classes are not found.

  Show description for eeec191
  StephanEwen

  committed
  eeec191

  Copy full SHA for eeec191

Commits on Aug 10, 2015

• [FLINK-2498] [tests] Clean up GroupReduceITCase and make it more robust by avoiding temp files

  StephanEwen

  committed
  ceb5c5e

  Copy full SHA for ceb5c5e

• [hotfix] Fix repository language statistics by adjusting .gitattributes

  StephanEwen

  committed
  0ce757f

  Copy full SHA for 0ce757f

• [FLINK-1177] [docs] Mark HDFS setup instructions as option in cluster setup docs

  StephanEwen

  committed
  27044b4

  Copy full SHA for 27044b4

• [FLINK-2453] [docs] Update README and setup docs to reflect requirement for Java 7+

  StephanEwen

  committed
  e503ebc

  Copy full SHA for e503ebc

• [FLINK-705] [license] Add license reference for TPC-H sample data in tests.

  StephanEwen

  committed
  368d7ae

  Copy full SHA for 368d7ae

Commits on Aug 6, 2015

• [hotfix] Fix TEZ task contect to reflect updated interface.

  StephanEwen

  committed
  441ebf1

  Copy full SHA for 441ebf1

• [FLINK-2240] [runtime] Pass flag to configure use of bloom filters through runtime configuration.

  Show description for 0b73b43
  StephanEwen

  committed
  0b73b43

  Copy full SHA for 0b73b43

Pagination

Previous

Next