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

2019-04-01 Thread Till Rohrmann
Thanks for reporting this problem and opening a JIRA issue. I've created a fix for the problem [1]. [1] https://github.com/apache/flink/pull/8096 Cheers, Till On Mon, Apr 1, 2019 at 12:30 AM Richard Deurwaarder wrote: > Hello @Aljoscha and @Rong, > > I've described the problem in the mailing

[jira] [Created] (FLINK-12079) Add support for generating optimized logical plan for join on batch

2019-04-01 Thread godfrey he (JIRA)
godfrey he created FLINK-12079: -- Summary: Add support for generating optimized logical plan for join on batch Key: FLINK-12079 URL: https://issues.apache.org/jira/browse/FLINK-12079 Project: Flink

[jira] [Created] (FLINK-12078) Abstract TaskEventPublisher interface for simplify NetworkEnvironment

2019-04-01 Thread zhijiang (JIRA)
zhijiang created FLINK-12078: Summary: Abstract TaskEventPublisher interface for simplify NetworkEnvironment Key: FLINK-12078 URL: https://issues.apache.org/jira/browse/FLINK-12078 Project: Flink

[jira] [Created] (FLINK-12077) Introduce HashJoinOperator and LongHashJoinGenerator to blink

2019-04-01 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12077: Summary: Introduce HashJoinOperator and LongHashJoinGenerator to blink Key: FLINK-12077 URL: https://issues.apache.org/jira/browse/FLINK-12077 Project: Flink

Re: Expose per partition Kafka lag metric in Flink Kafka connector

2019-04-01 Thread Shuyi Chen
ping to bump this topic. Can we get some more input here or on the JIRA on the agreement to resolve this issue? Thanks a lot. Shuyi On Mon, Mar 25, 2019 at 8:43 AM Shuyi Chen wrote: > Thanks a lot, Becket. I am sorry that I was out of the loop for the last > few days due to sickness. Let’s

[jira] [Created] (FLINK-12076) Add support for generating optimized logical plan for batch simple group aggregate

2019-04-01 Thread godfrey he (JIRA)
godfrey he created FLINK-12076: -- Summary: Add support for generating optimized logical plan for batch simple group aggregate Key: FLINK-12076 URL: https://issues.apache.org/jira/browse/FLINK-12076

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

2019-04-01 Thread Richard Deurwaarder
Hello @Aljoscha and @Rong, I've described the problem in the mailing list[1] and on stackoverflow[2] before. But the gist is: If there's a firewall between the yarn cluster and the machine submitting the job, we need to be able to set a fixed port (or range of ports) for REST communication with

[jira] [Created] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

2019-04-01 Thread Richard Deurwaarder (JIRA)
Richard Deurwaarder created FLINK-12075: --- Summary: Not able to submit jobs on YARN when there's a firewall Key: FLINK-12075 URL: https://issues.apache.org/jira/browse/FLINK-12075 Project: Flink