Re: [ANNOUNCE] New scalafmt formatter has been merged

2022-04-12 Thread Timo Walther
Thanks for the great work Francesco! This will improve the contributor productivity a lot and ease reviews. This change was long overdue. Regards, Timo Am 12.04.22 um 17:21 schrieb Francesco Guardiani: Hi all, The new scalafmt formatter has been merged. From now on, just using mvn spotless:a

[jira] [Created] (FLINK-27215) JDBC sink transiently deleted a record because of -u message of that record

2022-04-12 Thread tim yu (Jira)
tim yu created FLINK-27215: -- Summary: JDBC sink transiently deleted a record because of -u message of that record Key: FLINK-27215 URL: https://issues.apache.org/jira/browse/FLINK-27215 Project: Flink

Re: FLINK-11746 work

2022-04-12 Thread Yu Li
Hi Chen, Thanks for the interest to work on this. Before assigning the JIRA and starting the upstream work, how about reviving the discussion thread [1] first, making sure to reach a consensus on the design and find committer resources for code review, according to our code contribution process [

Re: Re: [VOTE] Release 1.15.0, release candidate #1

2022-04-12 Thread Yun Gao
Hi Yu, Yes, the RC1 is officially canceled, the pointer has been moved to RC2 now~ Very thanks for the tips of remaining open issues! They should indeed be moved and I'll move them to the next release~ Best, Yun Gao -- From:Yu L

Re: Re: [VOTE] Release 1.15.0, release candidate #1

2022-04-12 Thread Yu Li
Thanks for the efforts, Yun and Joe! According to the earlier reply, the vote of RC1 is officially canceled, right? And just a reminder that there are still many open issues with FixVersion marked as 1.15.0 [1] and I think most of them (if not all, meaning some more bug fixes are still expected t

Re: Contributing to FLINK-27195

2022-04-12 Thread Yu Li
Hi Mason, Thanks for the efforts. I could see that Ingo has already assigned it to you (and thanks Ingo for the action). Best Regards, Yu On Tue, 12 Apr 2022 at 14:42, Mason Chen wrote: > Hi Devs, > > Could a committer assign me this ticket: > https://issues.apache.org/jira/browse/FLINK-27195

[jira] [Created] (FLINK-27214) Build Failed on state backend benchmark

2022-04-12 Thread Yuan Mei (Jira)
Yuan Mei created FLINK-27214: Summary: Build Failed on state backend benchmark Key: FLINK-27214 URL: https://issues.apache.org/jira/browse/FLINK-27214 Project: Flink Issue Type: Bug R

[jira] [Created] (FLINK-27213) Add PurgingTrigger

2022-04-12 Thread zhangjingcun (Jira)
zhangjingcun created FLINK-27213: Summary: Add PurgingTrigger Key: FLINK-27213 URL: https://issues.apache.org/jira/browse/FLINK-27213 Project: Flink Issue Type: New Feature Compone

[jira] [Created] (FLINK-27212) Failed to CAST('abcde', VARBINARY)

2022-04-12 Thread Shengkai Fang (Jira)
Shengkai Fang created FLINK-27212: - Summary: Failed to CAST('abcde', VARBINARY) Key: FLINK-27212 URL: https://issues.apache.org/jira/browse/FLINK-27212 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-27211) RBAC deployments/finalizers missing for OpenShift Deployment

2022-04-12 Thread James Busche (Jira)
James Busche created FLINK-27211: Summary: RBAC deployments/finalizers missing for OpenShift Deployment Key: FLINK-27211 URL: https://issues.apache.org/jira/browse/FLINK-27211 Project: Flink

[jira] [Created] (FLINK-27210) StateFun example link on datastream integration page is broken

2022-04-12 Thread Mans Singh (Jira)
Mans Singh created FLINK-27210: -- Summary: StateFun example link on datastream integration page is broken Key: FLINK-27210 URL: https://issues.apache.org/jira/browse/FLINK-27210 Project: Flink I

[jira] [Created] (FLINK-27209) Half the Xmx and double the forkCount for unit tests

2022-04-12 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-27209: -- Summary: Half the Xmx and double the forkCount for unit tests Key: FLINK-27209 URL: https://issues.apache.org/jira/browse/FLINK-27209 Project: Flink Issu

[ANNOUNCE] New scalafmt formatter has been merged

2022-04-12 Thread Francesco Guardiani
Hi all, The new scalafmt formatter has been merged. From now on, just using mvn spotless:apply as usual will format both Java and Scala, and Intellij will automatically pick up the scalafmt config for who has the Scala plugin installed. If it doesn't, just go in Preferences > Editor > Code Style >

[jira] [Created] (FLINK-27208) Update the documentation to configure the IDE with scalafmt

2022-04-12 Thread Timo Walther (Jira)
Timo Walther created FLINK-27208: Summary: Update the documentation to configure the IDE with scalafmt Key: FLINK-27208 URL: https://issues.apache.org/jira/browse/FLINK-27208 Project: Flink

Re: [VOTE] Release 1.15.0, release candidate #2

2022-04-12 Thread Yun Gao
The last two reference links are [5] https://github.com/apache/flink/releases/tag/release-1.15.0-rc2/ [6] https://github.com/apache/flink-web/pull/526 Sorry it seems that the newline has something wrong with my mailbox. --Original Mail -- Sender:Yun Gao Send Da

[VOTE] Release 1.15.0, release candidate #2

2022-04-12 Thread Yun Gao
Hi everyone, Please review and vote on the release candidate #2 for the version 1.15.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], *

[jira] [Created] (FLINK-27207) Support built-in parquet format

2022-04-12 Thread Yubin Li (Jira)
Yubin Li created FLINK-27207: Summary: Support built-in parquet format Key: FLINK-27207 URL: https://issues.apache.org/jira/browse/FLINK-27207 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-27206) Deprecate reflection-based reporter instantiation

2022-04-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-27206: Summary: Deprecate reflection-based reporter instantiation Key: FLINK-27206 URL: https://issues.apache.org/jira/browse/FLINK-27206 Project: Flink Iss

[jira] [Created] (FLINK-27205) Translate "Concepts -> Glossary" page into Chinese

2022-04-12 Thread Zhuang Liu (Jira)
Zhuang Liu created FLINK-27205: --- Summary: Translate "Concepts -> Glossary" page into Chinese Key: FLINK-27205 URL: https://issues.apache.org/jira/browse/FLINK-27205 Project: Flink Issue Type:

[jira] [Created] (FLINK-27204) FileSystemJobResultStore should operator on the ioExecutor

2022-04-12 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-27204: - Summary: FileSystemJobResultStore should operator on the ioExecutor Key: FLINK-27204 URL: https://issues.apache.org/jira/browse/FLINK-27204 Project: Flink

Update regarding externalizing existing connectors and new connectors

2022-04-12 Thread Martijn Visser
Hi everyone, After our discussion thread on "Creating an external connector repository" [1], "Moving connectors from Flink to external connector repositories" [2] and "Plan to externalize connectors and versioning" [3] I wanted to give you an update on the current situation, what we're working on

Re: Re: [VOTE] Release 1.15.0, release candidate #1

2022-04-12 Thread Yun Gao
Hi Jing, No worry, very thanks for fixing the issue and informing us. I'll then head to create the rc2 today. Best, Yun --Original Mail -- Sender:Jing Zhang Send Date:Tue Apr 12 18:55:30 2022 Recipients:dev Subject:Re: [VOTE] Release 1.15.0, release candidate

Re: [VOTE] Release 1.15.0, release candidate #1

2022-04-12 Thread Jing Zhang
Hi, Yun Gao There is a new bug [1] introduced in release-1.15. It's better to be fixed in 1.15.0 version. I'm terribly sorry to merge the pull request too late. [1] https://issues.apache.org/jira/browse/FLINK-26681 Best, Jing Zhang Johannes Moser 于2022年4月12日周二 14:53写道: > Here is the missing li

[jira] [Created] (FLINK-27203) Add supports for uploading jars from object storage (s3, gcs, oss)

2022-04-12 Thread Xin Hao (Jira)
Xin Hao created FLINK-27203: --- Summary: Add supports for uploading jars from object storage (s3, gcs, oss) Key: FLINK-27203 URL: https://issues.apache.org/jira/browse/FLINK-27203 Project: Flink Iss

[jira] [Created] (FLINK-27202) NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer

2022-04-12 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-27202: -- Summary: NullPointerException on stop-with-savepoint with AsyncWaitOperator followed by FlinkKafkaProducer Key: FLINK-27202 URL: https://issues.apache.org/jira/browse/FLINK-2

[jira] [Created] (FLINK-27201) Remove CollectTableSink

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27201: --- Summary: Remove CollectTableSink Key: FLINK-27201 URL: https://issues.apache.org/jira/browse/FLINK-27201 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-12 Thread David Morávek
Hi David, I really like the proposal. This has so much potential for various optimizations, especially for temporal joins. My only concern is that the interfaces seems unnecessarily complicated. My feeling would be that we only need a single, simple interface that would fit it all (the same way a

[jira] [Created] (FLINK-27200) Replace CollectionTableSource and CollectionTableSink with new table stack alternatives

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27200: --- Summary: Replace CollectionTableSource and CollectionTableSink with new table stack alternatives Key: FLINK-27200 URL: https://issues.apache.org/jira/browse/FLINK-27

[jira] [Created] (FLINK-27199) Bump Pulsar to 2.10.0 for increasing the test stability

2022-04-12 Thread Yufan Sheng (Jira)
Yufan Sheng created FLINK-27199: --- Summary: Bump Pulsar to 2.10.0 for increasing the test stability Key: FLINK-27199 URL: https://issues.apache.org/jira/browse/FLINK-27199 Project: Flink Issue T

[jira] [Created] (FLINK-27198) Cleanup tests testing legacy TableSink/TableSource

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27198: --- Summary: Cleanup tests testing legacy TableSink/TableSource Key: FLINK-27198 URL: https://issues.apache.org/jira/browse/FLINK-27198 Project: Flink

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-12 Thread Jingsong Li
Hi David, Thanks for driving. I understand that state storage itself supports byte ordering, have we considered exposing Binary**State? This way the upper layers can be implemented on demand, Temporal is just one of them. Best, Jingsong On Tue, Apr 12, 2022 at 3:01 PM Aitozi wrote: > > Hi Davi

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-12 Thread Yun Tang
Hi David, Could you share some explanations why SortedMapState cannot work in details? I just cannot catch up what the statement below means: This was rejected as being overly difficult to implement in a way that would cleanly leverage RocksDB’s iterators. Best Yun Tang _

[jira] [Created] (FLINK-27197) Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27197: --- Summary: Port ArrowTableSource and PythonInputFormatTableSource to DynamicTableSource Key: FLINK-27197 URL: https://issues.apache.org/jira/browse/FLINK-27197

[jira] [Created] (FLINK-27196) Remove old format interfaces

2022-04-12 Thread Francesco Guardiani (Jira)
Francesco Guardiani created FLINK-27196: --- Summary: Remove old format interfaces Key: FLINK-27196 URL: https://issues.apache.org/jira/browse/FLINK-27196 Project: Flink Issue Type: Sub-ta

Re: [DISCUSS] FLIP-220: Temporal State

2022-04-12 Thread Aitozi
Hi David I have look through the doc, I think it will be a good improvement to this pattern usage, I'm interested in it. Do you have some POC work to share for a closer look. Besides, I have one question that can we support expose the namespace in the different state type not limited to `Tempo