Commits

Branch selector

 master

User selector

zhuzhurk

Datepicker

All time

Commit History

Commits on Jul 24, 2023

• [FLINK-32654][configuration] Deprecate ExecutionConfig#canEqual(obj)

  Show description for 5cda33d
  zhuzhurk

  committed
  5cda33d

Commits on Jan 31, 2023

• [FLINK-30828][table-planner] Let SortAggITCase#testLeadLag run in ALL_EXCHANGES_PIPELINED mode

  Show description for 9a5c2db
  zhuzhurk

  committed
  9a5c2db

Commits on Jan 30, 2023

• [hotfix] Remove legacy code which was not removed due merge conflicts

  zhuzhurk

  committed
  2ca7e41

• [FLINK-15325][coordination] Ignores the input locations of a ConsumePartitionGroup if the corresponding ConsumerVertexGroup is too large

  Show description for 76ebeb9
  zhuzhurk

  committed
  76ebeb9

• [FLINK-15325][coordination] Set the ConsumedPartitionGroup/ConsumerVertexGroup to its corresponding ConsumerVertexGroup/ConsumedPartitionGroup

  zhuzhurk

  committed
  c0bfb0b

• [hotfix] Migrate a few location preference tests to JUnit5

  zhuzhurk

  committed
  00c2ebd

Commits on Aug 23, 2022

• [FLINK-28139][docs] Add documentation for speculative execution

  Show description for 70d9f6c
  zhuzhurk

  committed
  70d9f6c

Commits on Aug 15, 2022

• [FLINK-28878][tests] Increase slot request timeout of PipelinedRegionSchedulingITCase

  Show description for 5f8f387
  zhuzhurk

  committed
  5f8f387

Commits on Aug 3, 2022

• [FLINK-28771][runtime] Assign speculative execution attempt with correct CREATED timestamp

  Show description for e1a74df
  zhuzhurk

  committed
  e1a74df

Commits on Jul 26, 2022

• [FLINK-28610][runtime] Enable speculative execution for sources

  Show description for 9192446
  zhuzhurk

  committed
  9192446

Commits on Jul 25, 2022

• [FLINK-28585][runtime] Ensure all the concurrent executions of SpeculativeExecutionVertex to share the same input splits

  Show description for 7611928
  zhuzhurk

  committed
  7611928

Commits on Jul 22, 2022

• [FLINK-28586][runtime] Ignore compatibility warnings for SplitEnumeratorContext#registeredReadersOfAttempts() and SplitEnumeratorContext#sendEventToSourceReader(int,int,SourceEvent)

  Show description for 863222e
  zhuzhurk

  committed
  863222e

• [FLINK-28586][runtime] Improve SourceCoordinator and SourceCoordinatorContext to support execution attempt level split requests and events

  Show description for 7129c2e
  zhuzhurk

  committed
  7129c2e

• [FLINK-28586][runtime] Refactor some OperatorCoordinator methods to be aware of execution attempts

  zhuzhurk

  committed
  bedcc3f

• [FLINK-28586][runtime] Let SourceCoordinator context know whether supportsConcurrentExecutionAttempts

  zhuzhurk

  committed
  9af271f

• [FLINK-28586][runtime] Introduce method ExecutionVertex#getCurrentExecution(int attemptNumber)

  zhuzhurk

  committed
  79d93f2

• [hotfix] Migrate SourceCoordinator tests to JUnit5

  zhuzhurk

  committed
  b27b1a9

• [FLINK-28138][runtime] Add metric numEffectiveSpeculativeExecutions for speculative execution

  Show description for 19b0a95
  zhuzhurk

  committed
  19b0a95

• [FLINK-28138][runtime] Add metric numSlowExecutionVertices for speculative execution

  zhuzhurk

  committed
  2173b45

• [hotfix] Remove duplicated inherited interfaces of AdaptiveBatchScheduler

  zhuzhurk

  committed
  3b1165b

Commits on Jul 20, 2022

• [FLINK-28612][runtime] SpeculativeScheduler cancels pending slot allocation after canceling pending executions

  Show description for 3278995
  zhuzhurk

  committed
  3278995

• [hotfix][runtime] Strengthen SpeculativeScheduler and its tests

  Show description for 94ece41
  zhuzhurk

  committed
  94ece41

Commits on Jul 13, 2022

• [FLINK-28137][runtime] Enable SimpleExecutionSlotAllocator to do batch slot request timeout check

  zhuzhurk

  committed
  265612c

• [hotfix] Migrate SlotSharingExecutionSlotAllocatorTest to JUnit5

  zhuzhurk

  committed
  c75a242

• [FLINK-28137][runtime] Introduce SpeculativeScheduler

  Show description for 81c739a
  zhuzhurk

  committed
  81c739a

• [hotfix][tests] Merge DefaultSchedulerBuilder and AdaptiveBatchSchedulerBuilder

  Show description for 51010a1
  zhuzhurk

  committed
  51010a1

• [hotfix] Remove the initialCapacity param from the constructor of DualKeyLinkedMap

  Show description for 331264c
  zhuzhurk

  committed
  331264c

Commits on Jul 11, 2022

• [FLINK-28402][runtime] Create FailureHandlingResultSnapshot with the truly failed execution

  Show description for edd10a1
  zhuzhurk

  committed
  edd10a1

• [hotfix] Migrate failure handling tests to JUnit5

  zhuzhurk

  committed
  777d780

Commits on Jul 6, 2022

• [FLINK-28392][runtime] DefaultExecutionDeployer avoid retrieving executions from ExecutionGraph#currentExecutions

  Show description for e5c4e3f
  zhuzhurk

  committed
  e5c4e3f

Commits on Jul 1, 2022

• [FLINK-28271][runtime] Add config options for speculative scheduler

  Show description for 2aae497
  zhuzhurk

  committed
  2aae497

• [FLINK-28134][runtime] Wait for all the executions to be terminated before finishing a job

  Show description for 67aeb81
  zhuzhurk

  committed
  67aeb81

• [FLINK-28134][runtime] Rework TaskDeploymentDescriptorFactory to accept an execution to deploy

  Show description for e73225e
  zhuzhurk

  committed
  e73225e

• [FLINK-28134][runtime] Introduce SpeculativeExecutionJobVertex and SpeculativeExecutionVertex

  Show description for b96d476
  zhuzhurk

  committed
  b96d476

Commits on Jun 28, 2022

• [FLINK-28258][runtime] Introduce ExecutionHistory to host historical executions for each execution vertex

  Show description for 8540b8d
  zhuzhurk

  committed
  8540b8d

Pagination

PreviousNext