-
Notifications
You must be signed in to change notification settings - Fork 13.5k
Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-37268][example] Add async state word count example
component=<none>
#26117
opened Feb 6, 2025 by
fredia
Loading…
[BP-1.19][FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side
component=Runtime/Coordination
#26116
opened Feb 6, 2025 by
XComp
Loading…
[BP-1.20][FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side
component=Runtime/Coordination
#26115
opened Feb 6, 2025 by
XComp
Loading…
[BP-2.0][FLINK-34227][runtime] Makes the JobMaster close procedure more robust to IO thread leaks from the scheduler side
component=Runtime/Coordination
#26114
opened Feb 6, 2025 by
XComp
Loading…
[FLINK-37267][table] Add support for UNNEST WITH ORDINALITY
component=TableSQL/API
#26113
opened Feb 6, 2025 by
gustavodemorais
Loading…
[FLINK-37264] Fix bugs of DataStream V2
component=API/DataStream
#26112
opened Feb 6, 2025 by
codenohup
Loading…
[FLINK-37258][runtime] Return Ordered Job list on Disptacher#requestMultipleJobDetails
component=<none>
#26111
opened Feb 5, 2025 by
vahmed-hamdy
Loading…
[FLINK-37249] Remove unnecessary --add-opens/--add-exports for java.base/sun.net.util
component=BuildSystem
#26103
opened Feb 4, 2025 by
X-czh
Loading…
[FLINK-37247][FileSystems][Tests] Implement common Hadoop file system integration tests for GCS.
component=FileSystems
component=Tests
#26102
opened Feb 3, 2025 by
cnauroth
Loading…
[FLINK-37246] add tokens acquired by current user for token refresh
component=Deployment/YARN
#26101
opened Feb 3, 2025 by
HuangZhenQiu
Loading…
[FLINK-37245] Prevent masking null values in BinaryRowData
component=TableSQL/API
component=TableSQL/Runtime
#26100
opened Feb 3, 2025 by
mxm
Loading…
[BP-1.20][FLINK-37241][runtime] Remove Mockito usage from StateBackendTestBase.
component=Runtime/StateBackends
component=Tests
#26096
opened Jan 31, 2025 by
dmvk
Loading…
[FLINK-37241][runtime] Remove Mockito usage from StateBackendTestBase.
component=Runtime/StateBackends
component=Tests
#26094
opened Jan 31, 2025 by
dmvk
Loading…
Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10
dependencies
Pull requests that update a dependency file
java
Pull requests that update Java code
#26090
opened Jan 29, 2025 by
dependabot
bot
Loading…
[FLINK-31275] extend lineage listener with QueryOperationEvent
component=TableSQL/Planner
#26089
opened Jan 29, 2025 by
pawel-big-lebowski
Loading…
[hotfix][runtime] Remove the redundant JobVertex#hasNoConnectedInputs and use JobVertex#isInputVertex instead.
#26083
opened Jan 26, 2025 by
RocMarshal
Loading…
[FLINK-36352][doc] Remove Scala DataStream API related doc
component=Documentation
#26082
opened Jan 26, 2025 by
X-czh
Loading…
FLINK-37154: Adding SimpleByteSchema for PyFlink
component=API/Python
#26080
opened Jan 25, 2025 by
christeoh
Loading…
[FLINK-37187][doc] Add doc for Submitting Refresh Job of Materialized Table to Yarn/K8s
#26073
opened Jan 24, 2025 by
hackergin
Loading…
[FLINK-36900][python] Migrate from conda to uv for managing Python environments for PyFlink
component=TestInfrastructure
#26065
opened Jan 23, 2025 by
autophagy
Loading…
[FLINK-37087][doc] Add docs for alter materialized table as query
component=Documentation
#26064
opened Jan 23, 2025 by
hackergin
Loading…
[FLINK-37207][runtime] Don't clear distributed cache in StreamExecutionEnvironment.configure
component=API/DataStream
#26062
opened Jan 23, 2025 by
dianfu
Loading…
Previous Next
ProTip!
no:milestone will show everything without a milestone.