The Wayback Machine - https://web.archive.org/web/20230104144135/https://github.com/apache/flink/pulls
Skip to content

Pull requests: apache/flink

New pull request New
956 Open 20,631 Closed
956 Open 20,631 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Milestones
Filter by milestone
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-30557][connector/kinesis] Remove Kinesis Data Streams connecto… component=Connectors/Kinesis
#21600 opened Jan 4, 2023 by dannycranmer Loading…
1
[FLINK-30231][kubernetes] Update to Fabric8 Kubernetes Client to 5.12… component=Deployment/Kubernetes
#21599 opened Jan 4, 2023 by Mrart Loading…
1
[FLINK-30558][runtime] Use different metric object to avoid metric 'numRestarts' being overridden by 'fullRestarts' in SchedulerBase component=Runtime/Metrics
#21598 opened Jan 4, 2023 by SinBex Loading…
1
[FLINK-30554][sql-client] Remove useless sessionId in the Executor component=TableSQL/Client
#21597 opened Jan 4, 2023 by fsk119 Loading…
2
[FLINK-29719][hive] Supports native count function for hive dialect component=<none>
#21596 opened Jan 4, 2023 by lsyldliu Loading…
1
[FLINK-30483] [Formats] [Avro] Add avro format support for TIMESTAMP_LTZ component=Formats
#21594 opened Jan 3, 2023 by jadireddi Loading…
1
[FLINK-30213] Fix logic for determining downstream subtasks for partitioner replacement component=Runtime/Configuration
#21593 opened Jan 3, 2023 by gyfora Loading…
1
[FLINK-30497][table-api] Introduce TableChange to represent DROP change component=TableSQL/API
#21592 opened Jan 3, 2023 by fsk119 Loading…
18
[FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records component=Connectors/Common component=Connectors/Kafka
#21589 opened Jan 3, 2023 by ruanhang1993 Loading…
1
[FLINK-30544][runtime] Speed up finding minimum watermark across channels by introducing heap-based algorithm component=Runtime/Task
#21588 opened Jan 3, 2023 by wanglijie95 Loading…
5
[FLINK-30542][table-runtime] Introduce adaptive hash aggregate to adaptively determine whether local hash aggregate is required at runtime component=TableSQL/Runtime
#21586 opened Jan 3, 2023 by swuferhong Loading…
1
[FLINK-28655][SQL gateway] Support show jobs operation in SqlGateway
#21582 opened Jan 2, 2023 by link3280 Loading…
3
[FLINK-30538][SQL gateway/client] Improve error handling of stop job operation
#21581 opened Jan 2, 2023 by link3280 Loading…
3
[hotfix][docs] maven project generation command for windows in Fraud Detection with the DataStream API
#21580 opened Dec 31, 2022 by Ngugisenior Loading…
1
[FLINK-30536][runtime] Remove CountingOutput from per-record code path for most operators component=<none>
#21579 opened Dec 31, 2022 by lindong28 Loading…
3
[FLINK-30533][runtime] SourceOperator#emitNext() should push records to DataOutput in a while loop component=Runtime/Task
#21576 opened Dec 29, 2022 by lindong28 Loading…
12
Update intro_to_table_api.md
#21575 opened Dec 29, 2022 by qq774724635 Loading…
1
Release 1.16 pyflink read from kafka failed.
#21574 opened Dec 29, 2022 by ColdWater2019 Loading…
1
[FLINK-30524] Support full screen viewing on the Logs/Stdout/Thread D… component=Runtime/WebFrontend
#21573 opened Dec 29, 2022 by damumu0625 Loading…
1
[FLINK-30525][web] Do not show environment info in web ui. component=Runtime/WebFrontend
#21572 opened Dec 28, 2022 by huwh Loading…
1
[FLINK-29666][runtime] Let adaptive batch scheduler divide subpartition range according to amount of data component=Runtime/Coordination
#21570 opened Dec 28, 2022 by wanglijie95 Loading…
23
[FLINK-30517][log]Decrease log output interval while waiting for YARN… component=Deployment/YARN
#21569 opened Dec 28, 2022 by huwh Loading…
3
[FLINK-30520] fix check comments in load yaml resource component=API/Core
#21567 opened Dec 28, 2022 by Tan-JiaLiang Loading…
1
[FLINK-18229][ResourceManager] Support cancel pending workers if no longer needed. component=Deployment/Kubernetes component=Deployment/YARN component=Runtime/Coordination
#21565 opened Dec 28, 2022 by huwh Loading…
15
[FLINK-30514] HybridSource savepoint recovery sequence fix component=Connectors/FileSystem
#21564 opened Dec 27, 2022 by WonderBeat Loading…
1
ProTip! Adding no:label will show everything without a label.