xuhuang created FLINK-36815:
---
Summary: series bugs of DSv2
Key: FLINK-36815
URL: https://issues.apache.org/jira/browse/FLINK-36815
Project: Flink
Issue Type: Bug
Components: API / DataStr
melin created FLINK-36814:
-
Summary: Flink CDC Support Mutil Datasource
Key: FLINK-36814
URL: https://issues.apache.org/jira/browse/FLINK-36814
Project: Flink
Issue Type: New Feature
Compon
Di Wu created FLINK-36813:
-
Summary: MySQLCDC supports synchronization of specified fields
Key: FLINK-36813
URL: https://issues.apache.org/jira/browse/FLINK-36813
Project: Flink
Issue Type: Improveme
ouyangwulin created FLINK-36812:
---
Summary: The flink jdbc connector's 'scan.partition.column'
supports the varchar field type.
Key: FLINK-36812
URL: https://issues.apache.org/jira/browse/FLINK-36812
Pro
Xuannan Su created FLINK-36811:
--
Summary: MySQL CDC
Key: FLINK-36811
URL: https://issues.apache.org/jira/browse/FLINK-36811
Project: Flink
Issue Type: Improvement
Components: Flink CDC
From: Emil Hjelle (ekstern)
Sent: Wednesday, November 27, 2024 4:35 PM
To: dev@flink.apache.org
Subject: Upsert to Kafka with flink SQL
Hi! I am new to Flink and not sure if this is the right place to ask this
question.
I am trying to create a demo of Flink SQ
Hi! I am new to Flink and not sure if this is the right place to ask this
question.
I am trying to create a demo of Flink SQL with the Kubernetes operator.
I am using the example from
https://github.com/apache/flink-kubernetes-operator/tree/main/examples/flink-sql-runner-example
I have modifie
Yusu Gao created FLINK-36810:
Summary: Reflective access warning not addressed causing Flink
failing to process job creation
Key: FLINK-36810
URL: https://issues.apache.org/jira/browse/FLINK-36810
Project
Gustavo de Morais created FLINK-36809:
-
Summary: Add ifNotExists param to createTable
Key: FLINK-36809
URL: https://issues.apache.org/jira/browse/FLINK-36809
Project: Flink
Issue Type: Im
Qingsheng Ren created FLINK-36808:
-
Summary: UNION ALL after lookup join produces unexpected results
Key: FLINK-36808
URL: https://issues.apache.org/jira/browse/FLINK-36808
Project: Flink
Iss
Hello Sergio,
Thankyou for starting this discussion, I have a few questions.
> having 2 identical pipelines running side-by-side
How do you ensure correctness between the 2 identical pipelines? For
example, processing time semantics or late data can result in different
outputs.
Some Sources have
Hi Ferenc
Could you please help to create a FLIP page if everything looks fine from
the above discussion/google doc. Thanks in advance.
Regards
Lajith K
On Thu, Nov 7, 2024 at 12:02 PM Lajith Koova wrote:
> Thank you so much, Ferenc , and regarding your observation , FLIP covers
> the changes
Arvid Heise created FLINK-36807:
---
Summary: Add coverage for pre-writer and pre-commit topologies for
SinkV2
Key: FLINK-36807
URL: https://issues.apache.org/jira/browse/FLINK-36807
Project: Flink
zjjiang created FLINK-36806:
---
Summary: Support for synchronization between timestamp fields with
and without time zones to avoid time offsets
Key: FLINK-36806
URL: https://issues.apache.org/jira/browse/FLINK-36806
The Apache Flink community is very happy to announce the release of Apache
Flink CDC 3.2.1.
Apache Flink CDC is a distributed data integration tool for real time data
and batch data, bringing the simplicity and elegance of data integration
via YAML to describe the data movement and transformation i
15 matches
Mail list logo
