Re: [DISCUSS] Drop Elasticssearch 1 connector

2019-04-09 Thread Jeff Zhang
+1 to drop this kind of thing to mitigate maintenance effort. Tzu-Li (Gordon) Tai 于2019年4月10日周三 下午2:17写道: > +1 to drop it. > > Elasticsearch 1.x is already 5 years old, and is already highly discouraged > to be used by the Elasticsearch community already. > > On Wed, Apr 3, 2019 at 8:10 PM Ches

Re: [DISCUSS] Drop Elasticssearch 1 connector

2019-04-09 Thread Tzu-Li (Gordon) Tai
+1 to drop it. Elasticsearch 1.x is already 5 years old, and is already highly discouraged to be used by the Elasticsearch community already. On Wed, Apr 3, 2019 at 8:10 PM Chesnay Schepler wrote: > Hello everyone, > > I'm proposing to remove the connector for elasticsearch 1. > > The connector

Flink contributor permission application

2019-04-09 Thread 乐夏
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is xiale. -- 夏乐 | Central South University Phone: 15810044060

Re: [DISCUSS] A more restrictive JIRA workflow

2019-04-09 Thread Robert Metzger
I'm +1 on option 1. On Tue, Apr 9, 2019 at 1:58 AM Timo Walther wrote: > Hi everyone, > > I'd like to bring up this discussion thread again. In summary, I think > we all agreed on improving the JIRA workflow to move design/consensus > discussions from PRs to the issues first, before implementing

[jira] [Created] (FLINK-12150) Flink on mesos failed to created TaskManager while cache directory is gone

2019-04-09 Thread JackHe (JIRA)
JackHe created FLINK-12150: -- Summary: Flink on mesos failed to created TaskManager while cache directory is gone Key: FLINK-12150 URL: https://issues.apache.org/jira/browse/FLINK-12150 Project: Flink

Re: [RESULT] [VOTE] Release 1.8.0, release candidate #5

2019-04-09 Thread jincheng sun
Very happy to see flink1.8 can be released! Thank you very much for your efforts. @Aljoscha Krettek ! Because I just ran all the tests, so sorry for the late vote! Although the vote is over, I still share the results of my inspection. :) The check for new changes(RC4 -> RC5): 1). Run Kafka09I

Support for ProtoBuf data format in StreamingFileSink

2019-04-09 Thread Kailash Dayanand
Hello, I am looking to contribute a ProtoParquetWriter support which can be used in Bulk format for the StreamingFileSink api. There has been earlier discussions on this in the user mailing list: https://goo.gl/ya2StL and thought it would be a good addition to have. For implementation, looking at

Re: Support for ProtoBuf data format in StreamingFileSink

2019-04-09 Thread Kailash Dayanand
cc'ing few folks who are interested in this discussion. On Tue, Apr 9, 2019 at 11:35 AM Kailash Dayanand wrote: > Hello, > > I am looking to contribute a ProtoParquetWriter support which can be used > in Bulk format for the StreamingFileSink api. There has been earlier > discussions on this in t

[jira] [Created] (FLINK-12149) Support Proto for Streaming File Sink

2019-04-09 Thread Kailash Hassan Dayanand (JIRA)
Kailash Hassan Dayanand created FLINK-12149: --- Summary: Support Proto for Streaming File Sink Key: FLINK-12149 URL: https://issues.apache.org/jira/browse/FLINK-12149 Project: Flink

Re: [DISCUSS] Apache Flink at Season of Docs

2019-04-09 Thread Fabian Hueske
Hi Aizhamal, hi everyone, Thanks for sharing this opportunity with our community! I can think of a few projects that could be done as part of GSoD. 1) Flink's user documentation is (IMO) fairly extensive and mostly complete, but its structure could be improved in some areas (event-time, state man

[jira] [Created] (FLINK-12148) Give precedence to specified local jar when same mainClass is included in both lib and specified jar

2019-04-09 Thread leesf (JIRA)
leesf created FLINK-12148: - Summary: Give precedence to specified local jar when same mainClass is included in both lib and specified jar Key: FLINK-12148 URL: https://issues.apache.org/jira/browse/FLINK-12148

[jira] [Created] (FLINK-12147) Error for monitor kafka metrics when Use influxDB metric plugins

2019-04-09 Thread ouyangwulin (JIRA)
ouyangwulin created FLINK-12147: --- Summary: Error for monitor kafka metrics when Use influxDB metric plugins Key: FLINK-12147 URL: https://issues.apache.org/jira/browse/FLINK-12147 Project: Flink

[jira] [Created] (FLINK-12146) Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService

2019-04-09 Thread zhijiang (JIRA)
zhijiang created FLINK-12146: Summary: Remove unregister task from NetworkEnvironment to simplify the interface of ShuffleService Key: FLINK-12146 URL: https://issues.apache.org/jira/browse/FLINK-12146 Pr

[jira] [Created] (FLINK-12145) Host config in flink-web is incorrect

2019-04-09 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12145: -- Summary: Host config in flink-web is incorrect Key: FLINK-12145 URL: https://issues.apache.org/jira/browse/FLINK-12145 Project: Flink Issue Type: Bug Reporte

[jira] [Created] (FLINK-12144) Option to prefer checkpoints on recovery

2019-04-09 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-12144: -- Summary: Option to prefer checkpoints on recovery Key: FLINK-12144 URL: https://issues.apache.org/jira/browse/FLINK-12144 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-12143) Mechanism to ship plugin jars in the cluster

