Commits

Branch selector

 c12469e

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 4, 2023

• [FLINK-31645][network] Introduce the DiskIOScheduler

  

  WencongLiu

  authored and

  reswqa

  committed
  c12469e

  Copy full SHA for c12469e

• [FLINK-31645][network] Introduce the ProducerMergedPartitionFileReader

  

  WencongLiu

  authored and

  reswqa

  committed
  25eb0ce

  Copy full SHA for 25eb0ce

• [FLINK-32498][table] Fix the problem of array_max return type, it should be forced to be nullable.

  

  liuyongvs

  authored and

  dawidwys

  committed
  f3eb364

  Copy full SHA for f3eb364

• [FLINK-32516][table] Support to parse [CREATE OR ] REPLACE TABLE AS statement (apache#22934)

  Tartarus0zm

  authored
  76d2a8d

  Copy full SHA for 76d2a8d

• [FLINK-32511][FileSystems] Upgrade GCS connector to 2.2.15. This closes apache#22930

  Show description for f6d09c5
  jayadeep-jayaraman

  authored
  f6d09c5

  Copy full SHA for f6d09c5

• [FLINK-32390][Runtime / Web Frontend] Bump engine.io and socket.io in /flink-runtime-web/web-dashboard. This closes apache#22513

  Show description for 4b61e4b
  dependabot[bot]

  authored
  4b61e4b

  Copy full SHA for 4b61e4b

• [FLINK-32506][connectors/common] Add the benchmark for watermark aggregation when enabling the watermark alignment

  1996fanrui

  committed
  b402108

  Copy full SHA for b402108

• [FLINK-32473] Introduce base interfaces for time travel (apache#22928)

  hackergin

  authored
  0be9262

  Copy full SHA for 0be9262

• [FLINK-32310][table] Support enhanced show functions syntax (apache#22903)

  Show description for c090846
  

  chucheng92

  and

  luoyuxia

  authored
  c090846

  Copy full SHA for c090846

Commits on Jul 3, 2023

• [FLINK-32438][runtime] Merges AbstractZooKeeperHaServices with ZooKeeperMultipleComponentLeaderElectionHaServices

  Show description for a7bd6de
  XComp

  committed
  a7bd6de

  Copy full SHA for a7bd6de

• [FLINK-32436][runtime] Removes obsolete LeaderContender#getDescription()

  Show description for 310d859
  XComp

  committed
  310d859

  Copy full SHA for 310d859

• [hotfix] Adds contenderID to EmbeddedLeaderElection

  Show description for d126ff0
  XComp

  committed
  d126ff0

  Copy full SHA for d126ff0

• [FLINK-32370][tests] Ignore logged exceptions in JDBC driver e2e test

  FangYongs

  authored
  b229ecd

  Copy full SHA for b229ecd

• [FLINK-32259]-table-Add-ARRAY_JOIN-function

  Show description for 962e51f
  

  hanyuzheng7

  authored and

  dawidwys

  committed
  962e51f

  Copy full SHA for 962e51f

• [hotfix] Add missing release note on binding to localhost by default since Flink 1.15

  MartijnVisser

  committed
  aad2023

  Copy full SHA for aad2023

• [FLINK-30141][s3][filesystem] Increase retries on MinIO container startup

  

  RyanSkraba

  authored and

  XComp

  committed
  972e153

  Copy full SHA for 972e153

• [FLINK-32132][table-planner] Cast function CODEGEN does not work as expected when nullOnFailure enabled

  Show description for 1824c25
  

  zhougit86

  and

  xiaogang

  authored
  1824c25

  Copy full SHA for 1824c25

• [FLINK-32479][tests] Wait until request was processed before revoking leadership

  zentol

  committed
  8dfd811

  Copy full SHA for 8dfd811

• [FLINK-31783][runtime] Migrates DefaultLeaderElectionService from LeaderElectionDriver to MultipleComponentLeaderElectionDriver

  Show description for 728e679
  XComp

  committed
  728e679

  Copy full SHA for 728e679

Commits on Jul 1, 2023

• [FLINK-32201][runtime]Automatically determine if the shuffle descriptor needs to be offloaded by the blob server based on the number of ShuffleDescriptor edges.

  Show description for 4fe3560
  

  huwh

  authored and

  wanglijie95

  committed
  4fe3560

  Copy full SHA for 4fe3560

• [FLINK-32201][runtime] Abstract shuffle descriptor serialize related logic to ShuffleDescriptorSerializer.

  

  huwh

  authored and

  wanglijie95

  committed
  29e452e

  Copy full SHA for 29e452e

• [hotfix] migrate task deployment related tests to junit5 and assertj.

  

  huwh

  authored and

  wanglijie95

  committed
  a68c047

  Copy full SHA for a68c047

Commits on Jun 30, 2023

• [FLINK-32505][network] Fixed compilation error in ProducerMergedPartitionFileWriter.

  XComp

  committed
  c174086

  Copy full SHA for c174086

• [FLINK-31644][network] Implement the disk tier producer for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  00e10cd

  Copy full SHA for 00e10cd

• [FLINK-31644][network] Implement ProducerMergePartitionFile for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  8b0afcf

  Copy full SHA for 8b0afcf

• [FLINK-31644][network] Introduce the interface of partition file writer and reader for the tiered storage

  

  TanYuxin-tyx

  authored and

  reswqa

  committed
  a77aa65

  Copy full SHA for a77aa65

• [FLINK-28046][connectors] Mark SourceFunction interface as @deprecated

  

  afedulov

  authored and

  reswqa

  committed
  07bf511

  Copy full SHA for 07bf511

• [FLINK-32410] Replace new LinkedHashMap<>(size) with CollectionUtil.newLinkedHashMapWithExpectedSize(size)

  StefanRRichter

  committed
  1ef9973

  Copy full SHA for 1ef9973

• [FLINK-32410] Replace new LinkedHashSet<>(size) with CollectionUtil.newLinkedHashSetWithExpectedSize(size)

  StefanRRichter

  committed
  4c5bca0

  Copy full SHA for 4c5bca0

• [FLINK-32410] Replace new HashSet<>(size) with CollectionUtil.newHashSetWithExpectedSize(size)

  StefanRRichter

  committed
  4532e41

  Copy full SHA for 4532e41

• [FLINK-32410] Replace new HashMap<>(size) with CollectionUtil.newHashMapWithExpectedSize(size)

  StefanRRichter

  committed
  ab9445a

  Copy full SHA for ab9445a

• [FLINK-32495][connectors/common] Limit the CoordinatorExecutorThreadFactory to be a one-off

  1996fanrui

  committed
  9d7b166

  Copy full SHA for 9d7b166

• [hotfix] Migrate StreamExecutionEnvironmentTest to Junit5 and AssertJ

  1996fanrui

  committed
  6453a48

  Copy full SHA for 6453a48

• [FLINK-32495][connectors/common] Fix the bug that the shared thread factory causes the source alignment unit test to fail

  1996fanrui

  committed
  24e4795

  Copy full SHA for 24e4795

• [FLINK-32467][rpc] Move common RPC utils to rpc-core

  zentol

  authored
  167d564

  Copy full SHA for 167d564

Pagination

Previous

Next