[jira] [Created] (FLINK-32666) ASM rewrite class lead to package failed.

2023-07-25 Thread lizhiqiang (Jira)
lizhiqiang created FLINK-32666: -- Summary: ASM rewrite class lead to package failed. Key: FLINK-32666 URL: https://issues.apache.org/jira/browse/FLINK-32666 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

2023-07-25 Thread Fang Yong (Jira)
Fang Yong created FLINK-32667: - Summary: Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster Key: FLINK-32667 URL: https://issues.apache.org/jira/browse/FLINK-32667

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2023-07-25 Thread Konstantin Knauf
Hi Alex, yes, I think, it makes sense to support the last 1.x release longer than usual. This should be limited to bugfixes in my opinion. Best, Konstantin Am Di., 25. Juli 2023 um 07:07 Uhr schrieb Xintong Song < tonysong...@gmail.com>: > Hi Alex, > > Providing a longer supporting period for

Re: [VOTE][2.0] FLIP-336: Remove "now" timestamp field from REST responses

2023-07-25 Thread Zhu Zhu
+1 (binding) Thanks, Zhu Xintong Song 于2023年7月25日周二 09:46写道: > > +1 (binding) > > Best, > > Xintong > > > > On Mon, Jul 24, 2023 at 11:26 PM Jing Ge wrote: > > > +1(binding) > > > > On Mon, Jul 24, 2023 at 8:55 PM Matthias Pohl > > wrote: > > > > > +1 (binding) > > > > > > On Mon, Jul 24, 2023

[jira] [Created] (FLINK-32668) fix up watchdog timeout bug in common.sh(e2e test) ?

2023-07-25 Thread Hongshun Wang (Jira)
Hongshun Wang created FLINK-32668: - Summary: fix up watchdog timeout bug in common.sh(e2e test) ? Key: FLINK-32668 URL: https://issues.apache.org/jira/browse/FLINK-32668 Project: Flink Issue

Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package

2023-07-25 Thread Stefan Richter
+1 > On 24. Jul 2023, at 12:25, Chesnay Schepler wrote: > > To properly reflect the state of the rocksdb statebackend I propose to move > all classes in the state-backend-rocksdb module under the classes to > o.a.f.state.rocksdb package. > > > https://www.google.com/url?q=https://cwiki.ap

Re: [DISCUSS][2.0] FLIP-351: REST API normalizes +/-Inf / NaN to 0

2023-07-25 Thread Chesnay Schepler
Then we'd break the API for users that did already apply workarounds although the user hasn't done anything wrong. On 25/07/2023 04:31, Xintong Song wrote: we should treat these cases as errors Looking at the fields listed in the FLIP, I'd agree with this argument. And based on this, shouldn'

Re: [DISCUSS][2.0] FLIP-352: Use camelCast for all REST API fields/parameters

2023-07-25 Thread Chesnay Schepler
On 25/07/2023 04:09, Xintong Song wrote: In this case, I wonder if it makes sense to bump the REST API version to V2. That should allow us to gradually phase out the old APIs without the above mentioned problems. It's ultimately possible do do that; it just implies duplicating _a lot_ classes an

[jira] [Created] (FLINK-32669) Support port-range for taskmanager data port

2023-07-25 Thread chenyuzhi (Jira)
chenyuzhi created FLINK-32669: - Summary: Support port-range for taskmanager data port Key: FLINK-32669 URL: https://issues.apache.org/jira/browse/FLINK-32669 Project: Flink Issue Type: Improvemen

Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package

2023-07-25 Thread Jing Ge
make sense. Best regards, Jing On Tue, Jul 25, 2023 at 4:29 PM Stefan Richter wrote: > > +1 > > > > > On 24. Jul 2023, at 12:25, Chesnay Schepler wrote: > > > > To properly reflect the state of the rocksdb statebackend I propose to > move all classes in the state-backend-rocksdb module under t

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Sergey Nuyanzin
Congratulations, Yong Fang! On Tue, Jul 25, 2023 at 7:53 AM ConradJam wrote: > Congratulations, Yong Fang > > Mang Zhang 于2023年7月25日周二 12:08写道: > > > Congratulations, Yong Fang! > > > > > > -- > > > > Best regards, > > Mang Zhang > > > > > > > > > > > > 在 2023-07-25 10:30:24,"Jark Wu" 写道: > >

