Zhipeng Zhang created FLINK-31732:
-
Summary: flink-ml-uber module should include statefun as a
dependency
Key: FLINK-31732
URL: https://issues.apache.org/jira/browse/FLINK-31732
Project: Flink
Hello Flink community,
I would like to discuss if it is worth adding EXACTLY_ONCE delivery
semantics to upsert-kafka connector. According to upsert-kafka docs[1] and
ReducingUpsertSink javadoc[2], the connector is correct even with duplicate
records under AT_LEAST_ONCE because the records are idem
Hi,
Thank you, it works perfectly now for me.
Regards,
Mate
Jing Ge ezt írta (időpont: 2023. ápr. 4., K,
20:32):
> Hi Mate,
>
> Thanks for the hint. I just updated the page and checked with a fresh,
> different browser. It should work now. Would you like to try again?
>
> Best regards,
> Jing
Martijn Visser created FLINK-31731:
--
Summary: No suitable constructor found for
DebeziumAvroSerializationSchema
Key: FLINK-31731
URL: https://issues.apache.org/jira/browse/FLINK-31731
Project: Flink
Hi Mate,
Thanks for the hint. I just updated the page and checked with a fresh,
different browser. It should work now. Would you like to try again?
Best regards,
Jing
On Tue, Apr 4, 2023 at 8:17 PM Mate Czagany wrote:
> Hi,
>
> It does not work for me either, the images are hosted on Google Dr
Hi all,
I've ported the critical fixes I mentioned to v3.0 and v4.0 branches of
apache/flink-connector-kafka now.
@martijnvis...@apache.org let me know if you'd
need help with creating a new RC, if there's too much to juggle on
your end. Happy to help out.
Thanks,
Gordon
On Sun, Apr 2, 2023 at
Hi,
It does not work for me either, the images are hosted on Google Drawings
and it seems like it went private.
Maybe you have the images in your browser cache if you can see them. I see
that other FLIPs have their images uploaded to Confluence, I think that
would be a better way to store them.
R
Zhenqiu Huang created FLINK-31730:
-
Summary: Support Ephemeral Storage in KubernetesConfigOptions
Key: FLINK-31730
URL: https://issues.apache.org/jira/browse/FLINK-31730
Project: Flink
Issue
Hi David,
I just checked and both diagrams are still there. The last change of the
page was on Sep 18, 2022. Would you like to clean your cache or change to
another browser and try again?
Best regards,
Jing
On Tue, Apr 4, 2023 at 5:25 PM David Anderson wrote:
> Does anyone know what happened
Alexander Smirnov created FLINK-31729:
-
Summary: Unexpected UPDATE_BEFORE output record in LEFT OUTER JOIN
Key: FLINK-31729
URL: https://issues.apache.org/jira/browse/FLINK-31729
Project: Flink
Does anyone know what happened to the diagrams that used to be in
FLIP-24: SQL Client? The last time I looked at this FLIP -- a few
weeks ago -- there were architecture diagrams for Gateway Mode and
Embedded Mode, but now those images are missing.
David
Chesnay Schepler created FLINK-31728:
Summary: Remove Scala API dependencies from batch/streaming
examples
Key: FLINK-31728
URL: https://issues.apache.org/jira/browse/FLINK-31728
Project: Flink
Dear devs and users,
Today was the kickoff meeting for Flink 1.18 release cycle. I'd like to
share the info synced in the meeting.
Meeting schedule:
Zoom will be used with a 40 mins limit for each meeting. That should be
fine for now. We will check it again if we have an issue with the time
limi
Yordan Pavlov created FLINK-31727:
-
Summary: Source parallelism should match number of Kafka partitions
Key: FLINK-31727
URL: https://issues.apache.org/jira/browse/FLINK-31727
Project: Flink
padavan created FLINK-31726:
---
Summary: PyFlink module java.base does not "opens java.lang" to
unnamed module
Key: FLINK-31726
URL: https://issues.apache.org/jira/browse/FLINK-31726
Project: Flink
Martijn Visser created FLINK-31725:
--
Summary: Synchronize dependency version between Flink and
flink-connector-pulsar
Key: FLINK-31725
URL: https://issues.apache.org/jira/browse/FLINK-31725
Project:
Thanks Qingsheng for your coordination and thanks to all previous release
managers for sharing your thoughts!
Best regards,
Jing
On Sat, Apr 1, 2023 at 5:54 PM Jark Wu wrote:
> Thank Konstantin, Qingsheng, Jing, Sergey for volunteering releases
> managers.
> Thank Qingsheng for being the releas
Thank you for your reply. I am very sorry for the misunderstanding caused
by my deviation from the original discussion.
@Shammon
> I found there is a pre-discussion [1] for this FLIP
Yes, there was indeed such a discussion before. However, in designing the
whole solution, I found that the logic o
Sergey Nuyanzin created FLINK-31724:
---
Summary: SqlClientITCase.testMatchRecognize fails with "bash -c rm
-rf /opt/flink/checkpoint/*" returned non-zero exit code 1
Key: FLINK-31724
URL: https://issues.apache.org
Sergey Nuyanzin created FLINK-31723:
---
Summary: DispatcherTest#testCancellationDuringInitialization is
unstable
Key: FLINK-31723
URL: https://issues.apache.org/jira/browse/FLINK-31723
Project: Flink
Martijn Visser created FLINK-31722:
--
Summary: Remove dependency on flink-shaded
Key: FLINK-31722
URL: https://issues.apache.org/jira/browse/FLINK-31722
Project: Flink
Issue Type: Technical D
Hi Feng
I think if there is a `registerCatalog` method in `CatalogManager`, it will
confuse users whether a method named `addCatalog` or `storeCatalog` is
added.
And as you mentioned, the memory catalog is a `cache`, I think the concept
of `cache` should not be exposed to users.
I found there is
tartarus created FLINK-31721:
Summary: Move JobStatusHook to flink-core module
Key: FLINK-31721
URL: https://issues.apache.org/jira/browse/FLINK-31721
Project: Flink
Issue Type: Sub-task
Thanks Feng for driving this FLIP.
I have few comments:
1: The mechanism of handling catalog with the same name looks a little of
complex to me. I think it'll be better to explain it in the java doc of these
methods and give a brief example in this FLIP.
2: TBH, the method name `addCatalog` sti
Yuxin Tan created FLINK-31720:
-
Summary: Pulsar connector v3.0 branch's docs are empty
Key: FLINK-31720
URL: https://issues.apache.org/jira/browse/FLINK-31720
Project: Flink
Issue Type: Bug
25 matches
Mail list logo
