Re: [DISCUSS] Creating an external connector repository

2021-10-29 Thread Till Rohrmann
Hi everyone, >From the discussion, it seems to me that we have different opinions whether to have an ASF umbrella repository or to host them outside of the ASF. It also seems that this is not really the problem to solve. Since there are many good arguments for either approach, we could simply

[jira] [Created] (FLINK-24708) `ConvertToNotInOrInRule` has a bug which leads to wrong result

2021-10-29 Thread JING ZHANG (Jira)
JING ZHANG created FLINK-24708: -- Summary: `ConvertToNotInOrInRule` has a bug which leads to wrong result Key: FLINK-24708 URL: https://issues.apache.org/jira/browse/FLINK-24708 Project: Flink

Re: [DISCUSS] FLIP-188: Introduce Built-in Dynamic Table Storage

2021-10-29 Thread Till Rohrmann
Hi Jingsong, Thanks for creating this FLIP. I don't have a lot to add because I am not very familiar with the SQL components. While reading the FLIP I was wondering what would we need in Flink to build something like the BDT feature outside of Flink as a kind of extension? Would something like

Re: [DISCUSS] FLIP-189: SQL Client Usability Improvements

2021-10-29 Thread Till Rohrmann
Thanks for creating this FLIP Sergey. I think what you propose sounds like very good improvements for the SQL client. This should make the client a lot more ergonomic :-) Cheers, Till On Fri, Oct 29, 2021 at 11:26 AM Sergey Nuyanzin wrote: > Hi Martijn, > > Thank you for your suggestion with

Re: [DISCUSS] FLIP-187: Adaptive Batch Job Scheduler

2021-10-29 Thread Till Rohrmann
Hi Lijie, Thanks for drafting this FLIP together with Zhu Zhu :-) I like the idea of making the parallelism of operators of a bounded job dependent on the data size. This makes the job adjust automatically when the data sources/sizes change. I can see this work well in combination with the

Re: [DISCUSS] FLIP-174: Improve the WithParam interface (Flink ML)

2021-10-29 Thread Dong Lin
Hi Jiangjie, Thanks for the review! Please find below my explanations. On Fri, Oct 29, 2021 at 8:49 PM Becket Qin wrote: > Hi Dong and Zhiping, > > Thanks for writing up the FLIP and sorry for the belated review. The FLIP > looks good to me overall. Just a few minor comments / questions about

[jira] [Created] (FLINK-24707) Upgrade Curator framework dependecy.

2021-10-29 Thread Jira
David Morávek created FLINK-24707: - Summary: Upgrade Curator framework dependecy. Key: FLINK-24707 URL: https://issues.apache.org/jira/browse/FLINK-24707 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-174: Improve the WithParam interface (Flink ML)

2021-10-29 Thread Becket Qin
Hi Dong and Zhiping, Thanks for writing up the FLIP and sorry for the belated review. The FLIP looks good to me overall. Just a few minor comments / questions about WithParams. 1. Currently all the methods in the WithParams interface have a default implementation. It is not clear to me what

[jira] [Created] (FLINK-24706) AkkaInvocationHandler silently ignores deserialization errors

2021-10-29 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24706: Summary: AkkaInvocationHandler silently ignores deserialization errors Key: FLINK-24706 URL: https://issues.apache.org/jira/browse/FLINK-24706 Project: Flink

[jira] [Created] (FLINK-24705) Flink blood relationship

2021-10-29 Thread HideOnBush (Jira)
HideOnBush created FLINK-24705: -- Summary: Flink blood relationship Key: FLINK-24705 URL: https://issues.apache.org/jira/browse/FLINK-24705 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-24704) Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-10-29 Thread lincoln lee (Jira)
lincoln lee created FLINK-24704: --- Summary: Exception occurs when the input record loses monotonicity on the sort key field of UpdatableTopNFunction Key: FLINK-24704 URL:

[jira] [Created] (FLINK-24703) Add support for reading CSV files based on StreamFormat (new file source API)

2021-10-29 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-24703: - Summary: Add support for reading CSV files based on StreamFormat (new file source API) Key: FLINK-24703 URL: https://issues.apache.org/jira/browse/FLINK-24703

[jira] [Created] (FLINK-24702) toUpperCase/toLowerCase calls may cause problems with some system locales

2021-10-29 Thread Jira
Mathias Fußenegger created FLINK-24702: -- Summary: toUpperCase/toLowerCase calls may cause problems with some system locales Key: FLINK-24702 URL: https://issues.apache.org/jira/browse/FLINK-24702

[jira] [Created] (FLINK-24701) "late events" link in "Timely Stream Processing" document is not working

2021-10-29 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-24701: --- Summary: "late events" link in "Timely Stream Processing" document is not working Key: FLINK-24701 URL: https://issues.apache.org/jira/browse/FLINK-24701 Project:

Re: [DISCUSS] FLIP-189: SQL Client Usability Improvements

2021-10-29 Thread Sergey Nuyanzin
Hi Martijn, Thank you for your suggestion with POC. Yes I will do that and come back to this thread probably after the weekend On Thu, Oct 28, 2021 at 4:38 PM Martijn Visser wrote: > Hi Sergey, > > Thanks for taking the initiative to create a FLIP and propose improvements > on the SQL client.

