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

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

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

--> 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

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

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

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

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

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-9209) Several handlers do not properly handle unknown ids

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

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

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

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

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

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

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:

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

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:

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

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

Re: [Discuss] FLINK-8533 MasterTriggerRestoreHook state initialization

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

Re: Kinesis getRecords read timeout and retry

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

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

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:

RE: understanding flink's codes

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

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

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