[jira] [Created] (FLINK-10135) The JobManager doesn't report the cluster-level metrics

2018-08-13 Thread Joey Echeverria (JIRA)
Joey Echeverria created FLINK-10135: --- Summary: The JobManager doesn't report the cluster-level metrics Key: FLINK-10135 URL: https://issues.apache.org/jira/browse/FLINK-10135 Project: Flink

[jira] [Created] (FLINK-10134) UTF-16 support for TextInputFormat

2018-08-13 Thread David Dreyfus (JIRA)
David Dreyfus created FLINK-10134: - Summary: UTF-16 support for TextInputFormat Key: FLINK-10134 URL: https://issues.apache.org/jira/browse/FLINK-10134 Project: Flink Issue Type: Bug

Re: [Discuss] Outer join support and timestamp assignment for IntervalJoin

2018-08-13 Thread Elias Levy
As a developer, while not quite a succinct, I feel that option A in both cases is easier to read. On Mon, Aug 13, 2018 at 4:18 AM Florian Schmidt wrote: > Hello Community, > > I’ve recently been working on adding support for outer joins [1] and > timestamp assignment [2] to the IntervalJoin in t

[jira] [Created] (FLINK-10133) finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters)

2018-08-13 Thread Xiangyu Zhu (JIRA)
Xiangyu Zhu created FLINK-10133: --- Summary: finished job's jobgraph never been cleaned up in zookeeper for standalone clusters (HA mode with multiple masters) Key: FLINK-10133 URL: https://issues.apache.org/jira/brow

[jira] [Created] (FLINK-10132) Incremental cleanup of local expired state with TTL discovered in full snapshot

2018-08-13 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-10132: --- Summary: Incremental cleanup of local expired state with TTL discovered in full snapshot Key: FLINK-10132 URL: https://issues.apache.org/jira/browse/FLINK-10132

[Discuss] Outer join support and timestamp assignment for IntervalJoin

2018-08-13 Thread Florian Schmidt
Hello Community, I’ve recently been working on adding support for outer joins [1] and timestamp assignment [2] to the IntervalJoin in the DataStream API. As this is a public API and it should be simple and understandable for users I wanted to gather some feedback on some variations that I drafte

[jira] [Created] (FLINK-10131) Improve logging around ResultSubpartition

2018-08-13 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-10131: --- Summary: Improve logging around ResultSubpartition Key: FLINK-10131 URL: https://issues.apache.org/jira/browse/FLINK-10131 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-10130) How to define two hdfs name-node IPs in flink-conf.yaml file

2018-08-13 Thread Keshav Lodhi (JIRA)
Keshav Lodhi created FLINK-10130: Summary: How to define two hdfs name-node IPs in flink-conf.yaml file Key: FLINK-10130 URL: https://issues.apache.org/jira/browse/FLINK-10130 Project: Flink

Re: [Discuss] FLIP-26 - SSL Mutual Authentication

2018-08-13 Thread Stephan Ewen
FYI: The 1.6 docs reflect the setup where internal and external SSL are separately configured, and where internal SSL uses client authentication. https://ci.apache.org/projects/flink/flink-docs-release-1.6/ops/security-ssl.html On Mon, Aug 13, 2018 at 8:54 AM, Stephan Ewen wrote: > Sounds good,