Yanquan Lv created FLINK-36887:
--
Summary: Add support for Flink 1.20 in Flink Hive connector
Key: FLINK-36887
URL: https://issues.apache.org/jira/browse/FLINK-36887
Project: Flink
Issue Type: N
Matthias Pohl created FLINK-36888:
-
Summary: Building flink-shaded-netty-tcnative-static for the
OpenSSL e2e tests timed out
Key: FLINK-36888
URL: https://issues.apache.org/jira/browse/FLINK-36888
Pro
Robert Metzger created FLINK-36889:
--
Summary: Mention locking down a Flink cluster in the 'Production
Readiness Checklist'
Key: FLINK-36889
URL: https://issues.apache.org/jira/browse/FLINK-36889
Proj
Maximilian Michels created FLINK-36890:
--
Summary: ObservedGeneration is not updated on NOOP spec updates
Key: FLINK-36890
URL: https://issues.apache.org/jira/browse/FLINK-36890
Project: Flink
Sergei Morozov created FLINK-36891:
--
Summary: MySQL CDC connector produces corrupted state in case of
serialization failure
Key: FLINK-36891
URL: https://issues.apache.org/jira/browse/FLINK-36891
Pro
Zakelly Lan created FLINK-36886:
---
Summary: Support interruptible timers with async state processing
Key: FLINK-36886
URL: https://issues.apache.org/jira/browse/FLINK-36886
Project: Flink
Issue
Hi Yanfei,
Thanks for your response!
The `SingleOutputStreamOperator` is the return type of `process()` or
`sum()`, so the example would be invoking `enableAsyncState()` after the
processing methods, which has been included in the examples within this
FLIP.
Best,
Zakelly
On Wed, Dec 11, 2024 a
Dawid Wysakowicz created FLINK-36885:
Summary: Multiple tests are incorrectly migrated to JUnit 5
Key: FLINK-36885
URL: https://issues.apache.org/jira/browse/FLINK-36885
Project: Flink
Is
Hi Enric,
This may be because your IDE has not indexed the dependency. Please try
reloading the maven project, by right clicking the project root -> Maven ->
Reload project.
Best,
Zakelly
On Wed, Dec 11, 2024 at 5:30 PM Enric Ott <243816...@qq.com> wrote:
> Hello,Community:
> When I import f
I'd like to start a discussion of FLIP-491: BundledAggregateFunction for
batched aggregation [1]
This feature proposes adding a new interface BundledAggregateFunction that
can be implemented by AggregateFunction UDFs. This allows the use of a
batched method call so that users can handle many rows
Xingcan Cui created FLINK-36893:
---
Summary: Support periodic full checkpoint
Key: FLINK-36893
URL: https://issues.apache.org/jira/browse/FLINK-36893
Project: Flink
Issue Type: Improvement
shaohui hong created FLINK-36894:
Summary: rowId comparision is incorrect in oracle connector
Key: FLINK-36894
URL: https://issues.apache.org/jira/browse/FLINK-36894
Project: Flink
Issue Type
ouyangwulin created FLINK-36895:
---
Summary: The JdbcSourceChunkSplitter#queryMin method passed a
parameter with tableName/coiumnName reversed.
Key: FLINK-36895
URL: https://issues.apache.org/jira/browse/FLINK-36895
Zakelly Lan created FLINK-36892:
---
Summary: Properly handle the watermark status
Key: FLINK-36892
URL: https://issues.apache.org/jira/browse/FLINK-36892
Project: Flink
Issue Type: Sub-task
14 matches
Mail list logo