Apache Flink

Settings | Report Duplicate

9

I Use This!

Very High Activity

Commits : Listings

Analyzed about 7 hours ago. based on code collected about 8 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Nov 12, 2024 — Nov 12, 2025 Showing page 1 of 1,243 Search / Filter on:
[hotfix][examples] Add Python examples on how to read binary data from Kafka	Dian Fu	More...				about 13 hours ago
[hotfix][table] Add `LOOKAHEAD` in `SqlRichExplain`	Sergey Nuyanzin	More...				about 15 hours ago
[FLINK-38676][runtime] Remove `DefaultSlotAssigner#getSlotsPerTaskExecutor` code duplication	Yuepeng Pan	More...				about 22 hours ago
[FLINK-38504][table] Add restore tests for delta join (#27117)	Xuyang	More...				1 day ago
[hotfix] [docs] Ververica URL and Product Name has been updated	Naci Simsek	More...				1 day ago
[FLINK-38436][doc] Add vector search doc (#27216)	Shengkai	More...				1 day ago
[hotfix][table] Simplify parsing of `REFRESH MODE` for `MATERIALIZED TABLE`	Sergey Nuyanzin	More...				1 day ago
[FLINK-38654][release] Add doc link for release-2.2	Hang Ruan	More...				2 days ago
[FLINK-33217][table] `UNNEST` fails with on `LEFT JOIN` with `NOT NULL` type in array	Sergey Nuyanzin	More...				2 days ago
[FLINK-38654][release] Build doc for release-2.2 branch	Hang Ruan	More...				3 days ago
[FLINK-38654][release] Add new version 2.3 and update GHA nightly build versions	Hang Ruan	More...				3 days ago
Update version to 2.3-SNAPSHOT	Hang Ruan	More...				3 days ago
[FLINK-38640][table-planner] Fix NPE in DeltaJoinUtil#isFilterOnOneSetOfUpsertKeys (#27204)	Xuyang	More...				3 days ago
[FLINK-38674][table] Support schema definition for Materialized tables while `CREATE` operation	Sergey Nuyanzin	More...				4 days ago
[FLINK-38104][table] Add table api support for ML_PREDICT (#27108)	Hao Li	More...				4 days ago
[FLINK-37865][Docs] Add documentation for AsyncTableFunction. This closes #26611	Alan Sheinberg	More...				6 days ago
[FLINK-15973][python] Optimize the execution plan where the same Python UDF is referred in multiple places (#27203)	Dian Fu	More...				6 days ago
[FLINK-38642][checkpoint] Specify thread pool to avoid CheckpointCoordinatorTest hang	Rui Fan	More...				6 days ago
[hotfix][table] Replace deprecated `JavaConversions` with `JavaConverters` in `CalcITCase`	Sergey Nuyanzin	More...				6 days ago
[FLINK-38268][core] Fix incorrect serialization of VARIANT type FLOAT	Jinkun Liu	More...				6 days ago
[FLINK-38547] [flink-protobuf] Upgrade protobuf to 4.32.1 (#27137)	Khaled Hammouda	More...				6 days ago
[hotfix][docs] Use `mvnw` in flink-docs README	Sergey Nuyanzin	More...				6 days ago
[hotfix] Disable changelog with heap-timer state tests (#27194)	Zakelly	More...				7 days ago
[FLINK-38488][tests] Use 'throws Exception' instead of try-catch-fail in tests in flink-tests (#27092)	Mingliang Liu	More...				7 days ago
[FLINK-38532][table] Make `FRESHNESS` Optional for Materialized Tables	Ramin Gharib	More...				7 days ago
[hotfix] Suppress log for reusing sst files (#27197)	Zakelly	More...				7 days ago
[FLINK-38591][python] Add Python AsyncFunction example (#27198)	Dian Fu	More...				7 days ago
[FLINK-38564][docs]FLIP-537: Add documentation to explain how Source re-assign splits once recovery in sources.md. (#27177)	Hongshun Wang	More...				7 days ago
[FLINK-37308] Support pauseOrResumeSplits in HybridSource (#26483)	Xingcan Cui	More...				7 days ago
[FLINK-38563][python][docs] Update documentation of Python AsyncFunction (#27195)	Dian Fu	More...				8 days ago

←
1
2
3
4
5
6
7
8
9
…
1242
1243
→