回复：[DISCUSS] Improve broadcast serialization

2018-07-19 Thread Zhijiang(wangzhijiang999)
Ok, that is fine. :) I will create JIRA today and submit the PR next week. Zhijiang -- 发件人：Piotr Nowojski 发送时间：2018年7月19日(星期四) 17:52 收件人：Zhijiang(wangzhijiang999) 抄　送：Nico Kruber ; dev 主　题：Re: [DISCUSS] Improve broadcast serializa

[jira] [Created] (FLINK-9901) Refactor InputStreamReader to Channels.newReader

2018-07-19 Thread zhangminglei (JIRA)
zhangminglei created FLINK-9901: --- Summary: Refactor InputStreamReader to Channels.newReader Key: FLINK-9901 URL: https://issues.apache.org/jira/browse/FLINK-9901 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-9900) Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase)

2018-07-19 Thread zhangminglei (JIRA)
zhangminglei created FLINK-9900: --- Summary: Failed to testRestoreBehaviourWithFaultyStateHandles (org.apache.flink.test.checkpointing.ZooKeeperHighAvailabilityITCase) Key: FLINK-9900 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-9899) Add more metrics to the Kinesis source connector

2018-07-19 Thread Lakshmi Rao (JIRA)
Lakshmi Rao created FLINK-9899: -- Summary: Add more metrics to the Kinesis source connector Key: FLINK-9899 URL: https://issues.apache.org/jira/browse/FLINK-9899 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-9898) Prometheus metrics reporter doesn't respect `metrics.scope`

2018-07-19 Thread Prithvi Raj (JIRA)
Prithvi Raj created FLINK-9898: -- Summary: Prometheus metrics reporter doesn't respect `metrics.scope` Key: FLINK-9898 URL: https://issues.apache.org/jira/browse/FLINK-9898 Project: Flink Issue

[jira] [Created] (FLINK-9897) Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops

2018-07-19 Thread Lakshmi Rao (JIRA)
Lakshmi Rao created FLINK-9897: -- Summary: Further enhance adaptiveReads in Kinesis Connector to read more records in the case of long running loops Key: FLINK-9897 URL: https://issues.apache.org/jira/browse/FLINK-989

[jira] [Created] (FLINK-9896) Fix flink documentation error

2018-07-19 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-9896: -- Summary: Fix flink documentation error Key: FLINK-9896 URL: https://issues.apache.org/jira/browse/FLINK-9896 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-9895) Ensure correct logging settings for NettyLeakDetectionResource

2018-07-19 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9895: --- Summary: Ensure correct logging settings for NettyLeakDetectionResource Key: FLINK-9895 URL: https://issues.apache.org/jira/browse/FLINK-9895 Project: Flink

[jira] [Created] (FLINK-9894) Potential Data Race

2018-07-19 Thread JIRA
陈梓立 created FLINK-9894: -- Summary: Potential Data Race Key: FLINK-9894 URL: https://issues.apache.org/jira/browse/FLINK-9894 Project: Flink Issue Type: Improvement Components: Local Runtime

[jira] [Created] (FLINK-9893) Cannot run Flink job in IDE when we have more than 1 taskslot

2018-07-19 Thread Aleksandr Filichkin (JIRA)
Aleksandr Filichkin created FLINK-9893: -- Summary: Cannot run Flink job in IDE when we have more than 1 taskslot Key: FLINK-9893 URL: https://issues.apache.org/jira/browse/FLINK-9893 Project: Flin

[jira] [Created] (FLINK-9892) Disable local recovery in Jepsen tests

2018-07-19 Thread Gary Yao (JIRA)
Gary Yao created FLINK-9892: --- Summary: Disable local recovery in Jepsen tests Key: FLINK-9892 URL: https://issues.apache.org/jira/browse/FLINK-9892 Project: Flink Issue Type: Bug Componen