[jira] [Created] (FLINK-18578) Add rejecting checkpoint logic in source

2020-07-13 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-18578: - Summary: Add rejecting checkpoint logic in source Key: FLINK-18578 URL: https://issues.apache.org/jira/browse/FLINK-18578 Project: Flink Issue Type: New Fe

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Dian Fu
Thanks a lot for the confirmation, Leonard! > 在 2020年7月13日,上午11:37,Leonard Xu 写道: > > Thanks Dian for the work, I’m fine with do not include FLINK-17726 in this > bug-fix version. > > Best, > Leonard Xu > >> 在 2020年7月13日,11:31,Dian Fu 写道: >> >> Hi all, >> >> I have gone over the issues me

[jira] [Created] (FLINK-18579) Remove deprecated classes in flink-connector-jdbc

2020-07-13 Thread Jark Wu (Jira)
Jark Wu created FLINK-18579: --- Summary: Remove deprecated classes in flink-connector-jdbc Key: FLINK-18579 URL: https://issues.apache.org/jira/browse/FLINK-18579 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-18580) Incomplete conversion for MySQL types

2020-07-13 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-18580: Summary: Incomplete conversion for MySQL types Key: FLINK-18580 URL: https://issues.apache.org/jira/browse/FLINK-18580 Project: Flink Issue Type: Bug

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Yun Tang
Hi If we decide to release Flink-1.11.1, I suggest to include fix for FLINK-18573 [1] as current influxdb metrics reporter is totally broken from Flink-1.11 under current plugins mechanism. [1] https://issues.apache.org/jira/browse/FLINK-18573 Best Yun Tang Fro

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Chesnay Schepler
Given that we are _just now_ starting to get bug reports, shouldn't we wait a bit longer with the next release? On 13/07/2020 10:30, Yun Tang wrote: Hi If we decide to release Flink-1.11.1, I suggest to include fix for FLINK-18573 [1] as current influxdb metrics reporter is totally broken fr

[jira] [Created] (FLINK-18581) Cannot find GC cleaner with java version previous 8u202

2020-07-13 Thread Xintong Song (Jira)
Xintong Song created FLINK-18581: Summary: Cannot find GC cleaner with java version previous 8u202 Key: FLINK-18581 URL: https://issues.apache.org/jira/browse/FLINK-18581 Project: Flink Issue

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Jark Wu
Hi Chesnay, As discussed in the thread, 1.11.1 is a quick fix release, not a normal fix release process. This is in order to deliver a complete feature for users to try out 1.11 ASAP. Actually, we already waited for the bugs for one week, and we have received some blocker issues reported by users

[jira] [Created] (FLINK-18582) add title anchor link for file event_driven.zh.md

2020-07-13 Thread Herman, Li (Jira)
Herman, Li created FLINK-18582: -- Summary: add title anchor link for file event_driven.zh.md Key: FLINK-18582 URL: https://issues.apache.org/jira/browse/FLINK-18582 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

2020-07-13 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18583: -- Summary: The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink Key: FLINK-18583 URL: https://issues.apache.org/jira/browse/FLINK-18583 Project: Fli

[jira] [Created] (FLINK-18584) JDBCLookupFunction not support AsyncLookupFunction

2020-07-13 Thread ranqiqiang (Jira)
ranqiqiang created FLINK-18584: -- Summary: JDBCLookupFunction not support AsyncLookupFunction Key: FLINK-18584 URL: https://issues.apache.org/jira/browse/FLINK-18584 Project: Flink Issue Type: I

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Chesnay Schepler
It would be good to fix FLINK-18581 as well. On 13/07/2020 11:14, Jark Wu wrote: Hi Chesnay, As discussed in the thread, 1.11.1 is a quick fix release, not a normal fix release process. This is in order to deliver a complete feature for users to try out 1.11 ASAP. Actually, we already waited fo

[jira] [Created] (FLINK-18585) Dynamic index can not work in new DynamicTableSink

2020-07-13 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18585: -- Summary: Dynamic index can not work in new DynamicTableSink Key: FLINK-18585 URL: https://issues.apache.org/jira/browse/FLINK-18585 Project: Flink Issue Type: Bu

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Dian Fu
Thanks! It makes sense to include FLINK-18573 and FLINK-18581 in 1.11.1. > 在 2020年7月13日,下午5:52,Chesnay Schepler 写道: > > It would be good to fix FLINK-18581 as well. > > On 13/07/2020 11:14, Jark Wu wrote: >> Hi Chesnay, >> >> As discussed in the thread, 1.11.1 is a quick fix release, not a nor

[ANNOUNCE] Weekly Community Update 2020/28

