Commits

Branch selector

 master

User selector

aljoscha

Datepicker

All time

Commit History

Commits on Apr 17, 2018

• Clarify where DataStream.print() and printToErr() print to

  aljoscha

  committed
  518adb0

  Copy full SHA for 518adb0

Commits on Apr 12, 2018

• [FLINK-9152] Add simple ITCase for non-keyed Broadcast Connect translation

  aljoscha

  committed
  f3d4011

  Copy full SHA for f3d4011

• [FLINK-9152] Fix error message on BroadcastConnectedStream

  aljoscha

  committed
  48d05f1

  Copy full SHA for 48d05f1

• [FLINK-9152] Use in-class Context objects in BroadcastProcessFunction

  Show description for 0838bbe
  aljoscha

  committed
  0838bbe

  Copy full SHA for 0838bbe

• [FLINK-9152] Harmonize BroadcastProcessFunction Context names

  aljoscha

  committed
  584229d

  Copy full SHA for 584229d

• [FLINK-9160] Make subclasses of RuntimeContext internal that should be internal

  aljoscha

  committed
  d5d6842

  Copy full SHA for d5d6842

Commits on Mar 11, 2018

• [FLINK-8487] Verify ZooKeeper checkpoint store behaviour with ITCase

  aljoscha

  committed
  4c85b74

  Copy full SHA for 4c85b74

• [FLINK-8911] Add separate script for nightly end-to-end tests

  aljoscha

  committed
  0f3b3f9

  Copy full SHA for 0f3b3f9

• [FLINK-8778] Port queryable state ITCases to use MiniClusterResource

  aljoscha

  committed
  8365c90

  Copy full SHA for 8365c90

• [FLINK-8797] Port AbstractOperatorRestoreTestBase to MiniClusterResource

  aljoscha

  committed
  6732669

  Copy full SHA for 6732669

• [FLINK-8758] Add FutureUtils.retrySuccessfulWithDelay()

  Show description for ccb78b0
  aljoscha

  committed
  ccb78b0

  Copy full SHA for ccb78b0

• Add our own Deadline implementation

  aljoscha

  committed
  3913382

  Copy full SHA for 3913382

Commits on Mar 9, 2018

• [FLINK-8860] Change slot-report message to DEBUG

  aljoscha

  committed
  82dec05

  Copy full SHA for 82dec05

Commits on Mar 7, 2018

• [FLINK-8890] Compare checkpoints with order in CompletedCheckpoint.checkpointsMatch()

  Show description for fb72a80
  aljoscha

  committed
  fb72a80

  Copy full SHA for fb72a80

Commits on Mar 5, 2018

• Fix checkstyle in ZooKeeperCompletedCheckpointStoreTest

  aljoscha

  committed
  c1b8050

  Copy full SHA for c1b8050

• [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop

  Show description for 4226bf2
  aljoscha

  committed
  4226bf2

  Copy full SHA for 4226bf2

• [FLINK-8700] Add ClusterClient.getJobStatus()

  

  aljoscha

  authored and

  zentol

  committed
  56fef58

  Copy full SHA for 56fef58

• [FLINK-8700] Add getters to JobDetailsInfo

  

  aljoscha

  authored and

  zentol

  committed
  7d1c6b4

  Copy full SHA for 7d1c6b4

• [FLINK-8758] Make non-blocking ClusterClient.submitJob() public

  

  aljoscha

  authored and

  zentol

  committed
  1e48b72

  Copy full SHA for 1e48b72

Commits on Mar 1, 2018

• [FLINK-8810] Move end-to-end test scripts to end-to-end module

  Show description for a0336f2
  aljoscha

  committed
  a0336f2

  Copy full SHA for a0336f2

Commits on Feb 28, 2018

• [hotfix] Enable FILESYTEM_DEFAULT_OVERRIDE in FLIP-6 MiniClusterResource

  aljoscha

  committed
  f577930

  Copy full SHA for f577930

Commits on Feb 26, 2018

• [FLINK-8543] Don't call super.close() in AvroKeyValueSinkWriter

  Show description for 915213c
  aljoscha

  committed
  915213c

  Copy full SHA for 915213c

Commits on Feb 22, 2018

• [FLINK-8735] Add new StatefulJobSavepointMigrationITCase

  Show description for e96f28b
  aljoscha

  committed
  e96f28b

  Copy full SHA for e96f28b

• [FLINK-8735] Rename StatefulJobSavepointMigrationITCase

  Show description for 70a2e7e
  aljoscha

  committed
  70a2e7e

  Copy full SHA for 70a2e7e

Commits on Feb 21, 2018

• [FLINK-8668] Document how to set HADOOP_CLASSPATH for Flink

  aljoscha

  committed
  a435436

  Copy full SHA for a435436

Commits on Feb 20, 2018

• [FLINK-8600] Allow disabling truncate() check in BucketingSink

  Show description for 9da3152
  aljoscha

  committed
  9da3152

  Copy full SHA for 9da3152

Commits on Feb 19, 2018

• [FLINK-8668] Remove "hadoop classpath" from config.sh

  Show description for 9d5a785
  aljoscha

  committed
  9d5a785

  Copy full SHA for 9d5a785

Commits on Feb 17, 2018

• [FLINK-8411] Don't allow null in ListState.add()/addAll()

  aljoscha

  committed
  f99c4dd

  Copy full SHA for f99c4dd

Commits on Feb 14, 2018

• [hotfix] Remove costly checkState() statements from CEP SharedBuffer

  aljoscha

  committed
  75b8398

  Copy full SHA for 75b8398

Commits on Feb 7, 2018

• [FLINK-7760] Fix deserialization of NFA state in CEP library

  Show description for c212701
  aljoscha

  committed
  c212701

  Copy full SHA for c212701

Commits on Dec 6, 2017

• [hotfix] Properly delete temp flink dir in create_source_release.sh

  aljoscha

  committed
  5221a70

  Copy full SHA for 5221a70

Commits on Dec 5, 2017

• [FLINK-8186] Exclude flink-avro from flink-dist; fix AvroUtils loading

  Show description for f6e24ab
  aljoscha

  committed
  f6e24ab

  Copy full SHA for f6e24ab

Commits on Dec 4, 2017

• [hotfix] Remove empty line in UtilsTest

  aljoscha

  committed
  7c5a694

  Copy full SHA for 7c5a694

• [FLINK-8177] Replace TestingContainer by mock in YARN UtilsTest

  Show description for aa1f833
  aljoscha

  committed
  aa1f833

  Copy full SHA for aa1f833

Commits on Nov 29, 2017

• [FLINK-8166] Create hadoop-free binary in release scripts

  aljoscha

  committed
  820cea8

  Copy full SHA for 820cea8

Pagination

Previous

Next