flink
https://github.com/apache/flink
Java
Apache Flink
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
Java not yet supported72 Subscribers
Add a CodeTriage badge to flink
Help out
- Issues
- [FLINK-37645] Improve existsUnboundedSource by avoiding duplicate check transformations
- [FLINK-38050][UI] Correct Flink UI Dropdown Width
- [FLINK-38866][flink-table-planner] Passing timestamp precision from window strategy to window operators to support non-compact BinaryRowData timestamps
- [FLINK-38992] Expire associated state together for non-time over windows
- [FLINK-38939][runtime] Pause sources until the 1st checkpoint to prioritize processing recovered records
- [FLINK-39005][format] Users can choose to use the fast reader feature.
- [FLINK-36808][table-planner] Fix LookupJoin bug when used with filterable table source
- [FLINK-38444][table] Join unique keys should not contain null values
- [FLINK-38510][table-planner] Remove targetColumns from the digest generation in SinkReuser
- [hotfix][docs] Add Kafka-to-Kafka SQL example to documentation
- Docs
- Java not yet supported