Commits

Branch selector

 master

User selector

pltbkd

Datepicker

All time

Commit History

Commits on Sep 29, 2022

• [FLINK-29348][table] DynamicFilteringEvent can be stored in the CoordinatorStore if it's received before the listener source coordinator is started.

  Show description for 7bae0eb
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  7bae0eb

Commits on Sep 8, 2022

• [FLINK-29132][rest] Cleanup subtask attempt metrics according to the JobDetails to avoid memory leak.

  Show description for 26eeabf
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  26eeabf

Commits on Aug 23, 2022

• [FLINK-28995][hive] HiveSourceDynamicFileEnumerator filters out a partition without matching if one of the fields is null but its type is not nullable

  Show description for 2322791
  

  pltbkd

  authored and

  godfreyhe

  committed
  2322791

Commits on Aug 9, 2022

• [FLINK-28711][hive] Hive source supports dynamic filtering

  Show description for 0dc8890
  

  pltbkd

  authored and

  godfreyhe

  committed
  0dc8890

Commits on Aug 7, 2022

• [FLINK-28709][table] Introduce ExecutionOrderEnforcerOperator to ensure the source with dynamic filtering is executed after the DynamicFilteringData is collected

  Show description for b085978
  

  pltbkd

  authored and

  godfreyhe

  committed
  b085978

• [FLINK-28709][table] Introduce DynamicFilteringData and the DynamicFilteringDataCollectorOperator to build and distribute the data

  Show description for 3a8e71e
  

  pltbkd

  authored and

  godfreyhe

  committed
  3a8e71e

• [FLINK-28709][source] Introduce coordinatorListeningID in SourceCoordinator to listen to events from other coordinators

  Show description for 9bda677
  

  pltbkd

  authored and

  godfreyhe

  committed
  9bda677

Commits on Aug 1, 2022

• [FLINK-28588][rest] Acquire information of all current executions in REST handlers if applicable

  Show description for f436b20
  

  pltbkd

  authored and

  bigdata_ng

  committed
  f436b20

• [FLINK-28588][rest] MetricStore supports to store and query metrics of multiple execution attempts of a subtask.

  

  pltbkd

  authored and

  bigdata_ng

  committed
  1a48fd5

• [FLINK-28588][rest] Archive all current executions in ArchivedExecutionVertex.

  

  pltbkd

  authored and

  bigdata_ng

  committed
  44c00db

• [FLINK-28588][rest] Add blocked task manager count and blocked slot count in ResourceOverview and ClusterOverview

  

  pltbkd

  authored and

  bigdata_ng

  committed
  0263b55

• [FLINK-28588][rest] Add blocked flag in TaskManagerInfo and TaskManagerDetailsInfo

  

  pltbkd

  authored and

  bigdata_ng

  committed
  5393868

• [hotfix][runtime][tests] Migrates some tests to Junit5

  

  pltbkd

  authored and

  bigdata_ng

  committed
  247d426

Commits on Jul 5, 2022

• [FLINK-28240][network] Fix the bug that NetworkBufferPool#getRequestedSegmentsUsage may throw ArithmeticException.

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  c6b3a8a

Commits on Jun 8, 2022

• [FLINK-27910][connector/filesystem] Register the timer to enforce rolling policy when file sink starts from scratch.

  Show description for d036c23
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  d036c23

Commits on Apr 19, 2022

• [FLINK-27148][checkpoint] Skip snapshotting the coordinators state or the master state if the pending checkpoint has been disposed.

  Show description for 2c608b8
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  2c608b8

Commits on Apr 8, 2022

• [FLINK-26394][checkpoint] Cancel the checkpoint completable future when checkpoint is aborting.

  

  pltbkd

  authored and

  becketqin

  committed
  31222b9

Commits on Mar 14, 2022

• [FLINK-26610][connectors/filesystem] Do not add state handlers for file compaction if compaction is not explicitly disabled.

  Show description for 9ef8873
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  9ef8873

• [FLINK-26610][datastream] Check whether sink uid is set when expanding sink topology.

  Show description for 04a56cb
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  04a56cb

Commits on Mar 13, 2022

• [hotfix][connectors/filesystem] Make the compactor tests to extend TestLogger.

  Show description for b8e7fc3
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  b8e7fc3

• [hotfix][connectors/filesystem] Rename the operatorName in topology of the state handler operators.

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  8d7194a

• [FLINK-26580][connectors/filesystem] CompactorOperatorStateHandler can accept multiple remaining in-progress files from different buckets.

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  fafac08

• [FLINK-26580][connectors/filesystem] Fix the bug that FileSink CompactCoordinator adds in-progress committable as toCompacted

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  b4e2690

Commits on Mar 11, 2022

• [FLINK-26564][connectors/filesystem] Fix the bug that CompactCoordinatorStateHandler doesn't properly handle the cleanup-in-progress requests.

  Show description for 155f17d
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  155f17d

Commits on Mar 8, 2022

• [FLINK-26440][connector/filesystem] Make CompactorOperatorStateHandler supporting unaligned checkpoint.

  Show description for 13b203f
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  13b203f

Commits on Mar 3, 2022

• [FLINK-26403][datastream] Fixes the endOfInput logic of sink writer and committer.

  Show description for 2c9d64e
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  2c9d64e

• Revert "[FLINK-26314][connectors/filesystem] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase."

  Show description for 64367a2
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  64367a2

Commits on Feb 28, 2022

• [FLINK-26314][connectors/filesystem] Disable unaligned checkpoints for StreamingExecutionFileSinkITCase.

  Show description for 69276df
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  69276df

Commits on Feb 21, 2022

• [FLINK-26235][connectors/filesystem] CompactingFileWriter and PendingFileRecoverable should not be exposed to users.

  Show description for 3c99b00
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  3c99b00

• [FLINK-26233][connectors/filesystem] Fix the FileSinkCompactionSwitchITCase.testSwitchingCompaction.

  Show description for 8af2495
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  8af2495

Commits on Feb 17, 2022

• [FLINK-26180][connectors/filesystem] Update docs to introduce the compaction for FileSink.

  Show description for 8b6ca8e
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  8b6ca8e

Commits on Feb 16, 2022

• [FLINK-25583][connectors/filesystem] Add IT cases for compaction in FileSink.

  Show description for aec2d38
  

  pltbkd

  authored and

  gaoyunhaii

  committed
  aec2d38

• [FLINK-25583][connectors/filesystem] Add compaction support for FileSink.

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  255d656

• [FLINK-25583][connectors/filesystem] Add bucketId and compactedFileToCleanup in FileSinkCommittable, delete compactedFileToCleanup in FileCommitter.

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  824752c

• [FLINK-25583][connectors/filesystem] Add the getPath and getSize methods in PendingFileRecoverable.

  

  pltbkd

  authored and

  gaoyunhaii

  committed
  b2ea16c

Pagination

PreviousNext