Hi Alexander,
Thanks for the review! We recently updated the FLIP and you can find those
changes from my latest email. Since some terminologies has changed so I’ll use
the new concept for replying your comments.
1. Builder vs ‘of’
I’m OK to use builder pattern if we have additional optional pa
Hi devs,
We recently updated FLIP-221 [1] in order to make the concept of caching
clearer and introduce some new common lookup table options. The changes are
listed below:
1. "LRU cache" and “all cache” have been renamed as “partial cache” and “full
cache”. It is not necessary for the cache to
Hi Gen Luo,
Thanks a lot for your feedback!
1. About the retry state:
I considered dropping the retry state which really simplifies state changes
and avoids compatibility handling. The only reason I changed my mind was
that it might be lossy to the user. Elements that has been tried several
ti
Hi,
I am working on auto scaling support for native deployments. Today Flink
provides Reactive mode however it only runs on standalone deployments. We
use Kubernetes native deployment. So I want to increase or decrease job
resources for our streamin jobs. Recent Flip-138 and Flip-160 are very
usefu
+1
Best,
Godfrey
LuNing Wang 于2022年5月23日周一 13:06写道：
>
> +1 (non-binding)
>
> Best,
> LuNing Wang
>
> Nicholas Jiang 于2022年5月23日周一 12:57写道：
>
> > +1 (non-binding)
> >
> > Best,
> > Nicholas Jiang
> >
> > On 2022/05/20 02:38:39 Shengkai Fang wrote:
> > > Hi, everyone.
> > >
> > > Thanks for your
LCER created FLINK-27738:
Summary: instance KafkaSink support config topic properties
Key: FLINK-27738
URL: https://issues.apache.org/jira/browse/FLINK-27738
Project: Flink
Issue Type: Improvement
Hi Kyle,
I've sent an invitation to your gmail.
Best,
Xintong
On Mon, May 23, 2022 at 1:39 PM Kyle Bendickson wrote:
> Hi Xintong!
>
> I’d love to take an early look if possible. I’m not a committer here, but I
> have a role in the Apache Iceberg slack and am looking forward to the Flink
>
Hi Xintong!
I’d love to take an early look if possible. I’m not a committer here, but I
have a role in the Apache Iceberg slack and am looking forward to the Flink
slack, particularly given the strong integration between Iceberg and Flink.
Thanks,
Kyle!
kjbendickson[at]gmail.com (preferred invite
All the blockers and major issues have been merged into release-1.0 branch.
Just follow what we have promised, I am preparing the first release
candidate now and will share it for the community-wide review today.
Best,
Yang
Márton Balassi 于2022年5月18日周三 00:29写道：
> Thanks Gyula and Yang. Awesome
Hi devs,
As we have approved on creating an Apache Flink Slack [1], I'm starting
this new thread to coordinate and give updates on the issues related to
initializing the slack workspace.
## Progress
1. Jark and I have worked on a draft of Slack Management Regulations [2],
including Code of Conduc
+1 (non-binding)
Best,
LuNing Wang
Nicholas Jiang 于2022年5月23日周一 12:57写道：
> +1 (non-binding)
>
> Best,
> Nicholas Jiang
>
> On 2022/05/20 02:38:39 Shengkai Fang wrote:
> > Hi, everyone.
> >
> > Thanks for your feedback for FLIP-91: Support SQL Gateway[1] on the
> > discussion thread[2]. I'd like
Aitozi created FLINK-27737:
--
Summary: Clean the outdated comments and unfencedMainExecutor
Key: FLINK-27737
URL: https://issues.apache.org/jira/browse/FLINK-27737
Project: Flink
Issue Type: Technica
+1 (non-binding)
Best,
Nicholas Jiang
On 2022/05/20 02:38:39 Shengkai Fang wrote:
> Hi, everyone.
>
> Thanks for your feedback for FLIP-91: Support SQL Gateway[1] on the
> discussion thread[2]. I'd like to start a vote for it. The vote will be
> open for at least 72 hours unless there is an obje
Thank Lincoln for the proposal!
The FLIP looks good to me. I'm in favor of the timer based implementation,
and I'd like to share some thoughts.
I'm thinking if we have to store the retry status in the state. I suppose
the retrying requests can just submit as the first attempt when the job
restore
LuNng Wang created FLINK-27736:
--
Summary: Pulsar sink catch watermark error
Key: FLINK-27736
URL: https://issues.apache.org/jira/browse/FLINK-27736
Project: Flink
Issue Type: Improvement
Hi,
Which port does flink UI run on in application mode?
If I am running 5 yarn jobs in application mode would the UI be same for
each or different ports for each?
Hi,
I'm getting this error in yarn application mode when submitting my job.
Caused by: java.lang.ClassCastException: cannot assign instance of
org.apache.commons.collections.map.LinkedMap to field
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase.pendingOffsetsToCommit
of type org
Hi, everyone can reply the issue but contributors also could not assign the
issue to themselves. You can reply to the discussion in the issue where you
what to fix the bug, and if a committer sees it, he will assign to you.
--
Best！
Xuyang
At 2022-05-22 18:58:02, "DavidLiu" wr
+1
Best,
Jingsong
On Sat, May 21, 2022 at 12:23 AM Shqiprim Bunjaku
wrote:
> +1 (non-binding)
>
> Best,
> Shqiprim Bunjaku
>
> On Fri, May 20, 2022 at 5:56 PM Yufei Zhang wrote:
>
> > +1 (non-binding)
> >
> > Best,
> > Yufei Zhang
> >
> > On Fri, May 20, 2022 at 11:24 AM Paul Lam wrote:
> >
>
Sergey Nuyanzin created FLINK-27735:
---
Summary: Update testcontainers dependency to v1.17.2
Key: FLINK-27735
URL: https://issues.apache.org/jira/browse/FLINK-27735
Project: Flink
Issue Type:
Feifan Wang created FLINK-27734:
---
Summary: Not showing checkpoint interval properly in WebUI when
checkpoint is disabled
Key: FLINK-27734
URL: https://issues.apache.org/jira/browse/FLINK-27734
Project:
Juntao Hu created FLINK-27733:
-
Summary: Rework on_timer output behind watermark bug fix
Key: FLINK-27733
URL: https://issues.apache.org/jira/browse/FLINK-27733
Project: Flink
Issue Type: Improve
Sergey Nuyanzin created FLINK-27732:
---
Summary: [JUnit5 Migration] Module: flink-examples-table
Key: FLINK-27732
URL: https://issues.apache.org/jira/browse/FLINK-27732
Project: Flink
Issue T
Hi Guys,
I want to contribute to Apache Flink.
Would you please give me the permission as a contributor?
My JIRA ID is DavidLiu001
Thanks & BR
DavidLiu
Hi Guys,
I want to contribute to Apache Flink.
Would you please give me the permission as a contributor?
My JIRA ID is DavidLiu001
Thanks & BR
DavidLiu
25 matches
Mail list logo
