[jira] [Created] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService

2017-07-14 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7201: -- Summary: ConcurrentModificationException in JobLeaderIdService Key: FLINK-7201 URL: https://issues.apache.org/jira/browse/FLINK-7201 Project: Flink Issue Type: B

[jira] [Created] (FLINK-7200) Make metrics more Datadog friendly

2017-07-14 Thread Robert Batts (JIRA)
Robert Batts created FLINK-7200: --- Summary: Make metrics more Datadog friendly Key: FLINK-7200 URL: https://issues.apache.org/jira/browse/FLINK-7200 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7199) Graph simplification does not set parallelism

2017-07-14 Thread Greg Hogan (JIRA)
Greg Hogan created FLINK-7199: - Summary: Graph simplification does not set parallelism Key: FLINK-7199 URL: https://issues.apache.org/jira/browse/FLINK-7199 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7198) Datadog Metric Reporter reports incorrect host for JobManager

2017-07-14 Thread Robert Batts (JIRA)
Robert Batts created FLINK-7198: --- Summary: Datadog Metric Reporter reports incorrect host for JobManager Key: FLINK-7198 URL: https://issues.apache.org/jira/browse/FLINK-7198 Project: Flink Is

[jira] [Created] (FLINK-7197) Missing call to GraphAlgorithmWrappingBase#canMergeConfigurationWith()

2017-07-14 Thread Ted Yu (JIRA)
Ted Yu created FLINK-7197: - Summary: Missing call to GraphAlgorithmWrappingBase#canMergeConfigurationWith() Key: FLINK-7197 URL: https://issues.apache.org/jira/browse/FLINK-7197 Project: Flink Issue

Akka dissassociated

2017-07-14 Thread Greg Hogan
Hi all, I’m having some issues with Akka running on a modest cluster where increasing the parallelism results in disassociation messages. I am running a batch job, Gelly’s TriangleListing (for simplicity) which is join-based. I have not seen this issue running AdamicAdar which is sort-based. I

[jira] [Created] (FLINK-7196) add a TTL to transient BLOB files

2017-07-14 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7196: -- Summary: add a TTL to transient BLOB files Key: FLINK-7196 URL: https://issues.apache.org/jira/browse/FLINK-7196 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-7195) FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states

2017-07-14 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-7195: -- Summary: FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states Key: FLINK-7195 URL: https://issues.apache.org/jira/browse/FLINK-

Exported metrics by Datadog/Statsd cannot be grouped due to varying metric name

2017-07-14 Thread Mustafa AKIN
In my machine, metrics from task manager are currently exported to Datadog as: "localhost.taskmanager.9fbab10326796246e65034ca260516ce.Status.JVM.GarbageColl..." However, using this metric name causes software to treat them as different metrics, and I cannout group by/aggregate across many hosts.

[jira] [Created] (FLINK-7194) Add getResultType and getAccumulatorType to AggregateFunction

2017-07-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7194: Summary: Add getResultType and getAccumulatorType to AggregateFunction Key: FLINK-7194 URL: https://issues.apache.org/jira/browse/FLINK-7194 Project: Flink

[jira] [Created] (FLINK-7193) Update all OVER window ProcessFunction implementations to use SortedQueueState

2017-07-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-7193: Summary: Update all OVER window ProcessFunction implementations to use SortedQueueState Key: FLINK-7193 URL: https://issues.apache.org/jira/browse/FLINK-7193 Project:

[jira] [Created] (FLINK-7192) Activate checkstyle flink-java/test/operator

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7192: --- Summary: Activate checkstyle flink-java/test/operator Key: FLINK-7192 URL: https://issues.apache.org/jira/browse/FLINK-7192 Project: Flink Issue Type:

[jira] [Created] (FLINK-7191) Activate checkstyle flink-java/operators/translation

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7191: --- Summary: Activate checkstyle flink-java/operators/translation Key: FLINK-7191 URL: https://issues.apache.org/jira/browse/FLINK-7191 Project: Flink Issu

[jira] [Created] (FLINK-7190) Activate checkstyle flink-java/*

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7190: --- Summary: Activate checkstyle flink-java/* Key: FLINK-7190 URL: https://issues.apache.org/jira/browse/FLINK-7190 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7189) Activate checkstyle flink-java/utils

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7189: --- Summary: Activate checkstyle flink-java/utils Key: FLINK-7189 URL: https://issues.apache.org/jira/browse/FLINK-7189 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-7187) Activate checkstyle flink-java/sca

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7187: --- Summary: Activate checkstyle flink-java/sca Key: FLINK-7187 URL: https://issues.apache.org/jira/browse/FLINK-7187 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-7188) Activate checkstyle flink-java/summarize

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7188: --- Summary: Activate checkstyle flink-java/summarize Key: FLINK-7188 URL: https://issues.apache.org/jira/browse/FLINK-7188 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-7186) Activate checkstyle flink-java/sampling

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7186: --- Summary: Activate checkstyle flink-java/sampling Key: FLINK-7186 URL: https://issues.apache.org/jira/browse/FLINK-7186 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-7185) Activate checkstyle flink-java/io

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7185: --- Summary: Activate checkstyle flink-java/io Key: FLINK-7185 URL: https://issues.apache.org/jira/browse/FLINK-7185 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7183) Activate checkstyle flink-java/aggregation

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7183: --- Summary: Activate checkstyle flink-java/aggregation Key: FLINK-7183 URL: https://issues.apache.org/jira/browse/FLINK-7183 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-7184) Activate checkstyle flink-java/hadoop

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7184: --- Summary: Activate checkstyle flink-java/hadoop Key: FLINK-7184 URL: https://issues.apache.org/jira/browse/FLINK-7184 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-7182) Activate checkstyle flink-java/functions

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7182: --- Summary: Activate checkstyle flink-java/functions Key: FLINK-7182 URL: https://issues.apache.org/jira/browse/FLINK-7182 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-7181) Activate checkstyle flink-java/operators

2017-07-14 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-7181: --- Summary: Activate checkstyle flink-java/operators Key: FLINK-7181 URL: https://issues.apache.org/jira/browse/FLINK-7181 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7180) CoGroupStream perform checkpoint failed

2017-07-14 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-7180: - Summary: CoGroupStream perform checkpoint failed Key: FLINK-7180 URL: https://issues.apache.org/jira/browse/FLINK-7180 Project: Flink Issue Type: Bug Com