Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-35293][hive] Hive source supports dynamic parallelism inference
component=Connectors/Hive
#24764
opened May 9, 2024 by
SinBex
Loading…
[FLINK-35164][table] Support
ALTER CATALOG RESET syntax
component=TableSQL/API
#24763
opened May 9, 2024 by
liyubin117
Loading…
[FLINK-32087][checkpoint] Introduce space amplification statistics of file merging
component=Runtime/Checkpointing
component=Runtime/StateBackends
#24762
opened May 8, 2024 by
fredia
Loading…
[FLINK-35198][table] Support the execution of refresh materialized table
component=TableSQL/API
#24760
opened May 7, 2024 by
xuyangzhong
Loading…
[FLINK-35302][rest] Ignore unknown fields in REST request deserialization
component=Runtime/REST
#24759
opened May 7, 2024 by
vancior98
Loading…
[hotfix] [docs] Clarifying sentence on streaming queries
#24758
opened May 6, 2024 by
upkarliddercflt
Loading…
[FLINK-35157][runtime] Sources with watermark alignment get stuck once some subtasks finish
component=Runtime/Coordination
#24757
opened May 6, 2024 by
elon-X
Loading…
[FLINK-35112][python] Fix membership for Row class PyFlink
component=API/Python
#24756
opened May 5, 2024 by
wzorgdrager
Loading…
[FLINK-33212][runtime] add job status changed listener for lineage
component=Runtime/REST
#24754
opened May 1, 2024 by
HuangZhenQiu
Loading…
[FLINK-35184][table-runtime] fix minibatch join hash collision release-1.19
component=TableSQL/Runtime
#24749
opened Apr 30, 2024 by
rovboyko
Loading…
[FLINK-35030][runtime] Introduce Epoch Manager under async execution
component=<none>
#24748
opened Apr 30, 2024 by
fredia
Loading…
[FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to g…
component=TableSQL/Client
#24742
opened Apr 29, 2024 by
davidradl
Loading…
[FLINK-31223][sqlgateway] Introduce getFlinkConfigurationOptions to
component=TableSQL/Client
#24741
opened Apr 29, 2024 by
davidradl
Loading…
[FLINK-35165][runtime/coordination] AdaptiveBatch Scheduler should not restrict the default source parall…
component=Runtime/Coordination
#24736
opened Apr 28, 2024 by
venkata91
Loading…
[FLINK-29797][flink-yarn] Fix fs.default-scheme will accidentally cau…
component=Deployment/YARN
#24733
opened Apr 27, 2024 by
slankka
Loading…
[FLINK-33210] Cleanup the lineage interface comments
component=API/DataStream
component=TableSQL/API
#24731
opened Apr 26, 2024 by
HuangZhenQiu
Loading…
[FLINK-35240][Connectors][format]Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record for csv format
component=Connectors/FileSystem
#24730
opened Apr 26, 2024 by
GOODBOY008
Loading…
[FLINK-35236] [chinese-translation] Modify Translation error on the execution_mode/order-of-processing
component=chinese-translation
#24726
opened Apr 26, 2024 by
maomao931228
Loading…
[WIP][FLINK-34977][API] Introduce State Access on DataStream API V2
component=API/DataStream
component=API/StateProcessor
#24725
opened Apr 26, 2024 by
jeyhunkarimov
•
Draft
[FLINK-35215][core] Fix the bug when Kryo serialize length is 0
component=API/TypeSerializationSystem
#24717
opened Apr 25, 2024 by
1996fanrui
Loading…
Previous Next
ProTip!
no:milestone will show everything without a milestone.