Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Jark Wu
Congratulations Xintong! Best, Jark On Fri, 5 Jun 2020 at 14:32, Danny Chan wrote: > Congratulations Xintong ! > > Best, > Danny Chan > 在 2020年6月5日 +0800 PM2:20,dev@flink.apache.org,写道: > > > > Congratulations Xintong >

[jira] [Created] (FLINK-18146) The note of  StreamingJobGraphGenerator#createJobGraph has a misspelling

2020-06-05 Thread ZhuShang (Jira)
ZhuShang created FLINK-18146: Summary: The note of  StreamingJobGraphGenerator#createJobGraph has a misspelling Key: FLINK-18146 URL: https://issues.apache.org/jira/browse/FLINK-18146 Project: Flink

[jira] [Created] (FLINK-18147) Orc document display is disordered

2020-06-05 Thread Shuai Xia (Jira)
Shuai Xia created FLINK-18147: - Summary: Orc document display is disordered Key: FLINK-18147 URL: https://issues.apache.org/jira/browse/FLINK-18147 Project: Flink Issue Type: Bug Compon

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread tison
Congrats, Xintong! Best, tison. Jark Wu 于2020年6月5日周五 下午3:00写道: > Congratulations Xintong! > > Best, > Jark > > On Fri, 5 Jun 2020 at 14:32, Danny Chan wrote: > > > Congratulations Xintong ! > > > > Best, > > Danny Chan > > 在 2020年6月5日 +0800 PM2:20,dev@flink.apache.org,写道: > > > > > > Congratu

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Congxian Qiu
Congratulations! Xintong! Best, Congxian Jark Wu 于2020年6月5日周五 下午3:00写道: > Congratulations Xintong! > > Best, > Jark > > On Fri, 5 Jun 2020 at 14:32, Danny Chan wrote: > > > Congratulations Xintong ! > > > > Best, > > Danny Chan > > 在 2020年6月5日 +0800 PM2:20,dev@flink.apache.org,写道: > > > > > >

[jira] [Created] (FLINK-18148) "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop()

2020-06-05 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18148: -- Summary: "Resuming Savepoint" e2e fails with TimeoutException in CliFrontend.stop() Key: FLINK-18148 URL: https://issues.apache.org/jira/browse/FLINK-18148 Proje

Re: [Discussion] flink elasticsearch connector supports

2020-06-05 Thread Forward Xu
hi Jacky Lau : I agree with jark's point of view, the use of es is not just to read data, more use is to group query, aggregate these. Best, Forward Jacky Lau 于2020年6月5日周五 下午2:47写道: > hi Etienne Chauchot: > you can read here https://www.jianshu.com/p/d32e17dab90c, which is > chinese.But you ca

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

2020-06-05 Thread Leonard Xu
+1 for Jingsong’s proposal to put flink-csv, flink-json and flink-avro under lib/ directory. I have heard many SQL users(most of newbies) complaint the out-of-box experience in mail list. Best, Leonard Xu > 在 2020年6月5日,14:39,Benchao Li 写道: > > +1 to include them for sql-client by default; >

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Yu Li
Congratulations Xintong, well deserved! Best Regards, Yu On Fri, 5 Jun 2020 at 15:12, Congxian Qiu wrote: > Congratulations! Xintong! > Best, > Congxian > > > Jark Wu 于2020年6月5日周五 下午3:00写道: > > > Congratulations Xintong! > > > > Best, > > Jark > > > > On Fri, 5 Jun 2020 at 14:32, Danny Chan

[jira] [Created] (FLINK-18149) Taskmanager logs could not show up in native K8s deployment

2020-06-05 Thread Yang Wang (Jira)
Yang Wang created FLINK-18149: - Summary: Taskmanager logs could not show up in native K8s deployment Key: FLINK-18149 URL: https://issues.apache.org/jira/browse/FLINK-18149 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Rui Li
Congrats Xintong! On Fri, Jun 5, 2020 at 3:12 PM Congxian Qiu wrote: > Congratulations! Xintong! > Best, > Congxian > > > Jark Wu 于2020年6月5日周五 下午3:00写道: > > > Congratulations Xintong! > > > > Best, > > Jark > > > > On Fri, 5 Jun 2020 at 14:32, Danny Chan wrote: > > > > > Congratulations Xinton

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