Re: Re: Re: [DISCUSS][2.0] FLIP-347: Remove IOReadableWritable serialization in Path

2023-07-25 Thread Junrui Lee
+1 Best, Junrui Jing Ge 于2023年7月24日周一 23:28写道: > agree, since we want to try our best to deprecate APIs in 1.18, it makes > sense. > > > Best regards, > Jing > > On Mon, Jul 24, 2023 at 12:11 PM Wencong Liu wrote: > > > Hi Jing and Matthias, > > > > > > I believe it is reasonable to examin

Re: [DISCUSS][2.0] FLIP-352: Use camelCast for all REST API fields/parameters

2023-07-25 Thread Xintong Song
Thanks for the explanation. I'd be fine with not bumping the version, if it requires that much effort. Best, Xintong On Tue, Jul 25, 2023 at 4:44 PM Chesnay Schepler wrote: > On 25/07/2023 04:09, Xintong Song wrote: > > In this case, I wonder if it makes sense to bump the REST API version t

Re: Re: [DISCUSS][2.0] FLIP-344: Remove parameter in RichFunction#open

2023-07-25 Thread Junrui Lee
+1 Best, Junrui Wencong Liu 于2023年7月24日周一 20:12写道: > Hi Timo, > > > Thanks for you reply. I think adding an empty OpenContext to keep the > signature is > reasonable. I'll modify the FLIP at a later time. > > > Best, > Wencong Liu > > > > > > > > > > > > > > > > > > At 2023-07-24 17:11:44, "Tim

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2023-07-25 Thread Márton Balassi
Hi team, +1 for supporting the last 1.x for a longer than usual period of time and limiting it to bugfixes. I would suggest supporting it for double the usual amount of time (4 minor releases). On Tue, Jul 25, 2023 at 9:25 AM Konstantin Knauf wrote: > Hi Alex, > > yes, I think, it makes sense t

Re: [DISCUSS][2.0] FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

2023-07-25 Thread Junrui Lee
+1 Best, Junrui weijie guo 于2023年7月24日周一 10:25写道: > +1 for this. > > Best regards, > > Weijie > > > liu ron 于2023年7月24日周一 09:58写道: > > > +1 > > > > Best, > > Ron > > > > Yuxin Tan 于2023年7月21日周五 16:21写道: > > > > > +1 > > > > > > Best, > > > Yuxin > > > > > > > > > Jing Ge 于2023年7月21日周五 15:41写

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2023-07-25 Thread Jing Ge
Hi all, Overall, it is a good idea to provide the LTS release, but I'd like to reference a concrete case as an example to understand what restrictions the LTS should have. Hypothetically, Source-/Sink- Function have been deprecated in 1.x LTS and removed in 2.0 and the issues[1] are not solved in

[DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-25 Thread Timo Walther
Hi everyone, I would like to start a discussion about introducing the concept of "System Columns" in SQL and Table API. The subject sounds bigger than it actually is. Luckily, Flink SQL already exposes the concept of metadata columns. And this proposal is just a slight adjustment for how met

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2023-07-25 Thread Konstantin Knauf
Hi Jing, let's not overindex on the Source-/SinkFunction discussion in this thread. We will generally drop/break a lot of APIs in Flink 2.0. So, naturally users will need to make more changes to their code in order to migrate from 1.x to Flink 2.0. In order to give them more time to do this, we s

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-25 Thread Konstantin Knauf
Hi Timo, this makes sense to me. Option 3 seems reasonable, too. Cheers, Konstantin Am Di., 25. Juli 2023 um 12:53 Uhr schrieb Timo Walther : > Hi everyone, > > I would like to start a discussion about introducing the concept of > "System Columns" in SQL and Table API. > > The subject sounds b

[jira] [Created] (FLINK-32670) Annotate interfaces that inherit from SourceFunction as deprecated

2023-07-25 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32670: - Summary: Annotate interfaces that inherit from SourceFunction as deprecated Key: FLINK-32670 URL: https://issues.apache.org/jira/browse/FLINK-32670 Project

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Yu Li
Congrats, Yong! Best Regards, Yu On Tue, 25 Jul 2023 at 18:03, Sergey Nuyanzin wrote: > Congratulations, Yong Fang! > > On Tue, Jul 25, 2023 at 7:53 AM ConradJam wrote: > > > Congratulations, Yong Fang > > > > Mang Zhang 于2023年7月25日周二 12:08写道: > > > > > Congratulations, Yong Fang! > > > > >

Re: [VOTE] Release 2.0 must-have work items - Round 2

2023-07-25 Thread Yu Li
+1 (binding) Thanks for driving this, Xintong! Best Regards, Yu On Sun, 23 Jul 2023 at 18:28, Yuan Mei wrote: > +1 (binding) > > Thanks for driving the discussion through and for all the efforts in > resolving the complexities :-) > > Best > Yuan > > On Thu, Jul 20, 2023 at 5:23 PM Xintong So

[jira] [Created] (FLINK-32671) Document Externalized Declarative Resource Management

2023-07-25 Thread Konstantin Knauf (Jira)
Konstantin Knauf created FLINK-32671: Summary: Document Externalized Declarative Resource Management Key: FLINK-32671 URL: https://issues.apache.org/jira/browse/FLINK-32671 Project: Flink

Re: [VOTE] Release 2.0 must-have work items - Round 2

2023-07-25 Thread Konstantin Knauf
I assume this vote includes a decision to not removing SourceFunction/SinkFunction in Flink 2.0 (as it has been removed from the table). If this is the case, I don't think, this discussion has concluded. There are multiple contributors like myself, Martijn, Alex Fedulov and Maximilian Michels, who

Re: [DISCUSS] Connectors, Formats, and even User Code should also be pluggable.

2023-07-25 Thread Benchao Li
I agree with Jing that the current doc is quite preliminary, and needs to be turned into a FLIP. I'll be very interested in this FLIP, and looking forward to it. We've suffered from reshading/relocating heavy connector dependencies for a long time. Besides, we've implemented a plugin mechanism to

Re: [DISCUSSION] Revival of FLIP-154 (SQL Implicit Type Coercion)

2023-07-25 Thread Benchao Li
Hi Sergey, There is a discussion[1] for this FLIP before. I like this feature, thanks for driving this. I hope it does not need to much customization (if there is any improvement which would benefit both Calcite and Flink, it would be great to push those also to upstream project, and I would like

Re: Flink suspected BUG

2023-07-25 Thread Matthias Pohl
Hi liuwb9, thanks for reporting this issue. Please keep a few things in mind, though: - The community only supports the two most-recently released versions of Flink. Your version 1.14 is too old (issues might have been fixed already in newer releases). Trying to reproduce the behavior in a supporte

Re: [VOTE] Release 2.0 must-have work items

2023-07-25 Thread Leonard Xu
We’ve detailed offline discussions with @Alexander and @Jingsong, about “Remove SourceFunction” item, we’ve reached a consensus as following: 1. Deprecate SourceFunction in 1.18 and implement following improvement subtasks of FLINK-28045[1] later is reasonable for all of us. 2. Deleting SourceF

[jira] [Created] (FLINK-32672) Migrate RabbitMQ connector to Source V2 API

2023-07-25 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32672: - Summary: Migrate RabbitMQ connector to Source V2 API Key: FLINK-32672 URL: https://issues.apache.org/jira/browse/FLINK-32672 Project: Flink Issue T

[jira] [Created] (FLINK-32673) Migrage Google PubSub connector to V2

2023-07-25 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-32673: - Summary: Migrage Google PubSub connector to V2 Key: FLINK-32673 URL: https://issues.apache.org/jira/browse/FLINK-32673 Project: Flink Issue Type: S

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Jing Ge
Congrats, Yong Fang! Best regards, Jing On Tue, Jul 25, 2023 at 7:35 PM Yu Li wrote: > Congrats, Yong! > > Best Regards, > Yu > > > On Tue, 25 Jul 2023 at 18:03, Sergey Nuyanzin wrote: > > > Congratulations, Yong Fang! > > > > On Tue, Jul 25, 2023 at 7:53 AM ConradJam wrote: > > > > > Congrat

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Matthias Pohl
Congratulations :) On Tue, Jul 25, 2023 at 5:13 PM Jing Ge wrote: > Congrats, Yong Fang! > > Best regards, > Jing > > On Tue, Jul 25, 2023 at 7:35 PM Yu Li wrote: > > > Congrats, Yong! > > > > Best Regards, > > Yu > > > > > > On Tue, 25 Jul 2023 at 18:03, Sergey Nuyanzin > wrote: > > > > > Con

