Skip to content

Pull requests: apache/flink

New pull request New
968 Open 19,996 Closed
968 Open 19,996 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
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

[FLINK-29513][BP 1.16][Connector/Kafka] Update Kafka to version 3.2.3
#20977 opened Oct 6, 2022 by MartijnVisser Loading…
1
[FLINK-29457][state-processor] Add UID (hash) remapping fuction component=API/StateProcessor
#20976 opened Oct 6, 2022 by zentol Loading…
2
[FLINK-29526][state/changelog] fix java doc mistake in SequenceNumber… component=Runtime/StateBackends
#20975 opened Oct 6, 2022 by zoltar9264 Loading…
2
[FLINK-29352]Support CONVERT_TZ built-in function in Table API component=API/Python component=TableSQL/API
#20974 opened Oct 6, 2022 by cun8cun8 Loading…
1
[FLINK-29514][Deployment/YARN] Bump Minikdc to v3.2.4 component=Deployment/YARN
#20973 opened Oct 5, 2022 by MartijnVisser Loading…
@zentol
5
[FLINK-29510] Add tests for NoticeFileChecker component=BuildSystem component=Tests
#20970 opened Oct 5, 2022 by zentol Loading…
6
Bump protobuf-java from 3.19.4 to 3.19.6 in /flink-end-to-end-tests/flink-glue-schema-registry-avro-test dependencies Pull requests that update a dependency file java Pull requests that update Java code
#20969 opened Oct 5, 2022 by dependabot bot Loading…
1
Bump protobuf-java from 3.19.4 to 3.19.6 in /flink-formats/flink-json-glue-schema-registry dependencies Pull requests that update a dependency file java Pull requests that update Java code
#20968 opened Oct 5, 2022 by dependabot bot Loading…
1
Bump protobuf-java from 3.19.4 to 3.19.6 in /flink-formats/flink-avro-glue-schema-registry dependencies Pull requests that update a dependency file java Pull requests that update Java code
#20967 opened Oct 5, 2022 by dependabot bot Loading…
1
[FLINK-29508][legal] Improve detection of non-deployed modules that need a NOTICE component=BuildSystem
#20966 opened Oct 5, 2022 by zentol Loading…
2
[FLINK-29244][state/changelog] Add metric lastMaterializationDuration… component=Runtime/StateBackends
#20965 opened Oct 5, 2022 by zoltar9264 Loading…
1
[FLINK-29503][rest] Add backpressureLevel field component=Runtime/REST
#20962 opened Oct 5, 2022 by zentol Loading…
1
[FLINK-29504][rest] Add schema to jar upload content component=Runtime/REST
#20959 opened Oct 5, 2022 by zentol Loading…
1
[FLINK-29486][sql-client] Add a new RemoteExecutor to send and retrieve messages form remote SQL gateway through rest endpoint component=TableSQL/Client
#20958 opened Oct 5, 2022 by yuzelin Loading…
1
Bump protobuf-java from 3.19.4 to 3.19.6 in /flink-end-to-end-tests/flink-glue-schema-registry-json-test dependencies Pull requests that update a dependency file java Pull requests that update Java code
#20956 opened Oct 4, 2022 by dependabot bot Loading…
@MartijnVisser
1
[FLINK-29502][Filesystem][S3] Update the Hadoop implementation for filesystems to 3.3.4 component=FileSystems
#20955 opened Oct 4, 2022 by MartijnVisser Loading…
@MartijnVisser
4
[FLINK-29485] Introduces FlinkVersion.mostRecentlyPublishedBaseMinorVersion(). component=Documentation component=Tests
#20954 opened Oct 4, 2022 by XComp • Draft
2
[FLINK-29501] Add option to override job vertex parallelisms during job submission component=Runtime/Configuration component=Runtime/REST
#20953 opened Oct 4, 2022 by mxm Loading…
12
[FLINK-29399][tests] Wait until job was cancelled component=TableSQL/Planner component=Tests
#20952 opened Oct 4, 2022 by zentol Loading…
1
[FLINK-29354]Support TO_DATE and TO_TIMESTAMP built-in function in th… component=<none>
#20948 opened Oct 4, 2022 by cun8cun8 Loading…
10
[FLINK-29353]Support UNIX_TIMESTAMP built-in function in Table API component=API/Python component=TableSQL/API
#20947 opened Oct 4, 2022 by cun8cun8 Loading…
7
[FLINK-29395][Connector/Kinesis] Make EFO consumer resilient when con… component=Connectors/Kinesis
#20945 opened Oct 4, 2022 by hlteoh37 Loading…
1
[FLINK-29437] Align the partition of data before and after the Kafka Shuffle component=API/DataStream
#20942 opened Oct 4, 2022 by Zakelly Loading…
2
[hotfix][docs]Fixed some typos of docs.
#20939 opened Oct 3, 2022 by liuzhuang2017 Loading…
3
[hotfix][table] Add the dayofweek function description.
#20938 opened Oct 2, 2022 by liuzhuang2017 Loading…
2
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.