ASF Git Repos - flink.git/search

2022-05-20	Zhu Zhu	[hotfix][runtime] Add serialVersionUID to ExecutionVertexID	commit \| commitdiff \| tree
2022-05-17	liujiangang	[FLINK-26909][Client/Job Submission] Allow to set parallelis...	commit \| commitdiff \| tree
2022-03-20	Lijie Wang	[FLINK-25226][doc] Add documentation about the AdaptiveBatch...	commit \| commitdiff \| tree
2022-03-10	Lijie Wang	[FLINK-26517][runtime] Normalize the decided parallelism...	commit \| commitdiff \| tree
2022-03-10	Lijie Wang	[hotfix][runtime] Fix typos.	commit \| commitdiff \| tree
2022-02-18	Lijie Wang	[FLINK-25225][e2e] Add e2e TPCDS tests to run against...	commit \| commitdiff \| tree
2022-02-17	Lijie Wang	[FLINK-26168][runtime] The judgment of chainable ignores...	commit \| commitdiff \| tree
2022-02-16	Lijie Wang	[FLINK-26148][runtime] Change the format of adaptive...	commit \| commitdiff \| tree
2022-02-15	Lijie Wang	[FLINK-25046][runtime] Convert unspecified edge to...	commit \| commitdiff \| tree
2022-02-15	Lijie Wang	[hotfix][doc] Fix typos.	commit \| commitdiff \| tree
2022-02-11	Lijie Wang	[FLINK-26004][runtime] Introduce ForwardForConsecutiveHashPa...	commit \| commitdiff \| tree
2022-02-11	Lijie Wang	[FLINK-25996][runtime] Introduce job property isDynamicGraph...	commit \| commitdiff \| tree
2022-01-29	Lijie Wang	[FLINK-25045][runtime] Introduce AdaptiveBatchScheduler	commit \| commitdiff \| tree
2022-01-27	Lijie Wang	[FLINK-25035][runtime] SingleInputGate supports consuming...	commit \| commitdiff \| tree
2022-01-27	Lijie Wang	[FLINK-25035][runtime] Move consumedSubpartitionIndex...	commit \| commitdiff \| tree
2022-01-25	Lijie Wang	[FLINK-25668][runtime] Support to compute network memory...	commit \| commitdiff \| tree
2022-01-24	Lijie Wang	[FLINK-25669][runtime] Support register operator coordinator...	commit \| commitdiff \| tree
2022-01-24	Lijie Wang	[FLINK-25036][runtime] Introduce vertex wise scheduling...	commit \| commitdiff \| tree
2022-01-20	Lijie Wang	[FLINK-25033][runtime] RegionPartitionGroupReleaseStrategy...	commit \| commitdiff \| tree
2022-01-20	Lijie Wang	[FLINK-25033][runtime] DefaultExecutionTopology supports...	commit \| commitdiff \| tree
2022-01-20	Lijie Wang	[hotfix][runtime] Add checkNotNull for Supplier/Function...	commit \| commitdiff \| tree
2022-01-15	Lijie Wang	[FLINK-25034][runtime] Let InputGateDeploymentDescriptor...	commit \| commitdiff \| tree
2022-01-15	Lijie Wang	[FLINK-25034][runtime] Support flexible number of subpartiti...	commit \| commitdiff \| tree
2022-01-11	Lijie Wang	[FLINK-25032][runtime] Enable to create a dynamic graph.	commit \| commitdiff \| tree
2022-01-11	Lijie Wang	[FLINK-25032][runtime] Allow parallelism of ExecutionJobVert...	commit \| commitdiff \| tree
2022-01-11	Lijie Wang	[FLINK-25032][runtime] Allow ExecutionJobVertex to...	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-12-09	Lijie Wang	[FLINK-25011][runtime] Introduce vertex parallelism...	commit \| commitdiff \| tree
2021-12-06	Lijie Wang	[FLINK-25031][runtime] Job finishes iff all job vertices...	commit \| commitdiff \| tree
2021-12-06	Lijie Wang	[hotfix][runtime] Remove useless method ExecutionGraph...	commit \| commitdiff \| tree
2021-12-01	Lijie Wang	[FLINK-24980] Introduce numBytesProduced counter into...	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-09-28	Lijie Wang	[FLINK-24375] Let name of flush thread in RecordWriter...	commit \| commitdiff \| tree
2021-08-30	Thesharing	[FLINK-23833][coordination] Rename IntermediateResult...	commit \| commitdiff \| tree
2021-08-30	Thesharing	[FLINK-23833][coordination] Individually clean up the...	commit \| commitdiff \| tree
2021-08-30	Thesharing	[FLINK-23833][coordination] Rename PartitionReleaseStrategy...	commit \| commitdiff \| tree
2021-08-30	Thesharing	[FLINK-23833][coordination] Make PartitionReleaseStrategy...	commit \| commitdiff \| tree
2021-08-30	Thesharing	[FLINK-23833][coordination] Add ConsumedPartitionGroup...	commit \| commitdiff \| tree
2021-08-30	Thesharing	[hotfix] Replace deprecated Assert.assertThat	commit \| commitdiff \| tree
2021-08-21	Thesharing	[FLINK-23172][docs] Fix broken links to Task Failure...	commit \| commitdiff \| tree
2021-08-19	Zhu Zhu	[FLINK-23806][runtime] Avoid StackOverflowException...	commit \| commitdiff \| tree
2021-08-15	Thesharing	[FLINK-22767][coordination] Optimize the initialization...	commit \| commitdiff \| tree
2021-08-15	Thesharing	[hotfix] Replace deprecated Assert.assertThat in LocalInputP...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[FLINK-22773][coordination] Optimize the construction...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[FLINK-22773][coordination] Introduce DefaultLogicalEdge	commit \| commitdiff \| tree
2021-08-11	Thesharing	[FLINK-22773][coordination] Make DefaultLogicalTopology...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[FLINK-22773][coordination] Make DefaultLogicalPipelinedRegi...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Remove unused method JobEdge#connectDataSet	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Fix checkstyle violations in JobEdge	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Cleanup PipelinedRegionComputeUtil	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Replace deprecated Assert.assertThat in DefaultSche...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Add the @Test tag for DefaultExecutionTopologyTest...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Remove unused variables in DefaultExecutionGraph...	commit \| commitdiff \| tree
2021-08-11	Thesharing	[hotfix] Fix typos in ExecutionGraph	commit \| commitdiff \| tree
2021-08-05	kevin.cyj	[FLINK-22675][runtime] Add lifecycle methods to ShuffleMaster	commit \| commitdiff \| tree
2021-08-05	kevin.cyj	[FLINK-23249][runtime] Introduce ShuffleMasterContext...	commit \| commitdiff \| tree
2021-08-05	kevin.cyj	[FLINK-22674][runtime] Provide JobID when applying...	commit \| commitdiff \| tree
2021-08-05	kevin.cyj	[FLINK-23214][runtime] Make ShuffleMaster a cluster...	commit \| commitdiff \| tree
2021-08-04	Thesharing	[FLINK-23172][docs] Fix broken links to the failover...	commit \| commitdiff \| tree
2021-08-04	Thesharing	[FLINK-23172][docs] Fix broken links to the restart...	commit \| commitdiff \| tree
2021-08-04	Thesharing	[FLINK-23599] Remove JobVertex#connectIdInput and its...	commit \| commitdiff \| tree
2021-08-04	Thesharing	[hotfix] Fix checkstyle in JobVertex and DefaultExecutionGra...	commit \| commitdiff \| tree
2021-07-29	Thesharing	[FLINK-23354][blob] Limit the size of ShuffleDescriptors...	commit \| commitdiff \| tree
2021-07-27	Thesharing	[FLINK-23218][coordination] Distribute the ShuffleDescriptor...	commit \| commitdiff \| tree
2021-07-27	Thesharing	[FLINK-23005][coordination] Cache compressed serialized...	commit \| commitdiff \| tree
2021-07-26	Thesharing	[FLINK-23005][coordination] Introduce CompressedSerializedValue	commit \| commitdiff \| tree
2021-07-26	Thesharing	[FLINK-23005][coordination] Pass ConsumedPartitionGroup...	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-07-19	jinxing64	[FLINK-22676][coordination] The partition tracker stops...	commit \| commitdiff \| tree
2021-07-15	Thesharing	[FLINK-22017][coordination] Allow BLOCKING result partition...	commit \| commitdiff \| tree
2021-07-15	Thesharing	[FLINK-22017][coordination] Get the ConsumedPartitionGroup...	commit \| commitdiff \| tree
2021-07-06	jinxing64	[FLINK-15031][runtime] Scheduler enriches network memory...	commit \| commitdiff \| tree
2021-07-06	jinxing64	[FLINK-15031][runtime] Netty Shuffle Service supports...	commit \| commitdiff \| tree
2021-06-30	Gen Luo	[FLINK-22954][runtime] Avoid StackOverflowException...	commit \| commitdiff \| tree
2021-06-28	Thesharing	[FLINK-23078] Add SchedulerBenchmarkBase#teardown	commit \| commitdiff \| tree
2021-06-24	Thesharing	[FLINK-23078] Add SchedulerBenchmarkUtils#shutdownTestingUti...	commit \| commitdiff \| tree
2021-06-04	Thesharing	[FLINK-22863][runtime] Fix ArrayIndexOutOfBoundsException...	commit \| commitdiff \| tree
2021-03-31	Thesharing	[FLINK-22037][benchmark] Remove the redundant blocking...	commit \| commitdiff \| tree
2021-03-30	kevin.cyj	[FLINK-20757][network] Optimize data broadcast for...	commit \| commitdiff \| tree
2021-03-30	Thesharing	[FLINK-21332] Optimize releasing result partitions...	commit \| commitdiff \| tree
2021-03-30	Thesharing	[hotfix] Rename IntermediateResultPartition#getConsumers...	commit \| commitdiff \| tree
2021-03-30	Thesharing	[hotfix] Rename ExecutionVertex#getConsumedPartitions...	commit \| commitdiff \| tree
2021-03-29	Thesharing	[FLINK-21330] Optimize the performance of PipelinedRegionSch...	commit \| commitdiff \| tree
2021-03-29	kevin.cyj	[FLINK-19938][network] Implement shuffle data read...	commit \| commitdiff \| tree
2021-03-26	kevin.cyj	[FLINK-20740][network] Introduce a separated buffer...	commit \| commitdiff \| tree
2021-03-26	Thesharing	[FLINK-21331] Optimize calculating tasks to restart...	commit \| commitdiff \| tree
2021-03-26	Thesharing	[hotfix] Make IterableUtils.flatMap return Iterable...	commit \| commitdiff \| tree
2021-03-26	Thesharing	[FLINK-21975] Remove hamcrest dependency from SchedulerBench...	commit \| commitdiff \| tree
2021-03-25	Thesharing	[FLINK-21731] Add benchmarks for DefaultScheduler's...	commit \| commitdiff \| tree
2021-03-25	Thesharing	[hotfix] Make SchedulingDownstreamTasksInBatchJobBenchmarkTe...	commit \| commitdiff \| tree
2021-03-25	kevin.cyj	[FLINK-21951][network] Fix the wrong if condition in...	commit \| commitdiff \| tree
2021-03-18	Thesharing	[FLINK-21328] Optimize the initialization of DefaultExecutio...	commit \| commitdiff \| tree
2021-03-18	Thesharing	[hotfix] Remove generic from LogicalTopology and its...	commit \| commitdiff \| tree
next

Apache Flink

RSS Atom