Thanks Hongshun for deeper analysis of the existing KafkaSource implementation
details, Cool!
There’s no specific use case to use a future TIMESTAMP and SPECIFIC-OFFSET for
new discovered partitions
The existing SpecifiedOffsetsInitializer will use the EARLIEST offset for
unspecified
Hi, Yuxia
Thank you for your reply.
We can identify whether a CatalogTable supports atomic Ctas by determining its
type in DynamicTableFactory/DynamicTableSink, like the following:
boolean isAtomicCtas = context.getCatalogTable().getOrigin() instanceof
TwoPhaseCatalogTable;
And I've updated the
I'm happy to announce that we have unanimously approved this release [1].
There are 4 approving votes, 3 of which are binding:
- Guowei Ma (binding)
- Xingbo Huang (binding)
- Dong Lin (binding)
- Zhipeng Zhang (non-binding)
There are no disapproving votes.
Thank you for verifying the release
Hi everyone,
I would like to start a discussion on FLINK-25132: KafkaSource cannot work
with object-reusing DeserializationSchema.
The implementation of FLINK-25132 moves the deserialization of kafka
records from SplitFetcher thread to thread that runs KafkaRecordEmitter,
namely flink's main
Hi Shammon,
I agree with you. Since only EARLIEST is used, it's better not to mislead
users through the interface.
Yours
Hongshun
On Tue, Apr 18, 2023 at 7:12 PM Shammon FY wrote:
> Hi Hongshun
>
> Thanks for your explanation, I have got your point. I review the FLIP again
> and only have
Fan Hong created FLINK-31846:
Summary: Support cancel final checkpoint when all tasks are
finished
Key: FLINK-31846
URL: https://issues.apache.org/jira/browse/FLINK-31846
Project: Flink
Issue
I am currently using Stateful Functions in my application.
I use Apache Flink for stream processing, and StateFun as a hand-off point for
the rest of the application.
It serves well as a bridge between a Flink Streaming job and micro-services.
I would be disappointed if StateFun was sunsetted.
Hi Martijn,
Thanks for your reply and attention.
1. As I read Nick's report here
https://issues.apache.org/jira/browse/FLINK-13414?focusedCommentId=17257763=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-17257763
Scala maintainers were blocked by Flink's source code
Hi Günter, David,
Let me reply to you both in one email. First of all, thank you for
engaging.
Günter:
- I fully agree that losing Scala API as officially supported in Flink
would be very unfortunate. Future of Scala is interesting and will bring
more benefits to Flink users.
Just to remind
+1 (binding)
- Checked hashes and signatures
- Built from source mvn clean install -Pcheck-convergence
-Dflink.version=1.17.0
- Eyeballed NOTICE license files
- Started a Flink 1.17.0 cluster + Kafka 3.2.3 cluster, submitted a SQL
statement using the Kafka connector under exactly-once mode.
Hello! +1 (non-binding)
I've validated the source for the RC1:
flink-connector-opensearch-1.0.1-src.tgz
* The sha512 checksum is OK.
* The source file is signed correctly.
* The signature A5F3BCE4CBE993573EC5966A65321B8382B219AF is found in the
KEYS file, and on https://keys.openpgp.org
* The
Daren Wong created FLINK-31845:
--
Summary: Make KubernetesStepDecorator Pluggable
Key: FLINK-31845
URL: https://issues.apache.org/jira/browse/FLINK-31845
Project: Flink
Issue Type: Improvement
Bo Cui created FLINK-31844:
--
Summary:
DefaultPackagedProgramRetriever#getClasspathsFromUserLibDir supports loading
profile
Key: FLINK-31844
URL: https://issues.apache.org/jira/browse/FLINK-31844
Project:
Weihua Hu created FLINK-31843:
-
Summary: Select slots from SlotPool#freeSlots in bulk
Key: FLINK-31843
URL: https://issues.apache.org/jira/browse/FLINK-31843
Project: Flink
Issue Type: Sub-task
Weihua Hu created FLINK-31842:
-
Summary: calculate task executor's utilization only when used
Key: FLINK-31842
URL: https://issues.apache.org/jira/browse/FLINK-31842
Project: Flink
Issue Type:
Wencong Liu created FLINK-31841:
---
Summary: Redundant local variables in AllWindowedStream#reduce
Key: FLINK-31841
URL: https://issues.apache.org/jira/browse/FLINK-31841
Project: Flink
Issue
Robert Metzger created FLINK-31840:
--
Summary: NullPointerException in
operators.window.slicing.SliceAssigners$AbstractSliceAssigner.assignSliceEnd
Key: FLINK-31840
URL:
Gabor Somogyi created FLINK-31839:
-
Summary: It's not possible to add flink-s3-fs-hadoop and
flink-s3-fs-presto plugins at the same time
Key: FLINK-31839
URL: https://issues.apache.org/jira/browse/FLINK-31839
Matthias Pohl created FLINK-31838:
-
Summary: Move thread handling from
DefaultMultipleComponentLeaderElectionService into DefaultLeaderElectionService
Key: FLINK-31838
URL:
Hi Hongshun
Thanks for your explanation, I have got your point. I review the FLIP again
and only have one minor comment which won't block this FLIP: should we need
in `OffsetsInitializer newDiscoveryOffsetsInitializer` in the constructor
of `KafkaSourceEnumerator`? I think we can remove it if we
Matthias Pohl created FLINK-31837:
-
Summary: Move LeaderElectionDriver instantiated into
DefaultLeaderElectionService's constructor
Key: FLINK-31837
URL: https://issues.apache.org/jira/browse/FLINK-31837
Sergey Nuyanzin created FLINK-31836:
---
Summary: Upgrade to Calcite version to 1.34.0
Key: FLINK-31836
URL: https://issues.apache.org/jira/browse/FLINK-31836
Project: Flink
Issue Type:
+1 (binding)
Hang Ruan 于2023年4月18日周二 14:03写道：
> +1 (no-binding)
>
> Best,
> Hang
>
> Shammon FY 于2023年4月18日周二 13:33写道：
>
> > +1 (no-binding)
> >
> > Best,
> > Shammon FY
> >
> > On Tue, Apr 18, 2023 at 12:56 PM Jacky Lau wrote:
> >
> > > +1 (no-binding)
> > >
> > > Best,
> > > Jacky Lau
> > >
jeff-zou created FLINK-31835:
Summary: DataTypeHint don't support Row>
Key: FLINK-31835
URL: https://issues.apache.org/jira/browse/FLINK-31835
Project: Flink
Issue Type: Bug
Hi Shammon,
Thank you for your advice.I have carefully considered whether to show this
in SQL DDL. Therefore, I carefully studied whether it is feasible Recently
However, after reading the corresponding code more thoroughly, it appears
that SpecifiedOffsetsInitializer and
Hi Yun,
You can also set the link to not expire, that's what I've always done. By
the way, the docs already have an updated Slack invite link.
Best regards,
Martijn
On Mon, Apr 17, 2023 at 6:04 PM Yun Tang wrote:
> Hi Madhur,
>
> Could you try this invitation link:
>
Robert Metzger created FLINK-31834:
--
Summary: Azure Warning: no space left on device
Key: FLINK-31834
URL: https://issues.apache.org/jira/browse/FLINK-31834
Project: Flink
Issue Type: Bug
Godfrey He created FLINK-31833:
--
Summary: Support code-gen fusion for multiple operators
Key: FLINK-31833
URL: https://issues.apache.org/jira/browse/FLINK-31833
Project: Flink
Issue Type:
Weihua Hu created FLINK-31832:
-
Summary: Add benchmarks for end to end restarting tasks
Key: FLINK-31832
URL: https://issues.apache.org/jira/browse/FLINK-31832
Project: Flink
Issue Type:
+1 (no-binding)
Best,
Hang
Shammon FY 于2023年4月18日周二 13:33写道：
> +1 (no-binding)
>
> Best,
> Shammon FY
>
> On Tue, Apr 18, 2023 at 12:56 PM Jacky Lau wrote:
>
> > +1 (no-binding)
> >
> > Best,
> > Jacky Lau
> >
> > Jingsong Li 于2023年4月18日周二 11:57写道：
> >
> > > +1
> > >
> > > On Tue, Apr 18,
30 matches
Mail list logo
