Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 21, 2020

• [FLINK-19483][python][e2e] Update PyFlink end-to-end tests to remove the unnecessary installation of zip (apache#13702)

  HuangXingBo

  authored
  2a9af7f

  Copy full SHA for 2a9af7f

• [FLINK-19605][table-runtime-blink] Implement cumulative windowing for window aggregate operator

  Show description for 9423cf1
  wuchong

  authored
  9423cf1

  Copy full SHA for 9423cf1

Commits on Oct 20, 2020

• [FLINK-19022] Fail TaskManagerRunner fatally if TaskExecutor terminates unexpectedly

  Show description for 0ff7d7a
  tillrohrmann

  committed
  0ff7d7a

  Copy full SHA for 0ff7d7a

• [FLINK-19022] Fail DispatcherResourceManagerComponent fatally if ResourceManager terminates unexpectedly

  Show description for b813c99
  tillrohrmann

  committed
  b813c99

  Copy full SHA for b813c99

• [FLINK-19022] Fail fatally if DispatcherGatewayService terminates unexpectedly in AbstractDispatcherLeaderProcess

  Show description for 11a4232
  tillrohrmann

  committed
  11a4232

  Copy full SHA for 11a4232

• [FLINK-19022] Let TaskExecutor, Dispatcher, RM fail fatally if onStart throws a Throwable

  Show description for 9e31510
  tillrohrmann

  committed
  9e31510

  Copy full SHA for 9e31510

• [FLINK-19022][rpc] Log if RpcEndpoint failed its termination

  Show description for 806b9f3
  tillrohrmann

  committed
  806b9f3

  Copy full SHA for 806b9f3

• [hotfix] Correct TestingDispatcherGatewayService closeAsync behavior

  Show description for d5f8a7c
  tillrohrmann

  committed
  d5f8a7c

  Copy full SHA for d5f8a7c

• [hotfix] Introduce ResourceManagerService to make DispatcherResourceManagerComponent easier to test

  Show description for 08fbf82
  tillrohrmann

  committed
  08fbf82

  Copy full SHA for 08fbf82

• [hotfix] Let DispatcherResourceManagerComponent accept AutoCloseableAsync instead of WebMonitorEndpoint

  Show description for 643d79b
  tillrohrmann

  committed
  643d79b

  Copy full SHA for 643d79b

• [hotfix] Add FlinkMatchers.willNotComplete to assert that a future times out

  tillrohrmann

  committed
  75d15bd

  Copy full SHA for 75d15bd

• [FLINK-19732] Disable checkpointing in BATCH mode

  Show description for 8fee135
  kl0u

  committed
  8fee135

  Copy full SHA for 8fee135

• [FLINK-19679][task] Migrate AlternatingCheckpointBarrierHandler to the generic SingleCheckpointBarrierHandler

  pnowojski

  committed
  79316f8

  Copy full SHA for 79316f8

• [hotfix][test] Remove unused code in AlternatingCheckpointBarrierHandlerTest

  pnowojski

  committed
  5835fa2

  Copy full SHA for 5835fa2

• [FLINK-19679][task] Migrate CheckpointBarrierAligner to the generic SingleCheckpointBarrierHandler

  Show description for e4fae5d
  pnowojski

  committed
  e4fae5d

  Copy full SHA for e4fae5d

• [FLINK-19679][task] Replace CheckpointBarrierUnaligner with more generic SingleCheckpointBarrierHandler

  Show description for 9dd2c35
  pnowojski

  committed
  9dd2c35

  Copy full SHA for 9dd2c35

• [hotfix][test] Fix measuring alignmentDurationNanosMax

  Show description for 8ffe245
  pnowojski

  committed
  8ffe245

  Copy full SHA for 8ffe245

• [hotfix][task] Drop CheckpointBarrierHandler#isBlocked method

  Show description for e9c5de6
  pnowojski

  committed
  e9c5de6

  Copy full SHA for e9c5de6

• [FLINK-19458] Fix ZK-related CI instabilities

  Show description for 947b3d3
  rmetzger

  committed
  947b3d3

  Copy full SHA for 947b3d3

• [FLINK-19728][yarn][test] Disable external resource related tests in TaskExecutorProcessSpecContainerResourcePriorityAdapterTest.

  Show description for ffa94e0
  xintongsong

  committed
  ffa94e0

  Copy full SHA for ffa94e0

• [FLINK-19728] Revert "[FLINK-19689][yarn][test] Fix TaskExecutorProcessSpecContainerResourcePriorityAdapterTest failure for Hadoop 2.10+."

  Show description for a5bc7d2
  xintongsong

  committed
  a5bc7d2

  Copy full SHA for a5bc7d2

• [FLINK-19707][table-runtime] Refactor table streaming file sink

  Show description for 15cc3a7
  JingsongLi

  authored
  15cc3a7

  Copy full SHA for 15cc3a7

• [FLINK-19664][e2e] Upload logs before tests time out

  Show description for 4ca00ed
  rmetzger

  committed
  4ca00ed

  Copy full SHA for 4ca00ed

• [FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute

  Show description for 16f97fb
  wuchong

  authored
  16f97fb

  Copy full SHA for 16f97fb

• [FLINK-16579][table] Upgrade Calcite version to 1.26 for Flink SQL (apache#13577)

  Show description for dc1da6a
  danny0405

  authored
  dc1da6a

  Copy full SHA for dc1da6a

• [FLINK-19579] Add the SideOutputTransformation translator

  Show description for c5f7d19
  kl0u

  committed
  c5f7d19

  Copy full SHA for c5f7d19

• [FLINK-19578] Add PartitionTransformation translator

  Show description for de7234b
  kl0u

  committed
  de7234b

  Copy full SHA for de7234b

• [FLINK-19577] Add the UnionTransformation translator

  Show description for 835ea03
  kl0u

  committed
  835ea03

  Copy full SHA for 835ea03

• [FLINK-19575] Add LegacySourceTransformation translator

  Show description for f005ba2
  kl0u

  committed
  f005ba2

  Copy full SHA for f005ba2

• [FLINK-19576] Add LegacySinkTransformation translator

  Show description for e5d3036
  kl0u

  committed
  e5d3036

  Copy full SHA for e5d3036

• [FLINK-19574] Add SourceTransformation translator

  Show description for acc9904
  kl0u

  committed
  acc9904

  Copy full SHA for acc9904

• [FLINK-19368][hive] TableEnvHiveConnectorITCase fails with Hive-3.x

  Show description for eb6d6f3
  lirui-apache

  authored
  eb6d6f3

  Copy full SHA for eb6d6f3

• [FLINK-19716][Kinesis][EFO] Unable to use Assume Role with EFO record publisher

  Show description for f4e4046
  

  dannycranmer

  authored and

  tzulitai

  committed
  f4e4046

  Copy full SHA for f4e4046

• [hotfix][yarn] Remove unused function in YarnResourceManagerDriver

  Show description for 9b612a0
  

  KarmaGYZ

  authored and

  xintongsong

  committed
  9b612a0

  Copy full SHA for 9b612a0

• [FLINK-19649][sql-parser] Fix unparse method of sql create table without columns (apache#13651)

  gsralex

  authored
  2a64773

  Copy full SHA for 2a64773

Pagination

Previous

Next