Re: [DISCUSS] FLIP-348: Support System Columns in SQL and Table API

2023-07-25 Thread Jing Ge
Hi Timo, Thanks for your proposal. It is a very pragmatic feature. Among all options in the FLIP, option 3 is one I prefer too and I'd like to ask some questions to understand your thoughts. 1. I did some research on pseudo columns, just out of curiosity, do you know why most SQL systems do not n

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

2023-07-25 Thread Jing Ge
Hi Konstantin, I might have not made myself clear enough, apologies. The source-/sink-function was used as a concrete example to discuss the pattern before we decided to offer LTS. The intention was not to hijack this thread to discuss how to deprecate them. We all wish that the only thing users

Re: [VOTE] Release 2.0 must-have work items

2023-07-25 Thread Jing Ge
Thanks Leonard for driving it. We are now on the same page. Best regards, Jing On Tue, Jul 25, 2023 at 9:19 PM Leonard Xu wrote: > We’ve detailed offline discussions with @Alexander and @Jingsong, about > “Remove SourceFunction” item, we’ve reached a consensus as following: > > 1. Deprecate Sou

Re: [DISCUSS] Add missing visibility annotation for Table APIs

2023-07-25 Thread Jing Ge
Hi Jane, Thanks for your effort of walking through all classes and compiling the sheet. It is quite helpful. Just out of curiosity, do we really need to mark some many classes as @Internal? What is the exactly different between a public class with no annotation and with the @Internal? Best regard

Re: [DISCUSS] FLIP-326: Enhance Watermark to Support Processing-Time Temporal Join

2023-07-25 Thread David Anderson
Dong, Thank you for the careful analysis of my proposal. Your conclusions make sense to me. David On Mon, Jul 24, 2023 at 8:37 PM Dong Lin wrote: > > Hi David, > > Thank you for the detailed comments and the suggestion of this alternative > approach. > > I agree with you that this alternative

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Danny Cranmer
Congrats and welcome! Danny. On Tue, 25 Jul 2023, 16:48 Matthias Pohl, wrote: > Congratulations :) > > On Tue, Jul 25, 2023 at 5:13 PM Jing Ge > wrote: > > > Congrats, Yong Fang! > > > > Best regards, > > Jing > > > > On Tue, Jul 25, 2023 at 7:35 PM Yu Li wrote: > > > > > Congrats, Yong! > >

[jira] [Created] (FLINK-32674) Add documentation for the new Context.getTargetColumns

2023-07-25 Thread lincoln lee (Jira)
lincoln lee created FLINK-32674: --- Summary: Add documentation for the new Context.getTargetColumns Key: FLINK-32674 URL: https://issues.apache.org/jira/browse/FLINK-32674 Project: Flink Issue Ty

Re: [VOTE] Release 2.0 must-have work items

