Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 14, 2022

• [FLINK-29282][tests] Decouple Quickstart E2E test from Elasticsearch

  zentol

  authored
  db98322

  Copy full SHA for db98322

• [FLINK-29285][tests] Move TestUtils#getResource

  zentol

  authored
  469049a

  Copy full SHA for 469049a

• [FLINK-29101] ignore non canBePipelined consumedPartitionGroup in getAllSchedulableRegions.

  Show description for c0165a8
  

  reswqa

  authored and

  xintongsong

  committed
  c0165a8

  Copy full SHA for c0165a8

• [FLINK-29101] Use loop instead of recursive algorithm for maybeScheduleRegions to avoid stackOverFlow.

  

  reswqa

  authored and

  xintongsong

  committed
  f5764e9

  Copy full SHA for f5764e9

• [FLINK-29101] Filter the the execution vertex finished event for non-finished ConsumedPartitionGroup

  

  reswqa

  authored and

  xintongsong

  committed
  f78fcb5

  Copy full SHA for f78fcb5

• [hotfix] Let scheduledRegions using the set backed up by IdentityHashMap

  

  reswqa

  authored and

  xintongsong

  committed
  77eab72

  Copy full SHA for 77eab72

• [hotfix] make schedulingDownStreamTasksInBatchJobBenchmark more in line with the real scene.

  

  reswqa

  authored and

  xintongsong

  committed
  869233d

  Copy full SHA for 869233d

• [FLINK-28853] Address PR comments / Add Kafka and Pulsar split pausing tests

  mxm

  committed
  0612a99

  Copy full SHA for 0612a99

• [FLINK-28853][connector-base] Add source reader split alignment test

  

  Sebastian Mattheis

  authored and

  mxm

  committed
  2e5a803

  Copy full SHA for 2e5a803

• [FLINK-28853][connector-base] Add allow-unaligned-source-splits config option

  

  Sebastian Mattheis

  authored and

  mxm

  committed
  b9ccc78

  Copy full SHA for b9ccc78

• [FLINK-28853][pulsar] Implement pausing Pulsar splits in case of watermark drift

  

  dawidwys

  authored and

  mxm

  committed
  175a819

  Copy full SHA for 175a819

• [FLINK-28853][kafka] Implement pausing Kafka partitions in case of watermark drift

  

  dawidwys

  authored and

  mxm

  committed
  ea8f943

  Copy full SHA for ea8f943

• [FLINK-28853][source][connector-base] Add support for aligning individual splits

  Show description for ec2c33f
  

  dawidwys

  authored and

  mxm

  committed
  ec2c33f

  Copy full SHA for ec2c33f

• [FLINK-28853][connector-base] Add support for paused SplitFetcher.

  Show description for a22cc43
  

  Arvid Heise

  authored and

  mxm

  committed
  a22cc43

  Copy full SHA for a22cc43

• [FLINK-28853][connector-base] Revise threading model of SplitFetcher.

  Show description for 9b31810
  

  Arvid Heise

  authored and

  mxm

  committed
  9b31810

  Copy full SHA for 9b31810

• [FLINK-28928][tests] Add E2E test for hybrid shuffle mode.

  Show description for 8de6f92
  

  reswqa

  authored and

  xintongsong

  committed
  8de6f92

  Copy full SHA for 8de6f92

• [FLINK-28928][tests] Add IT test for hybrid shuffle mode.

  

  reswqa

  authored and

  xintongsong

  committed
  21ec759

  Copy full SHA for 21ec759

• [FLINK-29102] Fix unstable ChangelogLocalRecoveryITCase

  Show description for 545ce28
  

  fredia

  authored and

  HuangXingBo

  committed
  545ce28

  Copy full SHA for 545ce28

• [FLINK-29113][table-planner] Throw exception when finding at least one invalid table name in join hints

  Show description for d518086
  

  xuyangzhong

  authored and

  godfreyhe

  committed
  d518086

  Copy full SHA for d518086

Commits on Sep 13, 2022

• [FLINK-29262][docs] Document API compatibility guarantees

  zentol

  authored
  030baed

  Copy full SHA for 030baed

• [FLINK-29249][rpc] Drop RpcService#execute/scheduleRunnable

  zentol

  authored
  0bbee30

  Copy full SHA for 0bbee30

• [FLINK-27976][Web-UI] Allow order jobs by name

  

  eskabetxe

  authored and

  MartijnVisser

  committed
  a91501f

  Copy full SHA for a91501f

• [FLINK-29260][release] Wipe exclusion list when updating reference version

  zentol

  authored
  19ddba0

  Copy full SHA for 19ddba0

• [FLINK-27660][table] Improve Javadoc of TableEnvironment#createFunction

  wuchong

  committed
  3ff0ef8

  Copy full SHA for 3ff0ef8

• [FLINK-27660][table] add table api for registering function with resource uris

  

  HuangZhenQiu

  authored and

  wuchong

  committed
  fbd369c

  Copy full SHA for fbd369c

• [FLINK-29238] Wrong index information will be obtained after the downstream failover in hybrid full mode

  Show description for 12dfe6a
  

  reswqa

  authored and

  xintongsong

  committed
  12dfe6a

  Copy full SHA for 12dfe6a

• [hotfix] Avoid possible deadlock in SubpartitionView and FileDataManager.

  

  reswqa

  authored and

  xintongsong

  committed
  83f87b2

  Copy full SHA for 83f87b2

• [hotfix][release] Mark 1.15 as latest stable

  zentol

  authored
  5ddf4f2

  Copy full SHA for 5ddf4f2

• [hotfix][tests] Cleaned up JDK/assertj plugin warnings

  XComp

  committed
  dbae7ae

  Copy full SHA for dbae7ae

• [FLINK-29253][runtime] Removes synchronous close call from DefaultJobManagerRunnerRegistry#localCleanupAsync

  Show description for 4e99d64
  XComp

  committed
  4e99d64

  Copy full SHA for 4e99d64

• Revert "[FLINK-19869][connectors/jdbc] Add support for postgres UUID type"

  Show description for fa199c1
  MartijnVisser

  committed
  fa199c1

  Copy full SHA for fa199c1

• [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are idle

  PatrickRen

  committed
  d62df68

  Copy full SHA for d62df68

• [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema

  Show description for 84e5c63
  

  sjvanrossum

  authored and

  HuangXingBo

  committed
  84e5c63

  Copy full SHA for 84e5c63

Commits on Sep 12, 2022

• [FLINK-25868][build] Enable japicmp for all modules

  zentol

  committed
  ccdf270

  Copy full SHA for ccdf270

• [FLINK-25868][build] Use custom japicmp plugin version

  zentol

  committed
  8fb3da7

  Copy full SHA for 8fb3da7

Pagination

Previous

Next