8000 Commits · sundeep/flink · GitHub

More Web Proxy on the site http://driver.im/

Commits

Commits on Dec 7, 2022

[FLINK-30189][runtime] HsSubpartitionFileReader may load data that has been consumed from memory

reswqa
authored and
xintongsong
committed

Commits on Dec 1, 2022

[FLINK-27944][runtime] Input channel metric will no longer be registered multiple times

authored and
pnowojski
committed
[hotfix] Migrate NettyShuffleEnvironmentTest to Junit5 and AssertJ.

reswqa
authored and
pnowojski
committed

Commits on Nov 17, 2022

[FLINK-29975][runtime] Mark HYBRID_FULL result partition as re-consumable.

reswqa
authored and
xintongsong
committed

Commits on Nov 16, 2022

[FLINK-29818] fix the unstable test 8000 HsResultPartitionTest.testAvailability

reswqa
authored and
xintongsong
committed
[FLINK-29818] Calculate the release number instead of the survival number for full spilling strategy

reswqa
authored and
xintongsong
committed
[hotfix] Fix an incorrect test case in NetworkBufferTest

reswqa
authored and
xintongsong
committed

Commits on Oct 31, 2022

[FLINK-28889] HsResultPartition support broadcast optimize

reswqa
authored and
xintongsong
committed
[FLINK-28889] fail fast when multiple consumer is not allowed but register many times

reswqa
authored and
xintongsong
committed
[FLINK-28889] Assign an unique identifier for each downstream consumer.

reswqa
authored and
xintongsong
committed
[FLINK-28889] HsFileDataManager supports multiple consumer.

reswqa
authored and
xintongsong
committed
[FLINK-28889] Introduce HsSubpartitionConsumerMemoryDataManager and let HsMemoryDataManager supports multiple consumer.

reswqa
authored and
xintongsong
committed
[FLINK-28889] HsBufferContext supports multiple consumer.

reswqa
authored and
xintongsong
committed
[FLINK-28889] Full spilling strategy is no longer consider consuming progress.

reswqa
authored and
xintongsong
committed
[hotfix] Migrate ResultPartitionFactoryTest to JUnit5 and AssertJ.

reswqa
authored and
xintongsong
committed
[FLINK-29728] TablePlanner prevents Flink from starting is working directory is a symbolic link

reswqa
authored and
xintongsong
committed
[FLINK-28102] Flink AkkaRpcSystemLoader fails when temporary directory is a symlink

reswqa
authored and
xintongsong
committed
[hotfix] Migrate FileUtilsTest to Junit5 and AssertJ.

reswqa
authored and
xintongsong
committed

Commits on Oct 25, 2022

[hotfix] fix typo in HiveOptions.

reswqa
authored and
MartijnVisser
committed

Commits on Oct 19, 2022

[FLINK-29419] Disable HybridShuffleITCase.

reswqa
authored and
HuangXingBo
committed

Commits on Oct 18, 2022

[FLINK-29641][tests] SortMergeResultPartitionReadSchedulerTest#testCreateSubpartitionReader is not stable
reswqa
authored

Commits on Oct 17, 2022

[FLINK-29419] Disable testHybridFullExchanges and testHybridFullExchangesRestart in HybridShuffleITCase temporarily.

reswqa
authored and
HuangXingBo
committed

Commits on Sep 30, 2022

Commits on Sep 28, 2022

[FLINK-29431] Exceptions during job graph serialization lock up client

reswqa
authored and
xintongsong
committed
[hotfix] Migrate StreamingJobGraphGeneratorTest all tests to assertj and make testing method package private

reswqa
authored and
xintongsong
committed
[FLINK-29425] Hybrid full spilling strategy triggering spilling frequently

reswqa
authored and
xintongsong
committed

Commits on Sep 26, 2022

[hotfix] fix the problem that BatchShuffleItCase not subject to configuration.

reswqa
authored and
xintongsong
committed

Commits on Sep 14, 2022

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

reswqa
authored and
xintongsong
committed

0