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

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:

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

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

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

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

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

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

Akka dissassociated

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.

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

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

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

Tzu-Li (Gordon) Tai created FLINK-7195: -- Summary: FlinkKafkaConsumer should not respect fetched partitions to filter restored partition states Key: FLINK-7195 URL:

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

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

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

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

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

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

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

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

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-7190) Activate checkstyle flink-java/*

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

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:

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

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:

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

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:

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

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:

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

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:

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

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:

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

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