ASF Git Repos - flink.git/search

4 days ago	Zhu Zhu	[FLINK-28271][runtime] Add config options for speculative...	commit \| commitdiff \| tree
4 days ago	Zhu Zhu	[FLINK-28134][runtime] Wait for all the executions...	commit \| commitdiff \| tree
4 days ago	Zhu Zhu	[FLINK-28134][runtime] Rework TaskDeploymentDescriptorFactor...	commit \| commitdiff \| tree
4 days ago	Zhu Zhu	[FLINK-28134][runtime] Introduce SpeculativeExecutionJobVert...	commit \| commitdiff \| tree
7 days ago	Zhu Zhu	[FLINK-28258][runtime] Introduce ExecutionHistory to...	commit \| commitdiff \| tree
11 days ago	Zhu Zhu	[FLINK-28133][runtime] Rework DefaultScheduler to directly...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Refine tests to ensure the consistenc...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Remove unnecessary fields from...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Remove unnecessary fields from...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Simplify ExecutionVertexID retrieval...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Rework MetricGroup methods to...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Refactor ExecutionAttemptID...	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[FLINK-17295][runtime] Introduce ExecutionGraphID	commit \| commitdiff \| tree
2022-05-20	Zhu Zhu	[hotfix][runtime] Add serialVersionUID to ExecutionVertexID	commit \| commitdiff \| tree
2022-05-02	Zhu Zhu	[FLINK-27460][runtime] Remove unused notifyPartitionDataAvai...	commit \| commitdiff \| tree
2021-12-30	Zhu Zhu	[FLINK-18295][runtime] Change IntermediateDataSet to...	commit \| commitdiff \| tree
2021-12-30	Zhu Zhu	[FLINK-18295][runtime] Change result partition to explicitly...	commit \| commitdiff \| tree
2021-11-08	Zhu Zhu	[FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCas...	commit \| commitdiff \| tree
2021-11-04	Zhu Zhu	[FLINK-19142][runtime] Fix slot hijacking after task...	commit \| commitdiff \| tree
2021-11-04	Zhu Zhu	[FLINK-19142][runtime] Use LocationPreferenceSlotSelectionSt...	commit \| commitdiff \| tree
2021-11-04	Zhu Zhu	[hotfix][tests] Factor PerJobMiniClusterFactoryTest...	commit \| commitdiff \| tree
2021-11-04	Zhu Zhu	[hotfix][runtime] Rename `previousExecutionGraphAllocations...	commit \| commitdiff \| tree
2021-11-04	Zhu Zhu	[hotfix][runtime] Refactor testing methods out from...	commit \| commitdiff \| tree
2021-08-19	Zhu Zhu	[FLINK-23806][runtime] Avoid StackOverflowException...	commit \| commitdiff \| tree
2021-07-20	Zhu Zhu	[FLINK-22677][runtime] AdaptiveScheduler requires partition...	commit \| commitdiff \| tree
2021-07-20	Zhu Zhu	[FLINK-22677][runtime] DefaultScheduler supports async...	commit \| commitdiff \| tree
2021-03-15	Zhu Zhu	[FLINK-21707][runtime] Do not trigger scheduling of...	commit \| commitdiff \| tree
2021-03-04	Zhu Zhu	[FLINK-21576][runtime] Remove legacy ExecutionVertex...	commit \| commitdiff \| tree
2020-12-23	Zhu Zhu	[FLINK-20439][runtime] Rename `scheduleOrUpdateConsumers...	commit \| commitdiff \| tree
2020-12-23	Zhu Zhu	[FLINK-20439][runtime] Rework scheduleOrUpdateConsumers...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-19921][runtime] Remove legacy RestartStrategy	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-19920][runtime] Remove legacy FailoverStrategy	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-19919][runtime] Remove legacy scheduling in...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime, tests] Add test to verify that...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime, tests] Add test to verify that...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime, tests] Add test to verify allocation...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime, tests] Rework legacy tests to...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime, tests] Remove ExecutionGraphMetricsTe...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime, tests] Rework ArchivedExecutionGraphT...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][hotfix][runtime] Rename SchedulerNG#setMainThr...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[hotfix][runtime] Rename SchedulerTestingUtils#createSchedul...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-17760][runtime] Set InternalTaskFailuresListener...	commit \| commitdiff \| tree
2020-12-17	Zhu Zhu	[FLINK-20626][runtime] Fix issue concurrent of concurrent...	commit \| commitdiff \| tree
2020-11-24	Zhu Zhu	[FLINK-20285][runtime] LazyFromSourcesSchedulingStrategy...	commit \| commitdiff \| tree
2020-11-17	Zhu Zhu	[FLINK-19806][runtime] Harden DefaultScheduler for...	commit \| commitdiff \| tree
2020-11-10	Zhu Zhu	[FLINK-19994][runtime] Remove unused interface method...	commit \| commitdiff \| tree
2020-11-10	Zhu Zhu	[FLINK-19994][runtime] Do not force iteration job to...	commit \| commitdiff \| tree
2020-11-10	Zhu Zhu	[FLINK-19994][hotfix][runtime] Build pipelined regions...	commit \| commitdiff \| tree
2020-11-02	Zhu Zhu	[FLINK-19703][runtime] Wrap TaskExecutionState with...	commit \| commitdiff \| tree
2020-11-02	Zhu Zhu	[FLINK-19703][runtime] Replace the param 'isCallback...	commit \| commitdiff \| tree
2020-11-02	Zhu Zhu	[FLINK-19703][hotfix][runtime] Remove the while-loop...	commit \| commitdiff \| tree
2020-10-27	Zhu Zhu	[hotifx][runtime] Print root cause of logical slot...	commit \| commitdiff \| tree
2020-10-27	Zhu Zhu	[hotfix][tests] Let SlotSharingExecutionSlotAllocatorTest...	commit \| commitdiff \| tree
2020-10-13	Zhu Zhu	[FLINK-19570][tests] Avoid directly creating ExecutionJobVer...	commit \| commitdiff \| tree
2020-10-13	Zhu Zhu	[FLINK-19570][tests] Remove preferred location tests...	commit \| commitdiff \| tree
2020-09-24	Zhu Zhu	[FLINK-19189][e2e] Let TPC-DS tests run in POINTWISE_EDGES_P...	commit \| commitdiff \| tree
2020-09-24	Zhu Zhu	[FLINK-19189][runtime] Enable pipelined region scheduling...	commit \| commitdiff \| tree
2020-09-23	Zhu Zhu	[FLINK-19286][runtime] Improve region sorting performance	commit \| commitdiff \| tree
2020-09-23	Zhu Zhu	[FLINK-19286][runtime] Improve region vertex sorting...	commit \| commitdiff \| tree
2020-09-23	Zhu Zhu	[FLINK-19286][runtime] Replace java streams on critical...	commit \| commitdiff \| tree
2020-09-11	Zhu Zhu	[FLINK-17016][runtime] Enable to use pipelined region...	commit \| commitdiff \| tree
2020-09-11	Zhu Zhu	[FLINK-17016][runtime] Use SlotSharingExecutionSlotAllocator...	commit \| commitdiff \| tree
2020-09-11	Zhu Zhu	[hotfix] Fix checkstyle violations in JobGraph and...	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[FLINK-14870][runtime] Drop the nullable assumption...	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[FLINK-14870][runtime] Drop the nullable assumption...	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[FLINK-14870][runtime] Drop the nullable assumption...	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[hotfix][runtime] Always invoke SlotPool#releaseTaskManager...	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[hotfix][runtime] Close SlotPool in main thread	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[FLINK-14870][runtime] Ensure JobVertex slot sharing...	commit \| commitdiff \| tree
2020-09-10	Zhu Zhu	[hotfix][runtime] Add missing Nullable annotations...	commit \| commitdiff \| tree
2020-08-25	Zhu Zhu	[FLINK-17330[runtime] Merge cyclic dependent pipelined...	commit \| commitdiff \| tree
2020-08-25	Zhu Zhu	[FLINK-17330[runtime] Extract common methods out from...	commit \| commitdiff \| tree
2020-08-25	Zhu Zhu	[hotfix][runtime] Avoid unnecessary map building in...	commit \| commitdiff \| tree
2020-08-18	Zhu Zhu	[FLINK-18972][runtime] BulkSlotProviderImpl disables...	commit \| commitdiff \| tree
2020-08-10	Zhu Zhu	[FLINK-18859][tests] Increase timeout of ExecutionGraphNotEn...	commit \| commitdiff \| tree
2020-08-05	Zhu Zhu	[FLINK-18690][runtime] Implement LocalInputPreferredSlotShar...	commit \| commitdiff \| tree
2020-08-05	Zhu Zhu	[FLINK-18690][runtime] Introduce ExecutionSlotSharingGroup...	commit \| commitdiff \| tree
2020-06-23	Zhu Zhu	[FLINK-18407][runtime] Harden SlotPoolImpl#maybeRemapOrphane...	commit \| commitdiff \| tree
2020-06-23	Zhu Zhu	[hotfix][runtime] Simplify SlotPoolImpl#maybeRemapOrphanedAl...	commit \| commitdiff \| tree
2020-06-22	Zhu Zhu	[FLINK-18372][runtime] Fix NPE problem when a slot...	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[FLINK-17019][runtime] Remap orphaned slot allocation...	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[FLINK-17019][runtime] Change primary key re-insertion...	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[FLINK-17019][runtime] Enable DualKeyLinkedMap for...	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[FLINK-17019][runtime] Make clear the iteration order...	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[hotfix][runtime] Make DualKeyLinkedMap package private	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[FLINK-17019][runtime] Fulfill slot requests in request...	commit \| commitdiff \| tree
2020-06-18	Zhu Zhu	[FLINK-17019][runtime] All pending requests removal...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[hotfix][runtime] Narrow down the access scope of SlotExecut...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[hotfix][runtime] Narrow down the access scope of DefaultExe...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[FLINK-17018][runtime] Use OneSlotPerExecutionSlotAllocator...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[FLINK-17018][runtime] Introduce OneSlotPerExecutionSlotAllo...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[FLINK-17018][runtime] Extract common logics of DefaultExecu...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[hotfix][runtime] Move shared static test methods of...	commit \| commitdiff \| tree
2020-06-16	Zhu Zhu	[hotfix][runtime] Move shared static test methods of...	commit \| commitdiff \| tree
2020-06-11	Zhu Zhu	[FLINK-17017][runtime] SchedulerImpl supports bulk...	commit \| commitdiff \| tree
2020-06-11	Zhu Zhu	[FLINK-17017][runtime] Introduce BulkSlotProvider which...	commit \| commitdiff \| tree
2020-06-11	Zhu Zhu	[FLINK-17017][runtime] Allow nullable timeout for streaming...	commit \| commitdiff \| tree
2020-06-11	Zhu Zhu	[FLINK-17017][runtime] Allow to disable batch slot...	commit \| commitdiff \| tree
2020-06-11	Zhu Zhu	[FLINK-17017][runtime] Enable to get allocated slots...	commit \| commitdiff \| tree
2020-06-11	Zhu Zhu	[FLINK-17017][runtime] Enable to get whether a physical...	commit \| commitdiff \| tree
next

Apache Flink

RSS Atom