Commits

Branch selector

 master

User selector

mxm

Datepicker

All time

Commit History

Commits on Jul 29, 2019

• Merge pull request #9177: [BEAM-7305] Set job name in Jet Runner

  mxm

  authored
  85bb004

  Copy full SHA for 85bb004

Commits on Jul 27, 2019

• [BEAM-7366] Restore Spotless check for Flink Runner

  Show description for 3d087be
  mxm

  committed
  3d087be

  Copy full SHA for 3d087be

Commits on Jul 20, 2019

• Merge pull request #9110: Revert incorrect doc on flink runner version

  mxm

  authored
  23a879f

  Copy full SHA for 23a879f

Commits on Jul 4, 2019

• Merge pull request #8937: [BEAM-7305] Add Jet Runner to Get Started documentation page

  mxm

  authored
  73735cc

  Copy full SHA for 73735cc

Commits on Jun 21, 2019

• Merge pull request #8910: [BEAM-7601] Fix typo on community page

  mxm

  authored
  553c560

  Copy full SHA for 553c560

Commits on Jun 15, 2019

• Merge pull request #8850: [BEAM-7144] Fix for rescaling problem on Flink >= 1.6

  mxm

  authored
  89c5abf

  Copy full SHA for 89c5abf

• [BEAM-7144] Fix for rescaling problem on Flink >= 1.6

  Show description for 1642655
  mxm

  committed
  1642655

  Copy full SHA for 1642655

Commits on Jun 14, 2019

• Merge pull request #8857: [BEAM-7551] Checkpoint Flink's ImpulseSourceFunction

  mxm

  authored
  f2067fe

  Copy full SHA for f2067fe

• [BEAM-7551] Checkpoint Flink's ImpulseSourceFunction

  Show description for 64abb60
  mxm

  committed
  64abb60

  Copy full SHA for 64abb60

Commits on Jun 12, 2019

• [website] Add artifact staging document to design documents

  mxm

  committed
  1159dd6

  Copy full SHA for 1159dd6

Commits on Jun 11, 2019

• Merge pull request #8812: [BEAM-7044] portable Spark: support stateful dofns

  mxm

  authored
  4f22c54

  Copy full SHA for 4f22c54

Commits on Jun 10, 2019

• [website] Correct date in release blog post

  Show description for 6cb1fd5
  mxm

  committed
  6cb1fd5

  Copy full SHA for 6cb1fd5

Commits on Jun 5, 2019

• Merge pull request #8753: Update Flink artifact name in archetypes

  mxm

  authored
  7c8530d

  Copy full SHA for 7c8530d

• Resolve Flink artifact name dynamically

  mxm

  committed
  a3a608d

  Copy full SHA for a3a608d

• [BEAM-5664] Improve cancellation of portable pipelines

  Show description for f3d2187
  mxm

  committed
  f3d2187

  Copy full SHA for f3d2187

Commits on Jun 4, 2019

• [BEAM-7487] Avoid throwing an exception in FlinkRunnerResult#cancel

  Show description for 949c972
  mxm

  committed
  949c972

  Copy full SHA for 949c972

• Update Flink artifact name in archetypes

  Show description for 5f26c5d
  mxm

  committed
  5f26c5d

  Copy full SHA for 5f26c5d

Commits on Jun 3, 2019

• [BEAM-2943] Check existence of to-be-staged files in PipelineResources

  Show description for 2839706
  mxm

  committed
  2839706

  Copy full SHA for 2839706

Commits on May 31, 2019

• Merge pull request #8715: [BEAM-7442][BEAM-5650] Read sequentially from bounded sources in UnboundedSourceWrapper

  mxm

  authored
  207f34e

  Copy full SHA for 207f34e

• [BEAM-7442][BEAM-5650] Read sequentially from bounded sources in UnboundedSourceWrapper

  Show description for b57c996
  mxm

  committed
  b57c996

  Copy full SHA for b57c996

• Merge pull request #8699: [BEAM-7305] Fix issues in and extend documentation for Hazelcast Jet Runner

  mxm

  authored
  ab6b65e

  Copy full SHA for ab6b65e

Commits on May 28, 2019

• [cleanup] Remove unncecessary Flink timestamp from UnboundedSourceWrapper

  Show description for 23115ce
  

  mxm

  authored and

  tweise

  committed
  23115ce

  Copy full SHA for 23115ce

• Merge pull request #8696: [BEAM-7436] Use coder for Flink's encoded key instead of falling back to Kryo

  mxm

  authored
  266ab37

  Copy full SHA for 266ab37

Commits on May 27, 2019

• Merge pull request #8693: [BEAM-7421] Add missing transform payload translator for Reshuffle

  Show description for 8bf679c
  mxm

  authored
  8bf679c

  Copy full SHA for 8bf679c

• Merge pull request #8694: [cleanup] Remove dead code from Flink Runner

  mxm

  authored
  1da00e2

  Copy full SHA for 1da00e2

• [BEAM-7436] Use coder for Flink's encoded key instead of falling back to Kryo

  Show description for 1ffe760
  mxm

  committed
  1ffe760

  Copy full SHA for 1ffe760

• [cleanup] Remove dead code from Flink Runner

  Show description for 9ed7ca2
  mxm

  committed
  9ed7ca2

  Copy full SHA for 9ed7ca2

• [BEAM-7421] Add missing transform payload translator for Reshuffle

  Show description for 42cfb31
  mxm

  committed
  42cfb31

  Copy full SHA for 42cfb31

Commits on May 24, 2019

• Merge pull request #8678: [BEAM-7417] Fix incorrect command on flink runner docs

  mxm

  authored
  aa8709e

  Copy full SHA for aa8709e

Commits on May 23, 2019

• Merge pull request #8637: [BEAM-7305] Make Jet Runner usable and documented

  mxm

  authored
  9a7b60f

  Copy full SHA for 9a7b60f

Commits on May 22, 2019

• Merge pull request #8624: [BEAM-7366] Include the project's SourceSets in Spotless target

  mxm

  authored
  38c62a8

  Copy full SHA for 38c62a8

• Move StateContextsTest to let it execute as part of the tests

  mxm

  committed
  809c335

  Copy full SHA for 809c335

• Apply Spotless after fixing source directory detection

  mxm

  committed
  c8f3e88

  Copy full SHA for c8f3e88

• [BEAM-7366] Include the project's SourceSets in Spotless target

  Show description for be8d10f
  mxm

  committed
  be8d10f

  Copy full SHA for be8d10f

Commits on May 21, 2019

• [BEAM-7378] Add trigger to Python Flink PVR tests for Kafka module

  Show description for 385f842
  mxm

  committed
  385f842

  Copy full SHA for 385f842

Pagination

Previous

Next