Pull requests: apache/flink
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[FLINK-35437] Rewrite BlockStatementGrouper so that it uses less memory
component=TableSQL/Runtime
#24834
opened May 23, 2024 by
dawidwys
Loading…
[FLINK-35434] Support pass exception in StateExecutor to runtime
component=Runtime/StateBackends
#24833
opened May 23, 2024 by
zoltar9264
Loading…
[FLINK-35412][State/Runtime] Batch execution of async state request callback
component=Runtime/StateBackends
component=Runtime/Task
#24832
opened May 23, 2024 by
Zakelly
Loading…
[FLINK-35426][table-planner] Change the distribution of DynamicFilteringDataCollector to Broadcast
component=TableSQL/Planner
#24830
opened May 23, 2024 by
SinBex
Loading…
[FLINK-35423][table] ARRAY_EXCEPT should follow set semantics
component=TableSQL/API
#24828
opened May 22, 2024 by
snuyanzin
Loading…
[FLINK-34673][test] Fix SessionRelatedITCase#testTouchSession failure on GitHub Actions
#24826
opened May 22, 2024 by
juanvisoler
Loading…
[FLINK-35353][docs-zh]Translate "Profiler" page into Chinese
component=chinese-translation
component=Documentation
#24822
opened May 22, 2024 by
drymatini
Loading…
[FLINK-35347][table] Introduce embedded scheduler and EmbeddedWorkflowScheduler plugin to support full refresh mode for materialized table
#24821
opened May 22, 2024 by
lsyldliu
Loading…
[FLINK-20402][e2e] Migrate test_tpch.sh
component=TableSQL/Ecosystem
component=Tests
#24820
opened May 21, 2024 by
morazow
Loading…
[FLINK-35406] Use inner serializer when casting RAW type to BINARY or…
component=TableSQL/Planner
#24818
opened May 21, 2024 by
docete
Loading…
[FLINK-35400][checkpoint] Release FileMergingSnapshotManager if all tasks finished
component=<none>
#24817
opened May 21, 2024 by
Zakelly
Loading…
[FLINK-35403] Allow Skipping Invocation of Function Calls While Constant-folding
component=<none>
#24814
opened May 20, 2024 by
AlanConfluent
Loading…
[FLINK-35049][state] Implement Map Async State API for ForStStateBackend
component=Runtime/StateBackends
#24812
opened May 20, 2024 by
fredia
Loading…
[FLINK-35355][State] Internal async aggregating state and corresponding state descriptor
component=Runtime/StateBackends
#24810
opened May 19, 2024 by
jectpro7
Loading…
[FLINK-32088][checkpoint] Space control in file merging
component=Runtime/Checkpointing
component=Runtime/StateBackends
#24807
opened May 17, 2024 by
Zakelly
Loading…
[FLINK-35378] [FLIP-453] Promote Unified Sink API V2 to Public and Deprecate SinkFunction
component=API/Core
#24805
opened May 16, 2024 by
MartijnVisser
•
Draft
[FLINK-35289][core] Batch mode onTimer should support processing ts
component=API/Core
#24800
opened May 16, 2024 by
jeyhunkarimov
Loading…
[FLINK-35342][table] Fix MaterializedTableStatementITCase test can check for wrong status
component=<none>
#24799
opened May 16, 2024 by
hackergin
Loading…
[FLINK-33759] [flink-parquet] Add support for nested array with row/map/array type
component=Formats
#24795
opened May 15, 2024 by
ViktorCosenza
Loading…
[BP-1.19][FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib"
component=Client/JobSubmission
component=flink-docker
#24792
opened May 15, 2024 by
ferenc-csaky
Loading…
[FLINK-35358][clients] Reintroduce recursive JAR listing in classpath load from "usrlib"
component=Client/JobSubmission
component=flink-docker
#24791
opened May 15, 2024 by
ferenc-csaky
Loading…
[FLINK-35361]Delete Flinkhistory files that failed to write to the lo…
component=<none>
#24790
opened May 15, 2024 by
d20162416
Loading…
[FLINK-34379][table] Fix adding catalogtable logic
component=TableSQL/Planner
#24788
opened May 15, 2024 by
jeyhunkarimov
Loading…
[FLINK-35318][table-planner] use UTC timezone to handle TIMESTAMP_WITHOUT_TIME_ZONE type in RexNodeToExpressionConverter
component=TableSQL/API
#24787
opened May 15, 2024 by
lshangq
Loading…
Previous Next
ProTip!
Type g i on any issue or pull request to go back to the issue listing page.