Apache Flink

Settings | Report Duplicate

9

I Use This!

Very High Activity

Commits : Listings

Analyzed about 13 hours ago. based on code collected about 19 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Apr 30, 2023 — Apr 30, 2024 Showing page 7 of 1,175 Search / Filter on:
[FLINK-34543][datastream] Introduce the SortPartition API on PartitionWindowedStream	Wencong Liu	More...				about 2 months ago
[FLINK-34543][datastream] Introduce the Aggregate API on PartitionWindowedStream	Wencong Liu	More...				about 2 months ago
[FLINK-34543][datastream] Introduce the Reduce API on PartitionWindowedStream	Wencong Liu	More...				about 2 months ago
[FLINK-34543][datastream] Introduce the MapPartition API on PartitionWindowedStream	Wencong Liu	More...				about 2 months ago
[FLINK-34624][state/changelog] Enable local recovery in ChangelogRescalingITCase (#24470)	Yanfei Lei	More...				about 2 months ago
[FLINK-32261][table] Add built-in MAP_UNION function	Hanyu Zheng	More...				about 2 months ago
[FLINK-34494][table] Migrate ReplaceIntersectWithSemiJoinRule to java	Jacky Lau	More...				about 2 months ago
[FLINK-34643][tests] Fix JobIDLoggingITCase	Roman Khachatryan	More...				about 2 months ago
[FLINK-32079][checkpoint] Support to read/write checkpoint metadata of merged files (#24480)	Hangxiang Yu	More...				about 2 months ago
[FLINK-32513][core] Add predecessor caching	Jeyhun Karimov	More...				about 2 months ago
[FLINK-34632][runtime/checkpointing] Log checkpoint ID when logging checkpoint processing delay (#24474)	Mingliang Liu	More...				about 2 months ago
[FLINK-34647][core] Optimize Path normalization (#24473)	David Schlosnagle	More...				about 2 months ago
[FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError	Weijie Guo	More...				about 2 months ago
[FLINK-34483][docs] Improve the documentation of 'state.checkpoints.dir' and 'state.checkpoint-storage' (#24401)	Yanfei Lei	More...				about 2 months ago
[FLINK-34622][docs] fix typo in execution_mode.md	Yu Chen	More...				about 2 months ago
[FLINK-34616][python] Fix python dist dir doesn't clean when open method construct resource has exception.	Jacky Lau	More...				about 2 months ago
[FLINK-34617][docs] Correct the Javadoc of org.apache.flink.api.common.time.Time	Yun Tang	More...				about 2 months ago
[FLINK-25544][streaming][JUnit5 Migration] The api package of module flink-stream-java (#24429)	Jiabao Sun	More...				about 2 months ago
[FLINK-34543][datastream] Introduce the PartitionWindowedStream	Wencong Liu	More...				about 2 months ago
[FLINK-34401][docs-zh] Translate "Flame Graphs" page into Chinese (#24279)	lxliyou001	More...				about 2 months ago
Revert "[FLINK-33532][network] Move the serialization of ShuffleDescriptorGroup out of the RPC main thread]"	caodizhou	More...				about 2 months ago
[FLINK-34582][realse][python] Updates cibuildwheel to support cpython3.11 wheel package	xingbo	More...				about 2 months ago
[FLINK-33210] Introduce lineage graph relevant interfaces (#23626)	Fang Yong	More...				about 2 months ago
Modify obvious errors in the doc.	DamonXue	More...				about 2 months ago
[FLINK-34517][table]fix environment configs ignored when calling procedure operation (#24397)	JustinLee	More...				about 2 months ago
[FLINK-34580][rest] Do not erase "pipeline.classpaths" config during REST job deploy	Ferenc Csaky	More...				about 2 months ago
[hotfix] Add toString to StateHandleDownloadSpec	Piotr Nowojski	More...				about 2 months ago
[hotfix][e2e] Fix naming of MAX_NUM_METRICS	Piotr Nowojski	More...				about 2 months ago
[hotfix][e2e] Fix wait_oper_metric_num_in_records	Piotr Nowojski	More...				about 2 months ago
[FLINK-25544][streaming][JUnit5 Migration] The util package of module flink-stream-java	Jiabao Sun	More...				about 2 months ago

←
1
2
3
4
5
6
7
8
9
10
11
…
1174
1175
→