2019-04-09 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-12143: -- Summary: Mechanism to ship plugin jars in the cluster Key: FLINK-12143 URL: https://issues.apache.org/jira/browse/FLINK-12143 Project: Flink Issue Type:

[jira] [Created] (FLINK-12142) Add beforeSnapshot method to StreamOperator interface

2019-04-09 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-12142: -- Summary: Add beforeSnapshot method to StreamOperator interface Key: FLINK-12142 URL: https://issues.apache.org/jira/browse/FLINK-12142 Project: Flink Issue Type:

[jira] [Created] (FLINK-12141) Allow @TypeInfo annotation on POJO field declarations

2019-04-09 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-12141: -- Summary: Allow @TypeInfo annotation on POJO field declarations Key: FLINK-12141 URL: https://issues.apache.org/jira/browse/FLINK-12141 Project: Flink Issue Type:

[jira] [Created] (FLINK-12140) Support queries like "select a, b, c, e from T1, T2 where T1.a = T2.d" run in batch mode

2019-04-09 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12140: Summary: Support queries like "select a, b, c, e from T1, T2 where T1.a = T2.d" run in batch mode Key: FLINK-12140 URL: https://issues.apache.org/jira/browse/FLINK-12140

[RESULT] [VOTE] Release 1.8.0, release candidate #5

2019-04-09 Thread Aljoscha Krettek
I'm happy to announce that we have unanimously approved this release. There are 5 approving votes, 4 of which are binding: * Rong * Chesnay * Thomas * Gordon * Aljoscha (I’m hereby +1’ing) There are no disapproving votes. Thanks everyone! > On 9. Apr 2019, at 10:22, Aljoscha Krettek wrote:

Re: [VOTE] Release 1.8.0, release candidate #5

2019-04-09 Thread Aljoscha Krettek
Thanks everyone for checking the release and voting! I’ll tally the results in a separate email. > On 8. Apr 2019, at 10:04, Aljoscha Krettek wrote: > > @Thomas There is a note about this in the documentation release notes: > https://github.com/apache/flink/blob/5d46437fee92a6e1ec8c0653849a6b2

[jira] [Created] (FLINK-12139) Flink on mesos - Parameterize disk space needed.

2019-04-09 Thread Juan (JIRA)
Juan created FLINK-12139: Summary: Flink on mesos - Parameterize disk space needed. Key: FLINK-12139 URL: https://issues.apache.org/jira/browse/FLINK-12139 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12138) Limit input split count of each source task for better failover experience

2019-04-09 Thread Zhu Zhu (JIRA)
Zhu Zhu created FLINK-12138: --- Summary: Limit input split count of each source task for better failover experience Key: FLINK-12138 URL: https://issues.apache.org/jira/browse/FLINK-12138 Project: Flink

Re: [DISCUSS] A more restrictive JIRA workflow

2019-04-09 Thread Timo Walther
Hi everyone, I'd like to bring up this discussion thread again. In summary, I think we all agreed on improving the JIRA workflow to move design/consensus discussions from PRs to the issues first, before implementing them. Two options have been proposed: 1. Only committers can assign people to

[jira] [Created] (FLINK-12137) Add more proper explanation on flink streaming connectors

2019-04-09 Thread JoongkeunYang (JIRA)
JoongkeunYang created FLINK-12137: - Summary: Add more proper explanation on flink streaming connectors Key: FLINK-12137 URL: https://issues.apache.org/jira/browse/FLINK-12137 Project: Flink

Re: [DISCUSS] Drop Elasticssearch 1 connector

2019-04-09 Thread vino yang
+1 to drop it. Stephan Ewen 于2019年4月6日周六 上午6:51写道: > +1 to drop it > > Previously released versions are still available and compatible with newer > Flink versions anyways. > > On Fri, Apr 5, 2019 at 2:12 PM Bowen Li wrote: > > > +1 for dropping elasticsearch 1 connector. > > > > On Wed, Apr 3,

[jira] [Created] (FLINK-12136) Increase parallelism of tasks with large input data size

2019-04-09 Thread BoWang (JIRA)
BoWang created FLINK-12136: -- Summary: Increase parallelism of tasks with large input data size Key: FLINK-12136 URL: https://issues.apache.org/jira/browse/FLINK-12136 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-12135) Decrease parallelism of tasks with too small input data size

2019-04-09 Thread BoWang (JIRA)
BoWang created FLINK-12135: -- Summary: Decrease parallelism of tasks with too small input data size Key: FLINK-12135 URL: https://issues.apache.org/jira/browse/FLINK-12135 Project: Flink Issue Type:

[jira] [Created] (FLINK-12134) Decrease parallelism of tasks with too small input data size

2019-04-09 Thread BoWang (JIRA)
BoWang created FLINK-12134: -- Summary: Decrease parallelism of tasks with too small input data size Key: FLINK-12134 URL: https://issues.apache.org/jira/browse/FLINK-12134 Project: Flink Issue Type:

Re: [Discuss] Semantics of event time for state TTL

2019-04-09 Thread Aljoscha Krettek
I think so, I just wanted to bring it up again because the question was raised. > On 8. Apr 2019, at 22:56, Elias Levy wrote: > > Hasn't this been always the end goal? It's certainly what we have been > waiting on for job with very large TTLed state. Beyond timer storage, > timer processing to