2023-07-25 Thread Xintong Song
Thanks Leonard for driving this, and thanks everyone for the discussion. The back-and-force reflects the importance and complexity around this topic. Glad to see we finally reached consensus. Best, Xintong On Wed, Jul 26, 2023 at 12:42 AM Jing Ge wrote: > Thanks Leonard for driving it. We ar

[jira] [Created] (FLINK-32675) Add doc for the tiered storage of hybrid shuffle

2023-07-25 Thread Yuxin Tan (Jira)
Yuxin Tan created FLINK-32675: - Summary: Add doc for the tiered storage of hybrid shuffle Key: FLINK-32675 URL: https://issues.apache.org/jira/browse/FLINK-32675 Project: Flink Issue Type: Improv

Re: [VOTE] Release 2.0 must-have work items - Round 2

2023-07-25 Thread Xintong Song
Hi Konstantin, It seems the offline discussion has already taken place [1], and part of the outcome is that removal of SourceFunction would be a *nice-to-have* item for release 2.0 which may not block this *must-have* vote. Do you have different opinions about the conclusions in [1]? If there are

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread weijie guo
Congrats, Yong Fang! Best regards, Weijie Danny Cranmer 于2023年7月26日周三 03:34写道: > Congrats and welcome! > > Danny. > > On Tue, 25 Jul 2023, 16:48 Matthias Pohl, > wrote: > > > Congratulations :) > > > > On Tue, Jul 25, 2023 at 5:13 PM Jing Ge > > wrote: > > > > > Congrats, Yong Fang! > > > >

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Yanfei Lei
Congratulations! Best regards, Yanfei weijie guo 于2023年7月26日周三 10:10写道: > > Congrats, Yong Fang! > > Best regards, > > Weijie > > > Danny Cranmer 于2023年7月26日周三 03:34写道: > > > Congrats and welcome! > > > > Danny. > > > > On Tue, 25 Jul 2023, 16:48 Matthias Pohl, > > wrote: > > > > > Congratulat

[jira] [Created] (FLINK-32676) Add doc for catalog modification listener

2023-07-25 Thread Fang Yong (Jira)
Fang Yong created FLINK-32676: - Summary: Add doc for catalog modification listener Key: FLINK-32676 URL: https://issues.apache.org/jira/browse/FLINK-32676 Project: Flink Issue Type: Improvement

Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Yuxin Tan
Congratulations, Yong Fang! Best, Yuxin Yanfei Lei 于2023年7月26日周三 10:18写道: > Congratulations! > > Best regards, > Yanfei > > weijie guo 于2023年7月26日周三 10:10写道: > > > > Congrats, Yong Fang! > > > > Best regards, > > > > Weijie > > > > > > Danny Cranmer 于2023年7月26日周三 03:34写道: > > > > > Congrats

Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Feifan Wang
Congratulations, Yong Fang! Best, Feifan Wang | | Feifan Wang | | zoltar9...@163.com | Replied Message | From | Yuxin Tan | | Date | 07/26/2023 10:25 | | To | | | Subject | Re: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang | Congratulations, Yong Fang! Best, Yuxin Yanfei

Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package

2023-07-25 Thread Yanfei Lei
+1 for moving all classes in the state-backend-rocksdb module under the classes to o.a.f.state.rocksdb package. I have always been curious about the relationship between o.a.f.contrib.xx and the flink-contrib module. :) Best, Yanfei Jing Ge 于2023年7月25日周二 17:50写道: > > make sense. > > Best regard

Re: [DISCUSS] Feature freeze and deprecation work for 2.0

2023-07-25 Thread Qingsheng Ren
(Sorry for resending this. I forgot to cc the dev mailing list) Hi Matthias and Xintong, Thanks for raising the question! We brought it to the 1.18 release sync on Jul 26th, and we decided to stick to the original schedule of 1.18 and will not accept new features, including those deprecation work

Re: [DISCUSS] Feature freeze and deprecation work for 2.0