Re: [NOTICE] CiBot improvements

2021-10-29 Thread JING ZHANG
Thanks a lot @Chesnay, I would try again. Chesnay Schepler 于2021年10月29日周五 下午4:21写道： > When you 'run azure', check the build after a minute or so and you > should see that the failed job is running again. > > > > On 29/10/2021 10:19, Chesnay Schepler wrote: > > It's working just fine. You need

[jira] [Created] (FLINK-24700) Clarify semantics of filter, projection, partition, and metadata pushdown

2021-10-29 Thread Timo Walther (Jira)
Timo Walther created FLINK-24700: Summary: Clarify semantics of filter, projection, partition, and metadata pushdown Key: FLINK-24700 URL: https://issues.apache.org/jira/browse/FLINK-24700 Project:

[jira] [Created] (FLINK-24699) Move scalastyle execution to validation phase

2021-10-29 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24699: Summary: Move scalastyle execution to validation phase Key: FLINK-24699 URL: https://issues.apache.org/jira/browse/FLINK-24699 Project: Flink Issue

Re: [NOTICE] CiBot improvements

2021-10-29 Thread Chesnay Schepler
When you 'run azure', check the build after a minute or so and you should see that the failed job is running again. On 29/10/2021 10:19, Chesnay Schepler wrote: It's working just fine. You need to rebase your branch because on your branch flink-python is simply broken. On 29/10/2021 08:57,

Re: [NOTICE] CiBot improvements

2021-10-29 Thread Chesnay Schepler
It's working just fine. You need to rebase your branch because on your branch flink-python is simply broken. On 29/10/2021 08:57, JING ZHANG wrote: Hi Chesnay, I meet with something weird. I submit a pull request https://github.com/apache/flink/pull/17571, it trigger a ci

[jira] [Created] (FLINK-24698) Unified operator used in transformation

2021-10-29 Thread jianzhang.yjz (Jira)
jianzhang.yjz created FLINK-24698: - Summary: Unified operator used in transformation Key: FLINK-24698 URL: https://issues.apache.org/jira/browse/FLINK-24698 Project: Flink Issue Type:

[jira] [Created] (FLINK-24697) Kafka table source cannot change the auto.offset.reset setting

2021-10-29 Thread Hang Ruan (Jira)
Hang Ruan created FLINK-24697: - Summary: Kafka table source cannot change the auto.offset.reset setting Key: FLINK-24697 URL: https://issues.apache.org/jira/browse/FLINK-24697 Project: Flink

[jira] [Created] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2021-10-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24696: -- Summary: Translate how to configure unaligned checkpoints into Chinese Key: FLINK-24696 URL: https://issues.apache.org/jira/browse/FLINK-24696 Project: Flink

[jira] [Created] (FLINK-24695) Update how to configure unaligned checkpoints in the documentation

2021-10-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24695: -- Summary: Update how to configure unaligned checkpoints in the documentation Key: FLINK-24695 URL: https://issues.apache.org/jira/browse/FLINK-24695 Project:

[jira] [Created] (FLINK-24694) Translate "Checkpointing under backpressure" page into Chinese

2021-10-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24694: -- Summary: Translate "Checkpointing under backpressure" page into Chinese Key: FLINK-24694 URL: https://issues.apache.org/jira/browse/FLINK-24694 Project: Flink

[jira] [Created] (FLINK-24693) Update Chinese version of "Checkpoints" page

2021-10-29 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-24693: -- Summary: Update Chinese version of "Checkpoints" page Key: FLINK-24693 URL: https://issues.apache.org/jira/browse/FLINK-24693 Project: Flink Issue Type:

????

2021-10-29 Thread 249968839
249968...@qq.com

退订

2021-10-29 Thread sh_0...@126.com
sh_0...@126.com

[jira] [Created] (FLINK-24692) kubernetes session mode deployment failed since slot allocation timeout

2021-10-29 Thread Zhou Parker (Jira)
Zhou Parker created FLINK-24692: --- Summary: kubernetes session mode deployment failed since slot allocation timeout Key: FLINK-24692 URL: https://issues.apache.org/jira/browse/FLINK-24692 Project: Flink

Re: Re: [NOTICE] CiBot improvements

2021-10-29 Thread JING ZHANG
Hi Chesnay, I meet with something weird. I submit a pull request https://github.com/apache/flink/pull/17571, it trigger a ci ( https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=25470=results) which fails at first time because of python module failure. I try to run 'run azure'

[jira] [Created] (FLINK-24691) FLINK SQL SUM() causes a precision error

2021-10-29 Thread Zongwen Li (Jira)
Zongwen Li created FLINK-24691: -- Summary: FLINK SQL SUM() causes a precision error Key: FLINK-24691 URL: https://issues.apache.org/jira/browse/FLINK-24691 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

2021-10-29 Thread Anton Kalashnikov (Jira)
Anton Kalashnikov created FLINK-24690: - Summary: Clarification of buffer size threshold calculation in BufferDebloater Key: FLINK-24690 URL: https://issues.apache.org/jira/browse/FLINK-24690