Commits

Branch selector

 master

User selector

reswqa

All time

Commit History

Commits on Jan 19, 2024

• [hotfix] peekNextBufferSubpartitionId shouldn't throw UnsupportedDataTypeException

  

  reswqa

  authored and

  dawidwys

  committed
  8dd28a2

  Copy full SHA for 8dd28a2

Commits on Sep 14, 2023

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

  reswqa

  committed
  e77dc91

  Copy full SHA for e77dc91

• [hotfix] Parameterlize RecordWriterTest and migrate it to junit5

  reswqa

  committed
  e198c09

  Copy full SHA for e198c09

Commits on Sep 13, 2023

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

  reswqa

  committed
  70f4c40

  Copy full SHA for 70f4c40

Commits on Sep 8, 2023

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

  reswqa

  committed
  c4a76e2

  Copy full SHA for c4a76e2

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

  reswqa

  committed
  f4ec68c

  Copy full SHA for 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

  Copy full SHA for 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

  Copy full SHA for c6d58e1

Commits on Jul 24, 2023

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

  reswqa

  committed
  eab99b6

  Copy full SHA for eab99b6

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

  reswqa

  committed
  51b0df6

  Copy full SHA for 51b0df6

Commits on Jul 20, 2023

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

  reswqa

  committed
  b332483

  Copy full SHA for b332483

Commits on Jul 10, 2023

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

  reswqa

  committed
  9aecb0c

  Copy full SHA for 9aecb0c

Commits on Jul 5, 2023

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

  reswqa

  committed
  4bc408b

  Copy full SHA for 4bc408b

Commits on Jun 25, 2023

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

  reswqa

  committed
  c2ea128

  Copy full SHA for c2ea128

• [hotfix] Extract IgnoreShutdownRejectedExecutionHandler.

  reswqa

  committed
  0a3a62e

  Copy full SHA for 0a3a62e

Commits on Jun 16, 2023

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

  reswqa

  committed
  65c3ce4

  Copy full SHA for 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

  Copy full SHA for a008f25

• [hotfix] Migrate SlotManagerConfigurationTest to Junit5 and AssertJ.

  reswqa

  committed
  9e12704

  Copy full SHA for 9e12704

Commits on May 25, 2023

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

  reswqa

  committed
  366d01d

  Copy full SHA for 366d01d

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

  reswqa

  committed
  b783da3

  Copy full SHA for b783da3

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

  reswqa

  committed
  d853b71

  Copy full SHA for d853b71

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

  reswqa

  committed
  c3409dc

  Copy full SHA for c3409dc

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

  reswqa

  committed
  a48c0ba

  Copy full SHA for a48c0ba

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

  reswqa

  committed
  ff49c65

  Copy full SHA for ff49c65

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

  reswqa

  committed
  d79f4c1

  Copy full SHA for d79f4c1

• [hotfix] Auto injects TestLoggerExtension for flink-tests

  reswqa

  committed
  d40d410

  Copy full SHA for 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

  Copy full SHA for b60973d

Commits on May 16, 2023

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

  reswqa

  committed
  ce286c9

  Copy full SHA for ce286c9

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

  reswqa

  committed
  a8c7570

  Copy full SHA for 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

  Copy full SHA for 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

  Copy full SHA for 2468539

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

  Show description for 835beb0
  

  2 peopleauthored and

  pnowojski

  committed
  835beb0

  Copy full SHA for 835beb0

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

  Show description for d5276d7
  

  2 peopleauthored and

  pnowojski

  committed
  d5276d7

  Copy full SHA for 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

  Copy full SHA for 63443ae

• [hotfix] Remove unnecessary public modifier for PartitionedFileWriteReadTest

  reswqa

  committed
  cd3d6ef

  Copy full SHA for cd3d6ef