2020-06-05 Thread Rui Li
+1 to add light-weighted formats into the lib On Fri, Jun 5, 2020 at 3:28 PM Leonard Xu wrote: > +1 for Jingsong’s proposal to put flink-csv, flink-json and flink-avro > under lib/ directory. > I have heard many SQL users(most of newbies) complaint the out-of-box > experience in mail list. > > B

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Dawid Wysakowicz
Congratulations! Best, Dawid On 05/06/2020 09:10, tison wrote: > Congrats, Xintong! > > Best, > tison. > > > Jark Wu 于2020年6月5日周五 下午3:00写道: > >> Congratulations Xintong! >> >> Best, >> Jark >> >> On Fri, 5 Jun 2020 at 14:32, Danny Chan wrote: >> >>> Congratulations Xintong ! >>> >>> Best, >>>

[jira] [Created] (FLINK-18150) A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata

2020-06-05 Thread Julius Michaelis (Jira)
Julius Michaelis created FLINK-18150: Summary: A single failing Kafka broker may cause jobs to fail indefinitely with TimeoutException: Timeout expired while fetching topic metadata Key: FLINK-18150 URL: http

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Yun Tang
Congratulations, Xintong Best Yun Tang From: Dawid Wysakowicz Sent: Friday, June 05, 2020 16:00 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song Congratulations! Best, Dawid On 05/06/2020 09:10, tison wrote: > Congrat

Re: [VOTE] Apache Flink Stateful Functions 2.1.0, release candidate #1

2020-06-05 Thread Robert Metzger
Thanks a lot for creating this release Gordon! +1 (binding) - maven staging repo looks fine (version tags, license files) - source archive looks good (no binaries, no unexpected files, pom has right version) - quickly checked diff: https://github.com/apache/flink-statefun/compare/release-2.0.0-rc

Re: [Discussion] flink elasticsearch connector supports

2020-06-05 Thread Etienne Chauchot
Hi Jacky Lau, 1) yes I saw that 2) I saw sources like IntegerSource which are bounded and which extend RichParallelSourceFunction. This is why I mentioned it. 3) True, there is an hadoop ES connector in Beam but it is more of a side connector, the main one is ElasticsearchIO here: https://g

[jira] [Created] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

2020-06-05 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-18151: --- Summary: Resolve CWE22 problems in pyflink_gateway_server.py Key: FLINK-18151 URL: https://issues.apache.org/jira/browse/FLINK-18151 Project: Flink Issue Type

[jira] [Created] (FLINK-18152) Master starts despite IllegalConfigurationException

2020-06-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18152: Summary: Master starts despite IllegalConfigurationException Key: FLINK-18152 URL: https://issues.apache.org/jira/browse/FLINK-18152 Project: Flink I

[jira] [Created] (FLINK-18153) flink-daemon does not detect errors if JVM crashes immediately

2020-06-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18153: Summary: flink-daemon does not detect errors if JVM crashes immediately Key: FLINK-18153 URL: https://issues.apache.org/jira/browse/FLINK-18153 Project: Flink

[jira] [Created] (FLINK-18155) Disable Log4j's JMX for (integration)tests

2020-06-05 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18155: -- Summary: Disable Log4j's JMX for (integration)tests Key: FLINK-18155 URL: https://issues.apache.org/jira/browse/FLINK-18155 Project: Flink Issue Type: I

[jira] [Created] (FLINK-18154) Unhelpful error message if heap.size takes up signficant portion of process.size

2020-06-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18154: Summary: Unhelpful error message if heap.size takes up signficant portion of process.size Key: FLINK-18154 URL: https://issues.apache.org/jira/browse/FLINK-18154

[jira] [Created] (FLINK-18156) Misleading error message if derived JVM overhead is too small

2020-06-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18156: Summary: Misleading error message if derived JVM overhead is too small Key: FLINK-18156 URL: https://issues.apache.org/jira/browse/FLINK-18156 Project: Flink

[jira] [Created] (FLINK-18157) Jobstore size check compares against offHeapMemory

2020-06-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18157: Summary: Jobstore size check compares against offHeapMemory Key: FLINK-18157 URL: https://issues.apache.org/jira/browse/FLINK-18157 Project: Flink Is

