[jira] [Created] (FLINK-9216) Fix comparator violation

2018-04-18 Thread Ruidong Li (JIRA)
Ruidong Li created FLINK-9216: - Summary: Fix comparator violation Key: FLINK-9216 URL: https://issues.apache.org/jira/browse/FLINK-9216 Project: Flink Issue Type: Bug Components: Stream

[jira] [Created] (FLINK-9215) TaskManager Releasing - org.apache.flink.util.FlinkException

2018-04-18 Thread Bob Lau (JIRA)
Bob Lau created FLINK-9215: -- Summary: TaskManager Releasing - org.apache.flink.util.FlinkException Key: FLINK-9215 URL: https://issues.apache.org/jira/browse/FLINK-9215 Project: Flink Issue Type:

[jira] [Created] (FLINK-9214) YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal

2018-04-18 Thread Ted Yu (JIRA)
Ted Yu created FLINK-9214: - Summary: YarnClient should be stopped in YARNSessionCapacitySchedulerITCase#testDetachedPerJobYarnClusterInternal Key: FLINK-9214 URL: https://issues.apache.org/jira/browse/FLINK-9214

Re: Kinesis getRecords read timeout and retry

2018-04-18 Thread Thomas Weise
--> On Wed, Apr 18, 2018 at 3:47 AM, Tzu-Li (Gordon) Tai wrote: > Hi Thomas, > > I see. If exposing access for these internal classes is a must to enable > further contributions, then I would agree to do so. > I think in the future, we should also keep a closer eye on parts of the > connector co

[jira] [Created] (FLINK-9213) Revert breaking change in checkpoint detail URL

2018-04-18 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9213: --- Summary: Revert breaking change in checkpoint detail URL Key: FLINK-9213 URL: https://issues.apache.org/jira/browse/FLINK-9213 Project: Flink Issue Typ

[jira] [Created] (FLINK-9212) Port SubtasksAllAccumulatorsHandler to new REST endpoint

2018-04-18 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9212: --- Summary: Port SubtasksAllAccumulatorsHandler to new REST endpoint Key: FLINK-9212 URL: https://issues.apache.org/jira/browse/FLINK-9212 Project: Flink

[jira] [Created] (FLINK-9211) Job submission via REST/dashboard does not work on Kubernetes

2018-04-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9211: --- Summary: Job submission via REST/dashboard does not work on Kubernetes Key: FLINK-9211 URL: https://issues.apache.org/jira/browse/FLINK-9211 Project: Flink

[jira] [Created] (FLINK-9210) Call getValue() only once in gauge serialization

2018-04-18 Thread Jisu You (JIRA)
Jisu You created FLINK-9210: --- Summary: Call getValue() only once in gauge serialization Key: FLINK-9210 URL: https://issues.apache.org/jira/browse/FLINK-9210 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9209) Several handlers do not properly handle unknown ids

2018-04-18 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9209: --- Summary: Several handlers do not properly handle unknown ids Key: FLINK-9209 URL: https://issues.apache.org/jira/browse/FLINK-9209 Project: Flink Issue

[jira] [Created] (FLINK-9208) StreamNetworkThroughputBenchmarkTests not run in Maven

2018-04-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9208: -- Summary: StreamNetworkThroughputBenchmarkTests not run in Maven Key: FLINK-9208 URL: https://issues.apache.org/jira/browse/FLINK-9208 Project: Flink Issue Type:

[jira] [Created] (FLINK-9207) Client returns SUCCESS(0) return code for canceled job

2018-04-18 Thread Amit Jain (JIRA)
Amit Jain created FLINK-9207: Summary: Client returns SUCCESS(0) return code for canceled job Key: FLINK-9207 URL: https://issues.apache.org/jira/browse/FLINK-9207 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9206) CheckpointCoordinator log messages do not contain the job ID

2018-04-18 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-9206: -- Summary: CheckpointCoordinator log messages do not contain the job ID Key: FLINK-9206 URL: https://issues.apache.org/jira/browse/FLINK-9206 Project: Flink Issue

[jira] [Created] (FLINK-9205) Delete non-well-defined SinkFunctions

2018-04-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9205: --- Summary: Delete non-well-defined SinkFunctions Key: FLINK-9205 URL: https://issues.apache.org/jira/browse/FLINK-9205 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-9204) Improve visibility of records being skipped by the `DeserializationSchema` in the Kafka / Kinesis connectors

2018-04-18 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9204: -- Summary: Improve visibility of records being skipped by the `DeserializationSchema` in the Kafka / Kinesis connectors Key: FLINK-9204 URL: https://issues.apache.org/ji

[jira] [Created] (FLINK-9203) Deprecate non-well-defined SinkFunctions

2018-04-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-9203: --- Summary: Deprecate non-well-defined SinkFunctions Key: FLINK-9203 URL: https://issues.apache.org/jira/browse/FLINK-9203 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-9202) AvroSerializer should not be serializing the target Avro type class

2018-04-18 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-9202: -- Summary: AvroSerializer should not be serializing the target Avro type class Key: FLINK-9202 URL: https://issues.apache.org/jira/browse/FLINK-9202 Project

Re: [Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

2018-04-18 Thread Stephan Ewen
I see that this is an important issue. Will try to review this soon. Till and me are the only ones that worked in this, and unfortunately is out this week and the next, and I am travelling a lot, being a bit swamped with conferences. Will try to get to that asap... On Wed, Apr 18, 2018 at 12:43 A

Re: Kinesis getRecords read timeout and retry

2018-04-18 Thread Tzu-Li (Gordon) Tai
Hi Thomas, I see. If exposing access for these internal classes is a must to enable further contributions, then I would agree to do so. I think in the future, we should also keep a closer eye on parts of the connector code which is highly subject to modifications on a per-environment basis and kee

[jira] [Created] (FLINK-9201) same merge window will fire twice if watermark already pass the window for merge windows

2018-04-18 Thread yuemeng (JIRA)
yuemeng created FLINK-9201: -- Summary: same merge window will fire twice if watermark already pass the window for merge windows Key: FLINK-9201 URL: https://issues.apache.org/jira/browse/FLINK-9201 Project: F

RE: understanding flink's codes

2018-04-18 Thread Mehmet EKICI
Hi, Thanks for the suggestion but I meant a little bit more about the understanding the codes. If you have any design docs, architecture docs etc. or only do we have github ? Best, From: zhangminglei [mailto:18717838...@163.com] Sent: Wednesday, April 18, 2018 11:22 AM To: dev@flink.apache.org

understanding flink's codes

2018-04-18 Thread Mehmet EKICI
Hi All, I would like to look at flink's source code and get familiar then commit some features. Would you please redirect so that I can quickly be a committer? Regards, Mehmet

[jira] [Created] (FLINK-9200) SQL E2E test failed on travis

2018-04-18 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9200: --- Summary: SQL E2E test failed on travis Key: FLINK-9200 URL: https://issues.apache.org/jira/browse/FLINK-9200 Project: Flink Issue Type: Bug C