Hi 华宗
退订请发送任意消息至dev-unsubscr...@flink.apache.org
In order to unsubscribe, please send an email to
dev-unsubscr...@flink.apache.org
Thanks
Best regards,
Jing
On Tue, Jun 14, 2022 at 2:05 AM 华宗 wrote:
> 退订
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> At 2022-06-13 22:44:24, "cao zou" wrote:
> >Hi
Jiangfei Liu created FLINK-28037:
Summary: Flink SQL Upsert-Kafka can not support Flink1.14.x
Key: FLINK-28037
URL: https://issues.apache.org/jira/browse/FLINK-28037
Project: Flink
Issue
luoyuxia created FLINK-28036:
Summary: Use correct writable type to creaet
ConstantObjectInspector
Key: FLINK-28036
URL: https://issues.apache.org/jira/browse/FLINK-28036
Project: Flink
Issue
+1 (non-binding)
- verify signatures and checksums
- no binaries found in source archive
- build from source
- verify python wheel package contents
- pip install apache-flink-libraries and apache-flink wheel packages
- run the examples from Python Table API tutorial
Best,
Xingbo
Konstantin
Congratulations, Jingsong!
Best,
Jing Zhang
Leonard Xu 于2022年6月14日周二 10:54写道：
> Congratulations, Jingsong!
>
>
> Best,
> Leonard
>
> > 2022年6月13日 下午6:52，刘首维 写道：
> >
> > Congratulations and well deserved, Jingsong!
> >
> >
> > Best regards,
> > Shouwei
> >
Congratulations, Jingsong!
Best,
Leonard
> 2022年6月13日 下午6:52，刘首维 写道：
>
> Congratulations and well deserved, Jingsong!
>
>
> Best regards,
> Shouwei
> --原始邮件--
> 发件人:
>
Jane Chan created FLINK-28035:
-
Summary: Enable scan reading different bucket num for rescale
bucket
Key: FLINK-28035
URL: https://issues.apache.org/jira/browse/FLINK-28035
Project: Flink
Issue
In general, I'll give a big +1 to deprecating the SourceFunction.
That said, it is indeed worth looking into what might be missing or less
easy to implement with FLIP-27 Source compared with the SourceFunction.
Maybe we can just compile a list of things to do in order to fully
deprecate the
Takayuki Eimizu created FLINK-28034:
---
Summary: ClassCastException occurred in creating a checkpoint with
merge windows
Key: FLINK-28034
URL: https://issues.apache.org/jira/browse/FLINK-28034
YeAble created FLINK-28033:
--
Summary: find and output new min watermark mybe wrong when in
multichannel
Key: FLINK-28033
URL: https://issues.apache.org/jira/browse/FLINK-28033
Project: Flink
Issue
退订
At 2022-06-13 22:44:24, "cao zou" wrote:
>Hi godfrey, thanks for your detail explanation.
>After explaining and glancing over the FLIP-231, I think it is
>really need, +1 for this and looking forward to it.
>
>best
>zoucao
>
>godfrey he 于2022年6月13日周一 14:43写道：
>
>> Hi Ingo,
>>
Pauli Gandhi created FLINK-28032:
Summary: Flink checkpointing hangs with some jobs
Key: FLINK-28032
URL: https://issues.apache.org/jira/browse/FLINK-28032
Project: Flink
Issue Type: Bug
Pauli Gandhi created FLINK-28031:
Summary: Checkpoint always hangs when running some jobs
Key: FLINK-28031
URL: https://issues.apache.org/jira/browse/FLINK-28031
Project: Flink
Issue Type:
Pauli Gandhi created FLINK-28030:
Summary: Checkpoint always hangs when running some jobs
Key: FLINK-28030
URL: https://issues.apache.org/jira/browse/FLINK-28030
Project: Flink
Issue Type:
Pauli Gandhi created FLINK-28029:
Summary: Checkpoint always hangs when running some jobs
Key: FLINK-28029
URL: https://issues.apache.org/jira/browse/FLINK-28029
Project: Flink
Issue Type:
Jing Ge created FLINK-28028:
---
Summary: Common secure credential protection mechanism in Flink SQL
Key: FLINK-28028
URL: https://issues.apache.org/jira/browse/FLINK-28028
Project: Flink
Issue Type:
Zichen Liu created FLINK-28027:
--
Summary: Initialise Async Sink maximum number of in flight
messages to low number for rate limiting strategy
Key: FLINK-28027
URL: https://issues.apache.org/jira/browse/FLINK-28027
@Nick Have you checked whether this really affects Flink`?
Asking since the regressions doesn't categorically affect every mixed
code base.
On 13/06/2022 16:50, Nick wrote:
I think upgrading to 2.12.15 would be the correct choice, as 2.12.16 has a
known regression for projects compiled with
Hi,
I have one flink job which has two tasks
Task1- Source some static data over https and keep it in memory, this keeps
refreshing it every 1 hour
Task2- Process some real-time events from Kafka and uses static data to
validate something and transform, then forward to other Kafka topic.
so far,
I think upgrading to 2.12.15 would be the correct choice, as 2.12.16 has a
known regression for projects compiled with Java & Scala, which Flink does:
https://github.com/scala/scala/releases/tag/v2.12.16
This regression will be addressed in a few months via 2.12.17, so for now
2.12.15 should be
Hi godfrey, thanks for your detail explanation.
After explaining and glancing over the FLIP-231, I think it is
really need, +1 for this and looking forward to it.
best
zoucao
godfrey he 于2022年6月13日周一 14:43写道：
> Hi Ingo,
>
> The semantics does not distinguish batch and streaming,
> It works for
Aiden Gong created FLINK-28026:
--
Summary: Add benchmark module for flink table store
Key: FLINK-28026
URL: https://issues.apache.org/jira/browse/FLINK-28026
Project: Flink
Issue Type: New
Biao Geng created FLINK-28025:
-
Summary: Document the change of serviceAccount in upgrading doc of
k8s opeator
Key: FLINK-28025
URL: https://issues.apache.org/jira/browse/FLINK-28025
Project: Flink
Matthias Pohl created FLINK-28024:
-
Summary: Azure worker stops operating due to log files becoming
too big
Key: FLINK-28024
URL: https://issues.apache.org/jira/browse/FLINK-28024
Project: Flink
Strongly +1
On 2022/06/13 09:59:17 Lihe Ma wrote:
> Hi, Everyone,
>
> I would like to open a discussion on setting incremental checkpoint as
default behavior.
>
> Currently, the configuration of state.backend.incremental is set as false
by default. Incremental checkpoint has been adopted widely
linqichen created FLINK-28023:
-
Summary: Translate "Native Kubernetes" page into Chinese
Key: FLINK-28023
URL: https://issues.apache.org/jira/browse/FLINK-28023
Project: Flink
Issue Type:
+1 (binding)
Op ma 13 jun. 2022 om 13:52 schreef Jark Wu :
> +1 (binding)
>
> nit: the stop job syntax should be
> STOP JOB '' [WITH SAVEPOINT] [WITH DRAIN]
> which means savepoint and drain can be enabled at the same time.
>
> Best,
> Jark
>
> On Mon, 13 Jun 2022 at 17:20, Jing Ge wrote:
>
> >
pengmd created FLINK-28022:
--
Summary: Support Google Cloud PubSub connector in Python
DataStream API
Key: FLINK-28022
URL: https://issues.apache.org/jira/browse/FLINK-28022
Project: Flink
Issue
+1 (binding)
Best regards
Utopia
2022年6月13日 +0800 10:16 dev@flink.apache.org，写道：
>
> Looking
+1
Best regards
Utopia
2022年6月13日 +0800 17:42 Xingbo Huang ，写道：
> +1 (binding)
>
> Best,
> Xingbo
>
> Dian Fu 于2022年6月13日周一 16:08写道：
>
> > +1 (binding)
> >
> > Regards,
> > Dian
> >
> > On Mon, Jun 13, 2022 at 3:55 PM Rui Fan <1996fan...@gmail.com> wrote:
> >
> > > Thanks for Nicholas driving
+1 (binding)
nit: the stop job syntax should be
STOP JOB '' [WITH SAVEPOINT] [WITH DRAIN]
which means savepoint and drain can be enabled at the same time.
Best,
Jark
On Mon, 13 Jun 2022 at 17:20, Jing Ge wrote:
> +1 (not binding)
>
> Thanks Paul for your effort!
>
> Best regards,
> Jing
>
>
Strongly +1
Best,
Rui Fan
On Mon, Jun 13, 2022 at 7:35 PM Martijn Visser
wrote:
> > BTW, from my knowledge, nothing would happen for HashMapStateBackend,
> which does not support incremental checkpoint yet, when enabling
> incremental checkpoints.
>
> Thanks Yun, if no errors would occur then
> BTW, from my knowledge, nothing would happen for HashMapStateBackend,
which does not support incremental checkpoint yet, when enabling
incremental checkpoints.
Thanks Yun, if no errors would occur then definitely +1 to enable it by
default
Op ma 13 jun. 2022 om 12:42 schreef Alexander Fedulov
Congratulations and well deserved, Jingsong!
Best regards,
Shouwei
----
??:
"dev"
+1
>From my experience, it is actually hard to come up with use cases where
incremental checkpoints should explicitly not be enabled with the RocksDB
state backend. If the state is so small that the full snapshots do not
have any negative impact, one should consider using HashMapStateBackend
Congratulations, Jingsong!
Best regards,
Yuxia
- 原始邮件 -
发件人: "Yun Tang"
收件人: "dev"
发送时间: 星期一, 2022年 6 月 13日 下午 6:12:24
主题: Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee
Congratulations, Jingsong! Well deserved.
Best
Yun Tang
From: Xingbo
+1
Glad to see the kickoff of this discussion. Thanks Lihe for driving this!
We have actually already discussed it internally a few months ago. After
considering some corner cases, all agreed on enabling the incremental
checkpoint as default.
Best regards,
Jing
On Mon, Jun 13, 2022 at 12:17 PM
Strongly +1 for making incremental checkpoints as default. Many users have ever
been asking why this configuration is not enabled by default.
BTW, from my knowledge, nothing would happen for HashMapStateBackend, which
does not support incremental checkpoint yet, when enabling incremental
Congratulations, Jingsong! Well deserved.
Best
Yun Tang
From: Xingbo Huang
Sent: Monday, June 13, 2022 17:39
To: dev
Subject: Re: [ANNOUNCE] New Apache Flink PMC Member - Jingsong Lee
Congratulations, Jingsong!
Best,
Xingbo
Jane Chan 于2022年6月13日周一 17:23写道：
Hi Lihe,
What happens if we enable incremental checkpoints by default while the used
memory backend is HashMapStateBackend, which doesn't support incremental
checkpoints?
Best regards,
Martijn
Op ma 13 jun. 2022 om 11:59 schreef Lihe Ma :
> Hi, Everyone,
>
> I would like to open a discussion
Hi, Everyone,
I would like to open a discussion on setting incremental checkpoint as default
behavior.
Currently, the configuration of state.backend.incremental is set as false by
default. Incremental checkpoint has been adopted widely in industry community
for many years , and it is also
+1 (binding)
Best,
Xingbo
Dian Fu 于2022年6月13日周一 16:08写道：
> +1 (binding)
>
> Regards,
> Dian
>
> On Mon, Jun 13, 2022 at 3:55 PM Rui Fan <1996fan...@gmail.com> wrote:
>
> > Thanks for Nicholas driving this.
> >
> > +1(non-binding)
> >
> > Best,
> > Rui Fan
> >
> > On Mon, Jun 13, 2022 at 3:05
Congratulations, Jingsong!
Best,
Xingbo
Jane Chan 于2022年6月13日周一 17:23写道：
> Congratulations, Jingsong!
>
> Best,
> Jane Chan
>
> On Mon, Jun 13, 2022 at 4:43 PM Shuo Cheng wrote:
>
> > Congratulations, Jingsong!
> >
> > On 6/13/22, Paul Lam wrote:
> > > Congrats, Jingsong! Well deserved!
> >
Martijn Visser created FLINK-28021:
--
Summary: Add FLIP-33 metrics to FileSystem connector
Key: FLINK-28021
URL: https://issues.apache.org/jira/browse/FLINK-28021
Project: Flink
Issue Type:
Congratulations, Jingsong!
Best,
Jane Chan
On Mon, Jun 13, 2022 at 4:43 PM Shuo Cheng wrote:
> Congratulations, Jingsong!
>
> On 6/13/22, Paul Lam wrote:
> > Congrats, Jingsong! Well deserved!
> >
> > Best,
> > Paul Lam
> >
> >> 2022年6月13日 16:31，Lincoln Lee 写道：
> >>
> >> Congratulations,
Congratulations, Jingsong!
Best,
Godfrey
Shuo Cheng 于2022年6月13日周一 16:43写道：
>
> Congratulations, Jingsong!
>
> On 6/13/22, Paul Lam wrote:
> > Congrats, Jingsong! Well deserved!
> >
> > Best,
> > Paul Lam
> >
> >> 2022年6月13日 16:31，Lincoln Lee 写道：
> >>
> >> Congratulations, Jingsong!
> >>
> >>
+1 (not binding)
Thanks Paul for your effort!
Best regards,
Jing
On Mon, Jun 13, 2022 at 11:11 AM Paul Lam wrote:
> Hi team,
>
> I'd like to start a vote for FLIP-222: Support full job lifecycle
> statements in SQL client [1],
> which is discussed on the thread [2].
>
> The vote will be open
Hi team,
I'd like to start a vote for FLIP-222: Support full job lifecycle statements in
SQL client [1],
which is discussed on the thread [2].
The vote will be open for at least 72 hours unless there is an objection or not
enough votes.
Thanks everyone who has participated in the
Caizhi Weng created FLINK-28020:
---
Summary: Refactor Flink connector for table store with
FileStoreTable
Key: FLINK-28020
URL: https://issues.apache.org/jira/browse/FLINK-28020
Project: Flink
Congratulations, Jingsong!
On 6/13/22, Paul Lam wrote:
> Congrats, Jingsong! Well deserved!
>
> Best,
> Paul Lam
>
>> 2022年6月13日 16:31，Lincoln Lee 写道：
>>
>> Congratulations, Jingsong!
>>
>> Best,
>> Lincoln Lee
>>
>>
>> Jark Wu 于2022年6月13日周一 16:29写道：
>>
>>> Congrats, Jingsong!
>>>
>>> Cheers,
Hi Yun,
Thanks for your reply!
Through offline communication with Dalong, I updated the JobStatusHook part to
FLIP, looking forward to your feedback.
--
Best regards,
Mang Zhang
At 2022-05-31 14:34:25, "Yun Gao" wrote:
>Hi,
>
>Regarding the drop operation, with some offline discussion
Hi team,
I think we’ve reached consensus on the FLIP, thus I’m starting a vote thread.
Thank you all for the your advice in the discussion!
Best,
Paul Lam
> 2022年6月10日 02:26，Jing Ge 写道：
>
> Hi Paul,
>
> Fired a ticket: https://issues.apache.org/jira/browse/FLINK-27977
>
zl created FLINK-28018:
--
Summary: the start index to create empty splits in
BinaryInputFormat#createInputSplits is inappropriate
Key: FLINK-28018
URL: https://issues.apache.org/jira/browse/FLINK-28018
Project:
Congrats, Jingsong! Well deserved!
Best,
Paul Lam
> 2022年6月13日 16:31，Lincoln Lee 写道：
>
> Congratulations, Jingsong!
>
> Best,
> Lincoln Lee
>
>
> Jark Wu 于2022年6月13日周一 16:29写道：
>
>> Congrats, Jingsong!
>>
>> Cheers,
>> Jark
>>
>> On Mon, 13 Jun 2022 at 16:16, Jiangang Liu
>> wrote:
>>
lincoln lee created FLINK-28019:
---
Summary: State staled errorRetractableTopNFunction
Key: FLINK-28019
URL: https://issues.apache.org/jira/browse/FLINK-28019
Project: Flink
Issue Type: Bug
Congratulations, Jingsong!
Best,
Lincoln Lee
Jark Wu 于2022年6月13日周一 16:29写道：
> Congrats, Jingsong!
>
> Cheers,
> Jark
>
> On Mon, 13 Jun 2022 at 16:16, Jiangang Liu
> wrote:
>
> > Congratulations, Jingsong!
> >
> > Best,
> > Jiangang Liu
> >
> > Martijn Visser 于2022年6月13日周一 16:06写道：
> >
> >
Congrats, Jingsong!
Cheers,
Jark
On Mon, 13 Jun 2022 at 16:16, Jiangang Liu
wrote:
> Congratulations, Jingsong!
>
> Best,
> Jiangang Liu
>
> Martijn Visser 于2022年6月13日周一 16:06写道：
>
> > Like everyone has mentioned, this is very well deserved. Congratulations!
> >
> > Op ma 13 jun. 2022 om
Hi Jing,
Thanks for your reply!
I recently updated the FLIP documentation, when you have time, you can look at
it again.
About Atomicity and Isolation, the main discussion point is on batch mode, to
be more specific is Hive/Spark.
My point of consideration is that according to the needs of
Jingsong Lee created FLINK-28017:
Summary: Introduce bucket-key to table store
Key: FLINK-28017
URL: https://issues.apache.org/jira/browse/FLINK-28017
Project: Flink
Issue Type: New Feature
Congratulations, Jingsong!
Best,
Jiangang Liu
Martijn Visser 于2022年6月13日周一 16:06写道：
> Like everyone has mentioned, this is very well deserved. Congratulations!
>
> Op ma 13 jun. 2022 om 09:57 schreef Benchao Li :
>
> > Congratulations, Jingsong! Well deserved.
> >
> > Rui Fan
Chesnay Schepler created FLINK-28016:
Summary: Support Maven 3.3+
Key: FLINK-28016
URL: https://issues.apache.org/jira/browse/FLINK-28016
Project: Flink
Issue Type: Technical Debt
+1 (binding)
Regards,
Dian
On Mon, Jun 13, 2022 at 3:55 PM Rui Fan <1996fan...@gmail.com> wrote:
> Thanks for Nicholas driving this.
>
> +1(non-binding)
>
> Best,
> Rui Fan
>
> On Mon, Jun 13, 2022 at 3:05 PM md peng wrote:
>
> > +1(not-binding)
> >
> > Best,
> > Mingde Peng
> >
> > Martijn
Like everyone has mentioned, this is very well deserved. Congratulations!
Op ma 13 jun. 2022 om 09:57 schreef Benchao Li :
> Congratulations, Jingsong! Well deserved.
>
> Rui Fan <1996fan...@gmail.com> 于2022年6月13日周一 15:53写道：
>
> > Congratulations, Jingsong!
> >
> > Best,
> > Rui Fan
> >
> > On
Congratulations, Jingsong!
Best,
Lijie
Rui Fan <1996fan...@gmail.com> 于2022年6月13日周一 15:53写道：
> Congratulations, Jingsong!
>
> Best,
> Rui Fan
>
> On Mon, Jun 13, 2022 at 3:40 PM LuNing Wang wrote:
>
> > Congratulations, Jingsong!
> >
> > Best,
> > LuNing Wang
> >
> > Ingo Bürk 于2022年6月13日周一
Congratulations, Jingsong! Well deserved.
Rui Fan <1996fan...@gmail.com> 于2022年6月13日周一 15:53写道：
> Congratulations, Jingsong!
>
> Best,
> Rui Fan
>
> On Mon, Jun 13, 2022 at 3:40 PM LuNing Wang wrote:
>
> > Congratulations, Jingsong!
> >
> > Best,
> > LuNing Wang
> >
> > Ingo Bürk
Thanks for Nicholas driving this.
+1(non-binding)
Best,
Rui Fan
On Mon, Jun 13, 2022 at 3:05 PM md peng wrote:
> +1(not-binding)
>
> Best,
> Mingde Peng
>
> Martijn Visser 于2022年6月13日周一 14:48写道：
>
> > +1 (binding)
> >
> > Looking forward :)
> >
> > Thanks, Martijn
> >
> > Op ma 13 jun. 2022
Congratulations, Jingsong!
Best,
Rui Fan
On Mon, Jun 13, 2022 at 3:40 PM LuNing Wang wrote:
> Congratulations, Jingsong!
>
> Best,
> LuNing Wang
>
> Ingo Bürk 于2022年6月13日周一 15:36写道：
>
> > Congrats, Jingsong!
> >
> > On 13.06.22 08:58, Becket Qin wrote:
> > > Hi all,
> > >
> > > I'm very happy
Congrats, Jingsong! Very well deserved!
Best regards,
Jing
On Mon, Jun 13, 2022 at 9:39 AM LuNing Wang wrote:
> Congratulations, Jingsong!
>
> Best,
> LuNing Wang
>
> Ingo Bürk 于2022年6月13日周一 15:36写道：
>
> > Congrats, Jingsong!
> >
> > On 13.06.22 08:58, Becket Qin wrote:
> > > Hi all,
> > >
>
Congratulations, Jingsong!
Best,
LuNing Wang
Ingo Bürk 于2022年6月13日周一 15:36写道：
> Congrats, Jingsong!
>
> On 13.06.22 08:58, Becket Qin wrote:
> > Hi all,
> >
> > I'm very happy to announce that Jingsong Lee has joined the Flink PMC!
> >
> > Jingsong became a Flink committer in Feb 2020 and has
Congrats, Jingsong!
On 13.06.22 08:58, Becket Qin wrote:
Hi all,
I'm very happy to announce that Jingsong Lee has joined the Flink PMC!
Jingsong became a Flink committer in Feb 2020 and has been continuously
contributing to the project since then, mainly in Flink SQL. He has been
quite active
Congratulations, Jingsong!
Regards,
Nicholas Jiang
On 2022/06/13 07:01:11 Qingsheng Ren wrote:
> Congratulations, Jingsong!
>
> Best,
> Qingsheng
>
> > On Jun 13, 2022, at 14:58, Becket Qin wrote:
> >
> > Hi all,
> >
> > I'm very happy to announce that Jingsong Lee has joined the Flink
+1(not-binding)
Best,
Mingde Peng
Martijn Visser 于2022年6月13日周一 14:48写道：
> +1 (binding)
>
> Looking forward :)
>
> Thanks, Martijn
>
> Op ma 13 jun. 2022 om 04:16 schreef Nicholas :
>
> > Hi everyone，
> >
> >
> >
> >
> > Thanks for feedback for FLIP-228: Support Within between events in CEP
> >
Congratulations, Jingsong!
Best,
Qingsheng
> On Jun 13, 2022, at 14:58, Becket Qin wrote:
>
> Hi all,
>
> I'm very happy to announce that Jingsong Lee has joined the Flink PMC!
>
> Jingsong became a Flink committer in Feb 2020 and has been continuously
> contributing to the project since
Hi all,
I'm very happy to announce that Jingsong Lee has joined the Flink PMC!
Jingsong became a Flink committer in Feb 2020 and has been continuously
contributing to the project since then, mainly in Flink SQL. He has been
quite active in the mailing list, fixing bugs, helping verifying
+1 (binding)
Looking forward :)
Thanks, Martijn
Op ma 13 jun. 2022 om 04:16 schreef Nicholas :
> Hi everyone，
>
>
>
>
> Thanks for feedback for FLIP-228: Support Within between events in CEP
> Pattern[1] on the discussion thread[2]. I'd like to start a VOTE thread for
> FLIP-228.
>
> The vote
Hi Ingo,
The semantics does not distinguish batch and streaming,
It works for both batch and streaming, but the result of
unbounded sources is meaningless.
Currently, I throw exception for streaming mode,
and we can support streaming mode with bounded source
in the future.
Best,
Godfrey
Ingo
Hi Godfrey,
thank you for the explanation. A SELECT is definitely more generic and
will work for all connectors automatically. As such I think it's a good
baseline solution regardless.
We can also think about allowing connector-specific optimizations in the
future, but I do like your idea
77 matches
Mail list logo
