+1 (non-binding)
Best,
Maciej Obuchowski
śr., 28 lut 2024 o 10:29 Zhanghao Chen
napisał(a):
> +1 (non-binding)
>
> Best,
> Zhanghao Chen
>
> From: Yong Fang
> Sent: Wednesday, February 28, 2024 10:12
> To: dev
> Subject: [VOTE] F
Hello,
I'm an OpenLineage committer - and previously, a minor Flink contributor.
OpenLineage community is very interested in conversation about Flink
metadata, and we'll be happy to cooperate with the Flink community.
Best,
Maciej Obuchowski
czw., 13 sty 2022 o 18:12 Martijn Visser
Maciej Obuchowski created FLINK-21643:
-
Summary: JDBC sink should be able to execute statements on
multiple tables
Key: FLINK-21643
URL: https://issues.apache.org/jira/browse/FLINK-21643
Project
While working on project that's strongly metadata-driven I've had to
overcome several deficiencies, or assumptions in Flink code. Project
involves reading from hundreds (possibly thousands) kafka topics, each
containing avro messages with different schemas. Then, various
transformations and aggrega
Maciej Obuchowski created FLINK-21488:
-
Summary: Jdbc XA sink - XID generation conflicts between jobs
Key: FLINK-21488
URL: https://issues.apache.org/jira/browse/FLINK-21488
Project: Flink
nd provide code review?
Thanks,
Maciej
pon., 22 lut 2021 o 14:09 Roman Khachatryan napisał(a):
> Hi,
>
> Yes, please go ahead. Thanks!
>
> Regards,
> Roman
>
>
> On Mon, Feb 22, 2021 at 12:18 PM Maciej Obuchowski <
> obuchowski.mac...@gmail.com> wrote:
>
>
Maciej Obuchowski created FLINK-21442:
-
Summary: Jdbc XA sink - restore state serialization error
Key: FLINK-21442
URL: https://issues.apache.org/jira/browse/FLINK-21442
Project: Flink
Hey, while working with the new 1.13 JDBC XA sink I had state restoration
errors connected to XaSinkStateSerializer with it's implementation of
SNAPSHOT using anonymous inner class, which is not restorable due to not
being public.
When changed to implementation similar to
CheckpointAndXidSimpleType