2020-07-13 Thread Konstantin Knauf
Dear community, happy to share this week's community update with a discussion on releasing Flink 1.11.1, FLIPs on a Python DataStream API and improvements to the "Connect API" of the Table API and a bit more. Flink Development == * [releases] Flink 1.11.0 was released. Check out the

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Jark Wu
After discussing FLINK-18581 with @Xintong Song offline, it seems that it doesn't need to block 1.11.1. Because users can switch to use another version of JDK as a workaround. Besides, this might not be a trivial issue, we may need more time to come up with a clean solution and check compatibility

[jira] [Created] (FLINK-18586) Simplify the creation of explicit structured types

2020-07-13 Thread Timo Walther (Jira)
Timo Walther created FLINK-18586: Summary: Simplify the creation of explicit structured types Key: FLINK-18586 URL: https://issues.apache.org/jira/browse/FLINK-18586 Project: Flink Issue Type

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Xintong Song
Thanks for the updates, Jark. + 1 for not blocking 1.11.1 with FLINK-18581. - The workaround requires upgrading to a later version of JDK8. I believe such minor version migration should be acceptable in most cases. - The original effort is contributed by Andrey & Till, both on vacation at the mom

[jira] [Created] (FLINK-18587) java.lang.IllegalArgumentException: Position out of bounds

2020-07-13 Thread Ori Popowski (Jira)
Ori Popowski created FLINK-18587: Summary: java.lang.IllegalArgumentException: Position out of bounds Key: FLINK-18587 URL: https://issues.apache.org/jira/browse/FLINK-18587 Project: Flink Is

[jira] [Created] (FLINK-18588) hive ddl create table should support 'if not exists'

2020-07-13 Thread wangtong (Jira)
wangtong created FLINK-18588: Summary: hive ddl create table should support 'if not exists' Key: FLINK-18588 URL: https://issues.apache.org/jira/browse/FLINK-18588 Project: Flink Issue Type: Impr

Use of SinkFunction.Context without generic parameter.

2020-07-13 Thread Niels Basjes
Hi, I prefer to have my code as "warning free" as possible so I was looking through some of the warnings my IDE gives about some of the Flink code I'm working on when I ran into this: Raw use of parameterized class 'SinkFunction.Context' Apparently the interface for a SinkFunction has the metho

[jira] [Created] (FLINK-18589) java.io.EOFException when reading integer state

2020-07-13 Thread Ori Popowski (Jira)
Ori Popowski created FLINK-18589: Summary: java.io.EOFException when reading integer state Key: FLINK-18589 URL: https://issues.apache.org/jira/browse/FLINK-18589 Project: Flink Issue Type: B

Re: Kinesis Performance Issue (was [VOTE] Release 1.11.0, release candidate #4)

2020-07-13 Thread Thomas Weise
+ dev@ for visibility I will investigate further today. On Wed, Jul 8, 2020 at 4:42 AM Aljoscha Krettek wrote: > On 06.07.20 20:39, Stephan Ewen wrote: > >- Did sink checkpoint notifications change in a relevant way, for > example > > due to some Kafka issues we addressed in 1.11 (@Aljosch

[jira] [Created] (FLINK-18590) Support json array explode to multi messages

2020-07-13 Thread Benchao Li (Jira)
Benchao Li created FLINK-18590: -- Summary: Support json array explode to multi messages Key: FLINK-18590 URL: https://issues.apache.org/jira/browse/FLINK-18590 Project: Flink Issue Type: Improvem

Re: [DISCUSS] Releasing Flink 1.11.1 soon?

2020-07-13 Thread Dian Fu
Thanks Jark and Xintong for the investigation of this problem. I'm fine to not include FLINK-18581 in 1.11.1 considering that there are workaround and it requires some time to come out with a proper fix. @Chesnay, what's your thought? An update of the other issues: - FLINK-17075: Add task status

[jira] [Created] (FLINK-18591) Fix the format issue for metrics web page

2020-07-13 Thread Zhijiang (Jira)
Zhijiang created FLINK-18591: Summary: Fix the format issue for metrics web page Key: FLINK-18591 URL: https://issues.apache.org/jira/browse/FLINK-18591 Project: Flink Issue Type: Bug C

[jira] [Created] (FLINK-18592) StreamingFileSink fails due to truncating HDFS file failure

2020-07-13 Thread JIAN WANG (Jira)
JIAN WANG created FLINK-18592: - Summary: StreamingFileSink fails due to truncating HDFS file failure Key: FLINK-18592 URL: https://issues.apache.org/jira/browse/FLINK-18592 Project: Flink Issue

[jira] [Created] (FLINK-18593) Hive bundle jar URLs are broken

2020-07-13 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-18593: Summary: Hive bundle jar URLs are broken Key: FLINK-18593 URL: https://issues.apache.org/jira/browse/FLINK-18593 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-18594) The link is broken in kafka doc

2020-07-13 Thread Dian Fu (Jira)
Dian Fu created FLINK-18594: --- Summary: The link is broken in kafka doc Key: FLINK-18594 URL: https://issues.apache.org/jira/browse/FLINK-18594 Project: Flink Issue Type: Bug Components: D