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 supported70 Subscribers
Add a CodeTriage badge to flink
Help out
- Issues
- [FLINK-40780][runtime] Make FORWARD-to-REBALANCE downgrade on parallelism mismatch configurable
- [FLINK-40785][build] Pick google-java-format by the JDK that runs Maven
- [FLINK-40708][table] Support ValueView in PTFs
- [FLINK-40608][python] Extract Dataframe type inference mechanism to shared component, add not null by default
- [FLINK-40751][state-processor-api] Use task io/memory manager in SavepointEnvironment
- [FLINK-36139][core] Do not use result type hints for aggregate accumulators
- [FLINK-40427][python] Add catalog management and catalog table I/O to DataFrame API
- [FLINK-40726][table-planner] Reading a key from a map returned by MAP_FROM_ARRAYS / MAP_FROM_ENTRIES / MAP_UNION fails with ClassCastException
- [FLINK-40681][table-runtime] Do not count an UPDATE_AFTER that replaces a record as a new association
- [FLINK-40731][table-common] CONVERT_TZ silently returns a wrong timestamp for a time zone it does not recognize
- Docs
- Java not yet supported