Skip to content

Pull requests: apache/flink

New pull request New
1,239 Open 24,346 Closed
1,239 Open 24,346 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-36643][filesystems] Update aws-java-sdk-core to 1.12.777 component=FileSystems
#25600 opened Oct 31, 2024 by tomncooper Loading…
1
[FLINK-36644] TIMESTAMPDIFF can not be string serialized component=TableSQL/API
#25599 opened Oct 31, 2024 by dawidwys Loading…
1
[FLINK-36624][checkpointing] Log JobID from the SourceCoordinator component=Runtime/Checkpointing
#25598 opened Oct 31, 2024 by pnowojski Loading…
3
[FLINK-36639] Use table aliases in Table API asSerializableString component=TableSQL/API
#25597 opened Oct 31, 2024 by dawidwys Loading…
2
[FLINK-36635][runtime] Remove PhysicalSlotRequestBulkImpl as it is not used component=Runtime/Coordination
#25596 opened Oct 31, 2024 by eemario Loading…
1
[FLINK-36496][table]Remove deprecated method CatalogFunction#isGeneric component=TableSQL/API
#25595 opened Oct 31, 2024 by RanJinh Loading…
1
[FLINK-36499][table]Remove deprecated method `SupportsProjectionPushD… component=TableSQL/API
#25594 opened Oct 31, 2024 by RanJinh Loading…
1
[FLINK-36634][table] Introduce AdaptiveBatchSchedulerFactory to support dynamic generate join operator at runtime. component=TableSQL/Runtime
#25593 opened Oct 31, 2024 by SinBex Loading…
1
[FLINK-30284][flink-metrics] Adding datacenter url property to datadog component=Runtime/Metrics
#25592 opened Oct 30, 2024 by rstpv Loading…
1
[FLINK-36068][runtime] Support for adaptive job scheduling based on StreamGraph component=Runtime/Coordination
#25591 opened Oct 30, 2024 by JunRuiLee • Draft
1
[FLINK-36161][docs]Update Integration Test Example with Sink API. component=Documentation component=Tests
#25590 opened Oct 30, 2024 by RanJinh Loading…
1
[FLINK-36011][runtime] Improved logging in StateTransitionManager component=Runtime/Coordination
#25589 opened Oct 29, 2024 by ztison Loading…
2
[FLINK-36497][table]Remove all deprecated methods CatalogTable component=TableSQL/API
#25585 opened Oct 29, 2024 by Edward-Gavin Loading…
1
[FLINK-36504][table]Remove all deprecated methods ModuleFactory component=TableSQL/API
#25584 opened Oct 29, 2024 by Edward-Gavin Loading…
1
[FLINK-36617] migrate kyro package component=<none>
#25583 opened Oct 28, 2024 by r-sidd Loading…
1
[FLINK-36615] Support LEAD/LAG functions in Table API component=TableSQL/API
#25582 opened Oct 28, 2024 by dawidwys Loading…
14
[FLINK-36613][tests] Ensure RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState runs with large enough value for STARTING_MEMORY_SEGMENT_SIZE component=Runtime/Checkpointing component=Tests
#25581 opened Oct 28, 2024 by snuyanzin Loading…
1
[hotfix][metrics] Fix default value of endTsMillis in SpanBuilder
#25580 opened Oct 28, 2024 by hackergin Loading…
2
[FLINK-36501][table] Remove all deprecated methods in CatalogFactory component=TableSQL/API
#25579 opened Oct 28, 2024 by hackergin Loading…
3
[FLINK-36607][table-planner] Introduce AdaptiveBroadcastJoinProcessor to inject adaptive broadcast join. component=TableSQL/Planner
#25578 opened Oct 28, 2024 by SinBex Loading…
5
[FLINK-36604][datastream] StreamingJobGraphGenerator::setOperatorConfig checks input serializer length component=API/DataStream
#25576 opened Oct 26, 2024 by liuml07 Loading…
1
[FLINK-36600][FLINK-36601][jdbc-driver] Improve Flink SQL JDBC
#25575 opened Oct 25, 2024 by cy2008 Loading…
2
[FLINK-33571][table] Backport json-path upgrade to deal with CVE component=<none>
#25573 opened Oct 24, 2024 by tomncooper Loading…
2
[FLINK-36585][connector / common] SplitFetcherManager.close() should not chain runnables to the element queue future in a tight loop. component=Connectors/Common
#25569 opened Oct 23, 2024 by becketqin Loading…
1
[FLINK-36594][hive]HiveCatalog should set HiveConf.hiveSiteLocation back component=Connectors/Hive
#25568 opened Oct 23, 2024 by slankka Loading…
1
ProTip! Filter pull requests by the default branch with base:master.