2023-07-25 Thread Xintong Song
Thanks for the response, Qingsheng. I'm fine with not allowing new features after the 1.18 freeze. Just want to double-check, how about the FLIPs that purely mark things as `@Deprecated` without adding anything new? Do we agree to treat them as "not new features"? Best, Xintong On Wed, Jul 2

Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang

2023-07-25 Thread Yun Tang
Congratulations, Yong Fang 🙂 Best Yun Tang From: Feifan Wang Sent: Wednesday, July 26, 2023 10:36 To: dev@flink.apache.org Cc: dev@flink.apache.org Subject: Re: [ANNOUNCE] New Apache Flink Committer - Yong Fang Congratulations, Yong Fang! Best, Feifan Wang

Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package

2023-07-25 Thread Yu Li
+1 Best Regards, Yu On Wed, 26 Jul 2023 at 10:47, Yanfei Lei wrote: > +1 for moving all classes in the state-backend-rocksdb module under > the classes to o.a.f.state.rocksdb package. > > I have always been curious about the relationship between > o.a.f.contrib.xx and the flink-contrib module.

[jira] [Created] (FLINK-32677) flink-benchmarks-regression-check failed to send slack messages since 2023.07.17

2023-07-25 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-32677: -- Summary: flink-benchmarks-regression-check failed to send slack messages since 2023.07.17 Key: FLINK-32677 URL: https://issues.apache.org/jira/browse/FLINK-32677 Project:

Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package

2023-07-25 Thread Yun Tang
+1 (binding) Best Yun Tang From: Yu Li Sent: Wednesday, July 26, 2023 14:10 To: dev@flink.apache.org Subject: Re: [DISCUSS][2.0] FLIP-349: Move RocksDB statebackend classes to o.a.f.state.rocksdb package +1 Best Regards, Yu On Wed, 26 Jul 2023 at 10:47, Yanf

[VOTE][2.0] FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

2023-07-25 Thread Wencong Liu
Hi dev, I'd like to start a vote on FLIP-343. Discussion thread: https://lists.apache.org/thread/zn11f460x70nn7f2ckqph41bvx416wxc FLIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=263425229 Best regards, Wencong Liu

[VOTE][2.0] FLIP-347: Remove IOReadableWritable serialization in Path

2023-07-25 Thread Wencong Liu
Hi dev, I'd like to start a vote on FLIP-347. Discussion thread: https://lists.apache.org/thread/3gcxhnqpsvb85golnlxf9tv5p43xkjgj FLIP: https://cwiki.apache.org/confluence/display/FLINK/FLIP-347%3A+Remove+IOReadableWritable+serialization+in+Path Best regards, Wencong Liu

[VOTE][2.0] FLIP-344: Remove parameter in RichFunction#open

2023-07-25 Thread Wencong Liu
Hi dev, I'd like to start a vote on FLIP-344. Discussion thread: https://lists.apache.org/thread/5lyjrrdtwkngkol2t541r4xwoh7133km FLIP: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=263425231 Best regards, Wencong Liu

Re: [VOTE][2.0] FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

2023-07-25 Thread weijie guo
+1 (binding) Best regards, Weijie Wencong Liu 于2023年7月26日周三 14:26写道: > Hi dev, > > > I'd like to start a vote on FLIP-343. > > > Discussion thread: > https://lists.apache.org/thread/zn11f460x70nn7f2ckqph41bvx416wxc > FLIP: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=263

[jira] [Created] (FLINK-32678) Test FLIP-285 LeaderElection

2023-07-25 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-32678: - Summary: Test FLIP-285 LeaderElection Key: FLINK-32678 URL: https://issues.apache.org/jira/browse/FLINK-32678 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-32679) Filter conditions cannot be pushed to JOIN in some case

2023-07-25 Thread grandfisher (Jira)
grandfisher created FLINK-32679: --- Summary: Filter conditions cannot be pushed to JOIN in some case Key: FLINK-32679 URL: https://issues.apache.org/jira/browse/FLINK-32679 Project: Flink Issue T