[jira] [Created] (FLINK-18158) Add a utility to create a DDL statement from avro schema

2020-06-05 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-18158: Summary: Add a utility to create a DDL statement from avro schema Key: FLINK-18158 URL: https://issues.apache.org/jira/browse/FLINK-18158 Project: Flink

[jira] [Created] (FLINK-18159) Add support for trimming stack traces in user-facing components

2020-06-05 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18159: Summary: Add support for trimming stack traces in user-facing components Key: FLINK-18159 URL: https://issues.apache.org/jira/browse/FLINK-18159 Project: Flin

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Till Rohrmann
Congratulations! Cheers, Till On Fri, Jun 5, 2020 at 10:00 AM Dawid Wysakowicz wrote: > Congratulations! > > Best, > > Dawid > > On 05/06/2020 09:10, tison wrote: > > Congrats, Xintong! > > > > Best, > > tison. > > > > > > Jark Wu 于2020年6月5日周五 下午3:00写道: > > > >> Congratulations Xintong! > >> >

[jira] [Created] (FLINK-18160) YARN session logs about HADOOP_CONF_DIR even though HADOOP_CLASSPATH containing a config is set

2020-06-05 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18160: -- Summary: YARN session logs about HADOOP_CONF_DIR even though HADOOP_CLASSPATH containing a config is set Key: FLINK-18160 URL: https://issues.apache.org/jira/browse/FLINK-1816

[jira] [Created] (FLINK-18161) Changing parallelism is not possible in sql-client.sh

2020-06-05 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-18161: -- Summary: Changing parallelism is not possible in sql-client.sh Key: FLINK-18161 URL: https://issues.apache.org/jira/browse/FLINK-18161 Project: Flink Iss

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Andrey Zagrebin
Welcome to committers and congrats, Xintong! Cheers, Andrey On Fri, Jun 5, 2020 at 4:22 PM Till Rohrmann wrote: > Congratulations! > > Cheers, > Till > > On Fri, Jun 5, 2020 at 10:00 AM Dawid Wysakowicz > wrote: > > > Congratulations! > > > > Best, > > > > Dawid > > > > On 05/06/2020 09:10, ti

[jira] [Created] (FLINK-18162) AddSplitEvents should serialize the splits into bytes.

2020-06-05 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-18162: Summary: AddSplitEvents should serialize the splits into bytes. Key: FLINK-18162 URL: https://issues.apache.org/jira/browse/FLINK-18162 Project: Flink Issue

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Zhijiang
Congratulations! Best, Zhijiang -- From:Andrey Zagrebin Send Time:2020年6月5日(星期五) 22:34 To:dev Subject:Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song Welcome to committers and congrats, Xintong! Cheers, Andrey On Fri, Ju

[jira] [Created] (FLINK-18163) Should be volatile: network.api.writer.RecordWriter.flusherException

2020-06-05 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-18163: - Summary: Should be volatile: network.api.writer.RecordWriter.flusherException Key: FLINK-18163 URL: https://issues.apache.org/jira/browse/FLINK-18163 Proje

[jira] [Created] (FLINK-18164) null <> 'str' should be true

2020-06-05 Thread Benchao Li (Jira)
Benchao Li created FLINK-18164: -- Summary: null <> 'str' should be true Key: FLINK-18164 URL: https://issues.apache.org/jira/browse/FLINK-18164 Project: Flink Issue Type: Bug Components

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-05 Thread Matt Wang
Congratulations! --- Best, Matt Wang On 06/5/2020 22:34,Andrey Zagrebin wrote: Welcome to committers and congrats, Xintong! Cheers, Andrey On Fri, Jun 5, 2020 at 4:22 PM Till Rohrmann wrote: Congratulations! Cheers, Till On Fri, Jun 5, 2020 at 10:00 AM Dawid Wysakowicz wrote: Congratula

Re: [DISCUSS] (Document) Backwards Compatibility of Savepoints

2020-06-05 Thread Congxian Qiu
Sorry for jumping in late. Currently, we only have a forward-compatible guarantee and do not have the backward-compatible guarantee. And as this may take a large effort to support the backward-compatible guarantee. so I agree that we should write this down explicitly. For the given scenario, I ha