Commits

Branch selector

 master

User selector

reswqa

Datepicker

All time

Commit History

Commits on Sep 14, 2023

• [FLINK-33076][network] Reduce serialization overhead of broadcast emit from ChannelSelectorRecordWriter.

  reswqa

  committed
  e77dc91

• [hotfix] Parameterlize RecordWriterTest and migrate it to junit5

  reswqa

  committed
  e198c09

Commits on Sep 13, 2023

• [FLINK-30906][task] TwoInputStreamTask and MultipleInputStreamTask passes wrong configuration when create input processor

  reswqa

  committed
  70f4c40

Commits on Sep 8, 2023

• [FLINK-32620][sink] Fix the bug that sinkv2 does not set coLocationGroupKey for writer.

  reswqa

  committed
  c4a76e2

• [FLINK-32620][sink] Migrate DiscardingSink to sinkv2.

  reswqa

  committed
  f4ec68c

Commits on Aug 3, 2023

• [FLINK-32685][streaming] Do not touch the branch related to changelog writer if it is already available.

  reswqa

  committed
  5e3cad5

Commits on Aug 1, 2023

• [FLINK-32098][runtime] Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO

  

  reswqa

  authored and

  XComp

  committed
  c6d58e1

Commits on Jul 24, 2023

• [FLINK-32640][Network] Measure backpressure time for tiered storage hybrid shuffle.

  reswqa

  committed
  eab99b6

• [FLINK-32640][Network] Measure backpressure time for legacy hybrid shuffle.

  reswqa

  committed
  51b0df6

Commits on Jul 20, 2023

• [hotfix][streaming] Reactive sanity check for windowOperator's mergeable state.

  reswqa

  committed
  b332483

Commits on Jul 10, 2023

• [hotfix][streaming] Fix typo in DataStream.java and DataStream.scala.

  reswqa

  committed
  9aecb0c

Commits on Jul 5, 2023

• [FLINK-32459][connector] Force set the parallelism of SocketTableSource to 1

  reswqa

  committed
  4bc408b

Commits on Jun 25, 2023

• [hotfix] Remove local timeout for Hybrid and Tiered result partition test.

  reswqa

  committed
  c2ea128

• [hotfix] Extract IgnoreShutdownRejectedExecutionHandler.

  reswqa

  committed
  0a3a62e

Commits on Jun 16, 2023

• [hotfix][state] Fix incorrect comments of channel input state redistribution.

  reswqa

  committed
  65c3ce4

Commits on Jun 7, 2023

• [FLINK-32254][runtime] FineGrainedSlotManager may not allocate enough taskmanagers if maxSlotNum is configured

  Show description for a008f25
  reswqa

  committed
  a008f25

• [hotfix] Migrate SlotManagerConfigurationTest to Junit5 and AssertJ.

  reswqa

  committed
  9e12704

Commits on May 25, 2023

• [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters

  reswqa

  committed
  366d01d

• [FLINK-32161][test] Migrate and remove legacy WorkingDirectoryResource.

  reswqa

  committed
  b783da3

• [FLINK-32161][test] Migrate and remove legacy RocksDBResource.

  reswqa

  committed
  d853b71

• [FLINK-32161][test] Migrate and remove legacy BlobServerResource.

  reswqa

  committed
  c3409dc

• [FLINK-32161][test] Migrate and remove legacy LogLevelRule.

  reswqa

  committed
  a48c0ba

• [FLINK-32161][test] Migrate and remove legacy MultipartUploadResource and NettyLeakDetectionResource.

  reswqa

  committed
  ff49c65

• [FLINK-32161][test] Migrate and remove legacy ZookeeperResource.

  reswqa

  committed
  d79f4c1

• [hotfix] Auto injects TestLoggerExtension for flink-tests

  reswqa

  committed
  d40d410

• [hotfix] Exclude META-INF/services/org.junit.jupiter.api.extension.Extension for flink-runtime as it still used by JUnit4 modules.

  reswqa

  committed
  b60973d

Commits on May 16, 2023

• [FLINK-32060][test] Migrate subclasses of BatchAbstractTestBase in table and other modules to JUnit5

  reswqa

  committed
  ce286c9

• [FLINK-32060][test] Introduce NoOpTestExtension to make subclass unaware of @testtemplate

  reswqa

  committed
  a8c7570

Commits on May 15, 2023

• [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml.

  reswqa

  committed
  4dc2a98

Commits on May 11, 2023

• [FLINK-18808][streaming] Include side outputs in numRecordsOut metric

  Show description for 2468539
  

  2 peopleauthored and

  pnowojski

  committed
  2468539

• [FLINK-18808][streaming] Introduce OutputWithRecordsCountCheck.

  Show description for 835beb0
  

  2 peopleauthored and

  pnowojski

  committed
  835beb0

• [FLINK-18808][streaming] Introduce helper builder class for StreamConfigChainer.

  Show description for d5276d7
  

  2 peopleauthored and

  pnowojski

  committed
  d5276d7

Commits on May 9, 2023

• [FLINK-32027][runtime] Fix the potential concurrent reading bug of index file for SortMergeShuffle.

  Show description for 63443ae
  reswqa

  committed
  63443ae

• [hotfix] Remove unnecessary public modifier for PartitionedFileWriteReadTest

  reswqa

  committed
  cd3d6ef

Commits on May 6, 2023

• [FLINK-31764][runtime] Get rid of numberOfRequestedOverdraftMemorySegments in LocalBufferPool.

  reswqa

  committed
  3379c2c

Pagination

PreviousNext