[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206017#comment-16206017 ] Till Rohrmann commented on FLINK-7844: -- Hi [~zhenzhongxu], thanks for the feedback.

[jira] [Assigned] (FLINK-7851) Improve scheduling balance in case of fewer sub tasks than input operator

[ https://issues.apache.org/jira/browse/FLINK-7851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7851: Assignee: Till Rohrmann > Improve scheduling balance in case of fewer sub tasks than input

[jira] [Comment Edited] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206017#comment-16206017 ] Till Rohrmann edited comment on FLINK-7844 at 10/16/17 2:54 PM:

[jira] [Commented] (FLINK-7340) Taskmanager hung after temporary DNS outage

[ https://issues.apache.org/jira/browse/FLINK-7340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206053#comment-16206053 ] Till Rohrmann commented on FLINK-7340: -- Thanks for the pointer [~hadronzoo], I think

[jira] [Comment Edited] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16206017#comment-16206017 ] Till Rohrmann edited comment on FLINK-7844 at 10/16/17 3:23 PM:

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7844: - Component/s: (was: Core) State Backends, Checkpointing > Fine Grained Recover

[jira] [Updated] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7844: - Affects Version/s: 1.4.0 > Fine Grained Recovery triggers checkpoint timeout failure > ---

[jira] [Commented] (FLINK-7844) Fine Grained Recovery triggers checkpoint timeout failure

[ https://issues.apache.org/jira/browse/FLINK-7844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16207117#comment-16207117 ] Till Rohrmann commented on FLINK-7844: -- Yes it would. I actually have a small fix alm

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16207130#comment-16207130 ] Till Rohrmann commented on FLINK-7368: -- I'm not entirely sure whether it is that impo

[jira] [Comment Edited] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16207130#comment-16207130 ] Till Rohrmann edited comment on FLINK-7368 at 10/17/17 7:43 AM:

[jira] [Assigned] (FLINK-7785) DispatcherTest failure

[ https://issues.apache.org/jira/browse/FLINK-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7785: Assignee: Till Rohrmann > DispatcherTest failure > -- > >

[jira] [Created] (FLINK-7861) Suppress ActorKilledExceptions

Till Rohrmann created FLINK-7861: Summary: Suppress ActorKilledExceptions Key: FLINK-7861 URL: https://issues.apache.org/jira/browse/FLINK-7861 Project: Flink Issue Type: Improvement

[jira] [Resolved] (FLINK-7785) DispatcherTest failure

[ https://issues.apache.org/jira/browse/FLINK-7785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7785. -- Resolution: Fixed Fixed via 9772e03d725e607495f5602f716609e3e7f9b248 > DispatcherTest failure >

[jira] [Created] (FLINK-7862) Add TaskManagerDetailsHandler

Till Rohrmann created FLINK-7862: Summary: Add TaskManagerDetailsHandler Key: FLINK-7862 URL: https://issues.apache.org/jira/browse/FLINK-7862 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-7863) Make MetricFetcher work with RestfulGateway

Till Rohrmann created FLINK-7863: Summary: Make MetricFetcher work with RestfulGateway Key: FLINK-7863 URL: https://issues.apache.org/jira/browse/FLINK-7863 Project: Flink Issue Type: Sub-tas

[jira] [Commented] (FLINK-7854) Reject lateral table outer joins with predicates in SQL

[ https://issues.apache.org/jira/browse/FLINK-7854?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208964#comment-16208964 ] Till Rohrmann commented on FLINK-7854: -- Is this truly a blocker issue [~fhueske]? My

[jira] [Commented] (FLINK-7853) Reject table function outer joins with predicates in Table API

[ https://issues.apache.org/jira/browse/FLINK-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208965#comment-16208965 ] Till Rohrmann commented on FLINK-7853: -- Same here, is this truly a blocker issue? >

[jira] [Commented] (FLINK-7838) Kafka 0.11 producer exactly-once test failure

[ https://issues.apache.org/jira/browse/FLINK-7838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208966#comment-16208966 ] Till Rohrmann commented on FLINK-7838: -- Are you working on this issue [~pnowojski]? I

[jira] [Updated] (FLINK-7839) Creating Quickstart project for SNAPSHOT version fails

[ https://issues.apache.org/jira/browse/FLINK-7839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7839: - Priority: Major (was: Blocker) > Creating Quickstart project for SNAPSHOT version fails > ---

[jira] [Updated] (FLINK-7837) AggregatingFunction does not work with immutable types

[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7837: - Priority: Major (was: Blocker) > AggregatingFunction does not work with immutable types > ---

[jira] [Commented] (FLINK-7837) AggregatingFunction does not work with immutable types

[ https://issues.apache.org/jira/browse/FLINK-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208967#comment-16208967 ] Till Rohrmann commented on FLINK-7837: -- Not strictly a release blocker I would say, b

[jira] [Commented] (FLINK-7824) Put the queryable state jars in the opt folder.

[ https://issues.apache.org/jira/browse/FLINK-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208971#comment-16208971 ] Till Rohrmann commented on FLINK-7824: -- Not a release blocker. > Put the queryable s

[jira] [Updated] (FLINK-7824) Put the queryable state jars in the opt folder.

[ https://issues.apache.org/jira/browse/FLINK-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7824: - Priority: Major (was: Blocker) > Put the queryable state jars in the opt folder. > --

[jira] [Updated] (FLINK-7781) Support simple on-demand metrics aggregation

[ https://issues.apache.org/jira/browse/FLINK-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7781: - Priority: Major (was: Blocker) > Support simple on-demand metrics aggregation > -

[jira] [Commented] (FLINK-7418) Replace all uses of jackson with flink-shaded-jackson

[ https://issues.apache.org/jira/browse/FLINK-7418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208977#comment-16208977 ] Till Rohrmann commented on FLINK-7418: -- What's the state of this issue [~Zentol]? >

[jira] [Updated] (FLINK-7779) Relocate Curator

[ https://issues.apache.org/jira/browse/FLINK-7779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7779: - Priority: Critical (was: Blocker) > Relocate Curator > > > Key:

[jira] [Commented] (FLINK-7781) Support simple on-demand metrics aggregation

[ https://issues.apache.org/jira/browse/FLINK-7781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208975#comment-16208975 ] Till Rohrmann commented on FLINK-7781: -- Not a blocker I would say. > Support simple

[jira] [Updated] (FLINK-7778) Relocate ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7778: - Priority: Critical (was: Blocker) > Relocate ZooKeeper > -- > > K

[jira] [Commented] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

[ https://issues.apache.org/jira/browse/FLINK-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208982#comment-16208982 ] Till Rohrmann commented on FLINK-7755: -- Is this truly a blocker issue? I would assess

[jira] [Updated] (FLINK-7702) Javadocs link broken

[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7702: - Priority: Critical (was: Blocker) > Javadocs link broken > > >

[jira] [Commented] (FLINK-7702) Javadocs link broken

[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208985#comment-16208985 ] Till Rohrmann commented on FLINK-7702: -- Since it only affects the master, it should n

[jira] [Commented] (FLINK-7637) FlinkKinesisProducer violates at-least-once guarantees

[ https://issues.apache.org/jira/browse/FLINK-7637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208990#comment-16208990 ] Till Rohrmann commented on FLINK-7637: -- Is this issue in progress? > FlinkKinesisPro

[jira] [Commented] (FLINK-7610) xerces lib conflict

[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208996#comment-16208996 ] Till Rohrmann commented on FLINK-7610: -- Hi [~domenico.campagn...@gmail.com], we've re

[jira] [Updated] (FLINK-7610) xerces lib conflict

[ https://issues.apache.org/jira/browse/FLINK-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7610: - Priority: Critical (was: Blocker) > xerces lib conflict > --- > >

[jira] [Updated] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7608: - Priority: Major (was: Blocker) > LatencyGauge change to histogram metric > -

[jira] [Commented] (FLINK-7608) LatencyGauge change to histogram metric

[ https://issues.apache.org/jira/browse/FLINK-7608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16208999#comment-16208999 ] Till Rohrmann commented on FLINK-7608: -- I think this issue should not block the 1.4 r

[jira] [Commented] (FLINK-7548) Support watermark generation for TableSource

[ https://issues.apache.org/jira/browse/FLINK-7548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209002#comment-16209002 ] Till Rohrmann commented on FLINK-7548: -- Is this strictly a blocker for 1.4? > Suppor

[jira] [Commented] (FLINK-7420) Move all Avro code to flink-avro

[ https://issues.apache.org/jira/browse/FLINK-7420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209006#comment-16209006 ] Till Rohrmann commented on FLINK-7420: -- What's the state of the issue [~twalthr]? >

[jira] [Commented] (FLINK-7587) Flink doesn't delete empty checkpoint file's dir from s3

[ https://issues.apache.org/jira/browse/FLINK-7587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209009#comment-16209009 ] Till Rohrmann commented on FLINK-7587: -- Yes indeed. > Flink doesn't delete empty che

[jira] [Assigned] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7153: Assignee: (was: Stephan Ewen) > Eager Scheduling can't allocate source for ExecutionGra

[jira] [Commented] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209021#comment-16209021 ] Till Rohrmann commented on FLINK-7153: -- These are good ideas [~sihuazhou]. I like cou

[jira] [Updated] (FLINK-7153) Eager Scheduling can't allocate source for ExecutionGraph correctly

[ https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7153: - Priority: Critical (was: Blocker) > Eager Scheduling can't allocate source for ExecutionGraph cor

[jira] [Updated] (FLINK-7866) Weigh list of preferred locations for scheduling

[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7866: - Description: [~sihuazhou] proposed to not only use the list of preferred locations to decide wher

[jira] [Created] (FLINK-7866) Weigh list of preferred locations for scheduling

Till Rohrmann created FLINK-7866: Summary: Weigh list of preferred locations for scheduling Key: FLINK-7866 URL: https://issues.apache.org/jira/browse/FLINK-7866 Project: Flink Issue Type: Im

[jira] [Updated] (FLINK-7866) Weigh list of preferred locations for scheduling

[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7866: - Description: [~sihuazhou] proposed to not only use the list of preferred locations to decide wher

[jira] [Updated] (FLINK-7866) Weigh list of preferred locations for scheduling

[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7866: - Description: [~sihuazhou] proposed to not only use the list of preferred locations to decide wher

[jira] [Updated] (FLINK-7866) Weigh list of preferred locations for scheduling

[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7866: - Description: [~sihuazhou] proposed to not only use the list of preferred locations to decide wher

[jira] [Commented] (FLINK-7100) TaskManager metrics are registered twice

[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209035#comment-16209035 ] Till Rohrmann commented on FLINK-7100: -- What's the state of this issue? Should we try

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209038#comment-16209038 ] Till Rohrmann commented on FLINK-7067: -- [~uce] are you still working on this issue so

[jira] [Commented] (FLINK-6951) Incompatible versions of httpcomponents jars for Flink kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209048#comment-16209048 ] Till Rohrmann commented on FLINK-6951: -- Not sure whether we have this much time if th

[jira] [Updated] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-6944: - Priority: Major (was: Blocker) > Introduce DefaultTypeSerializerConfigSnapshot as a base implemen

[jira] [Commented] (FLINK-6944) Introduce DefaultTypeSerializerConfigSnapshot as a base implementation for serializer compatibility checks

[ https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209049#comment-16209049 ] Till Rohrmann commented on FLINK-6944: -- I think this is not a blocker for 1.4. > Int

[jira] [Commented] (FLINK-6697) Add batch multi-window support

[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209050#comment-16209050 ] Till Rohrmann commented on FLINK-6697: -- Is this truly a blocker for 1.4 [~fhueske]?

[jira] [Commented] (FLINK-6584) Support multiple consecutive windows in SQL

[ https://issues.apache.org/jira/browse/FLINK-6584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209052#comment-16209052 ] Till Rohrmann commented on FLINK-6584: -- Is this truly a blocker for 1.4 [~fhueske]? I

[jira] [Commented] (FLINK-6546) Fix dependencies of flink-mesos

[ https://issues.apache.org/jira/browse/FLINK-6546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209053#comment-16209053 ] Till Rohrmann commented on FLINK-6546: -- Are you working on this issue [~StephanEwen]?

[jira] [Commented] (FLINK-5823) Store Checkpoint Root Metadata in StateBackend (not in HA custom store)

[ https://issues.apache.org/jira/browse/FLINK-5823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209061#comment-16209061 ] Till Rohrmann commented on FLINK-5823: -- Is it still realistic that this will make it

[jira] [Commented] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209064#comment-16209064 ] Till Rohrmann commented on FLINK-5789: -- Is this a strict blocker for 1.4? > Make Buc

[jira] [Commented] (FLINK-5704) Deprecate FlinkKafkaConsumer constructors in favor of improvements to decoupling from Kafka offset committing

[ https://issues.apache.org/jira/browse/FLINK-5704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209065#comment-16209065 ] Till Rohrmann commented on FLINK-5704: -- Are we gonna have this improvement in 1.4? >

[jira] [Updated] (FLINK-5627) Allow job specific externalized checkpoint dir

[ https://issues.apache.org/jira/browse/FLINK-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5627: - Priority: Major (was: Blocker) > Allow job specific externalized checkpoint dir > ---

[jira] [Commented] (FLINK-5627) Allow job specific externalized checkpoint dir

[ https://issues.apache.org/jira/browse/FLINK-5627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209066#comment-16209066 ] Till Rohrmann commented on FLINK-5627: -- I unblocked 1.4 from this issue. > Allow job

[jira] [Updated] (FLINK-5372) Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints()

[ https://issues.apache.org/jira/browse/FLINK-5372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5372: - Labels: test-stability (was: ) > Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() >

[jira] [Commented] (FLINK-5015) Add Tests/ITCase for Kafka Per-Partition Watermarks

[ https://issues.apache.org/jira/browse/FLINK-5015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209078#comment-16209078 ] Till Rohrmann commented on FLINK-5015: -- [~tzulitai] are you still working on this iss

[jira] [Commented] (FLINK-4808) Allow skipping failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209082#comment-16209082 ] Till Rohrmann commented on FLINK-4808: -- Is this truly a blocker for 1.4? I would actu

[jira] [Comment Edited] (FLINK-4808) Allow skipping failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209082#comment-16209082 ] Till Rohrmann edited comment on FLINK-4808 at 10/18/17 9:42 AM:

[jira] [Updated] (FLINK-4808) Allow skipping failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4808: - Priority: Major (was: Blocker) > Allow skipping failed checkpoints >

[jira] [Updated] (FLINK-4810) Checkpoint Coordinator should fail ExecutionGraph after "n" unsuccessful checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4810: - Priority: Major (was: Blocker) > Checkpoint Coordinator should fail ExecutionGraph after "n" unsu

[jira] [Updated] (FLINK-4809) Operators should tolerate checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-4809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4809: - Priority: Major (was: Blocker) > Operators should tolerate checkpoint failures >

[jira] [Updated] (FLINK-4811) Checkpoint Overview should list failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-4811: - Priority: Major (was: Blocker) > Checkpoint Overview should list failed checkpoints > ---

[jira] [Comment Edited] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209096#comment-16209096 ] Till Rohrmann edited comment on FLINK-7368 at 10/18/17 10:01 AM: ---

[jira] [Commented] (FLINK-7368) MetricStore makes cpu spin at 100%

[ https://issues.apache.org/jira/browse/FLINK-7368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209096#comment-16209096 ] Till Rohrmann commented on FLINK-7368: -- Piotr correctly pointed out to me that copyin

[jira] [Commented] (FLINK-7778) Relocate ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209174#comment-16209174 ] Till Rohrmann commented on FLINK-7778: -- Might be a good idea to further decrease Flin

[jira] [Commented] (FLINK-7755) Null values are not correctly handled by batch inner and outer joins

[ https://issues.apache.org/jira/browse/FLINK-7755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16209183#comment-16209183 ] Till Rohrmann commented on FLINK-7755: -- But this bug is already present since Flink 1

[jira] [Created] (FLINK-7867) Start MetricQueryService on TaskManagerRunner

Till Rohrmann created FLINK-7867: Summary: Start MetricQueryService on TaskManagerRunner Key: FLINK-7867 URL: https://issues.apache.org/jira/browse/FLINK-7867 Project: Flink Issue Type: Impro

[jira] [Updated] (FLINK-5789) Make Bucketing Sink independent of Hadoop's FileSystem

[ https://issues.apache.org/jira/browse/FLINK-5789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-5789: - Priority: Major (was: Blocker) > Make Bucketing Sink independent of Hadoop's FileSystem > ---

[jira] [Created] (FLINK-7872) Set ACCESS_CONTROL_ALLOW_ORIGIN header in HandlerUtils#sendResponse

Till Rohrmann created FLINK-7872: Summary: Set ACCESS_CONTROL_ALLOW_ORIGIN header in HandlerUtils#sendResponse Key: FLINK-7872 URL: https://issues.apache.org/jira/browse/FLINK-7872 Project: Flink

[jira] [Created] (FLINK-7874) Add environment logging to cluster entrypoints

Till Rohrmann created FLINK-7874: Summary: Add environment logging to cluster entrypoints Key: FLINK-7874 URL: https://issues.apache.org/jira/browse/FLINK-7874 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-7875) StaticFileServer should not reuse the tmp dir

Till Rohrmann created FLINK-7875: Summary: StaticFileServer should not reuse the tmp dir Key: FLINK-7875 URL: https://issues.apache.org/jira/browse/FLINK-7875 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-7021) Flink Task Manager hangs on startup if one Zookeeper node is unresolvable

[ https://issues.apache.org/jira/browse/FLINK-7021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7021. -- Resolution: Fixed Fixed via 45aceb4d8d0e2f4b8af2fc04c0ff403e7fc001b6 > Flink Task Manager hangs

[jira] [Created] (FLINK-7876) Register TaskManagerMetricGroup under ResourceID instead of InstanceID

Till Rohrmann created FLINK-7876: Summary: Register TaskManagerMetricGroup under ResourceID instead of InstanceID Key: FLINK-7876 URL: https://issues.apache.org/jira/browse/FLINK-7876 Project: Flink

[jira] [Created] (FLINK-7880) flink-queryable-state-java fails with core-dump

Till Rohrmann created FLINK-7880: Summary: flink-queryable-state-java fails with core-dump Key: FLINK-7880 URL: https://issues.apache.org/jira/browse/FLINK-7880 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-7880) flink-queryable-state-java fails with core-dump

[ https://issues.apache.org/jira/browse/FLINK-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212278#comment-16212278 ] Till Rohrmann commented on FLINK-7880: -- One more: https://travis-ci.org/apache/flink/

[jira] [Commented] (FLINK-7866) Weigh list of preferred locations for scheduling

[ https://issues.apache.org/jira/browse/FLINK-7866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212318#comment-16212318 ] Till Rohrmann commented on FLINK-7866: -- I haven't worked on this [~sihuazhou]. But I

[jira] [Commented] (FLINK-7702) Javadocs link broken

[ https://issues.apache.org/jira/browse/FLINK-7702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212322#comment-16212322 ] Till Rohrmann commented on FLINK-7702: -- Arg, this is indeed very nasty. Should indeed

[jira] [Commented] (FLINK-7067) Cancel with savepoint does not restart checkpoint scheduler on failure

[ https://issues.apache.org/jira/browse/FLINK-7067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212376#comment-16212376 ] Till Rohrmann commented on FLINK-7067: -- I actually would like to go with 4) relax t

[jira] [Commented] (FLINK-7100) TaskManager metrics are registered twice

[ https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16212472#comment-16212472 ] Till Rohrmann commented on FLINK-7100: -- I think, I accidentally addressed this issue

[jira] [Closed] (FLINK-7831) Retrieve last received heartbeat from HeartbeatManager

[ https://issues.apache.org/jira/browse/FLINK-7831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7831. Resolution: Fixed Fix Version/s: 1.4.0 Added via 06b6c87a63397ba0251c0b0aba72abbc4984557d >

[jira] [Closed] (FLINK-7861) Suppress ActorKilledExceptions

[ https://issues.apache.org/jira/browse/FLINK-7861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7861. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 33497024852c521472c40040cc023526426835af >

[jira] [Closed] (FLINK-7874) Add environment logging to cluster entrypoints

[ https://issues.apache.org/jira/browse/FLINK-7874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7874. Resolution: Done Fix Version/s: 1.4.0 Added via a5801d058dc955200d726131f98a6f0f883ed4dc > A

[jira] [Closed] (FLINK-7875) StaticFileServer should not reuse the tmp dir

[ https://issues.apache.org/jira/browse/FLINK-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7875. Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 142ff78c3851e9393d9c4d5ef1c65798c3dbdd21 >

[jira] [Resolved] (FLINK-7855) Port JobVertexAccumulatorsHandler to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7855. -- Resolution: Done Fix Version/s: 1.4.0 Added via ebc3bc1f9ce9dcbd69fedc2ec79ab03d94d99cef

[jira] [Created] (FLINK-7896) Kafka011ProducerExactlyOnceITCase.testExactlyOnceRegularSink does not finish on Travis

Till Rohrmann created FLINK-7896: Summary: Kafka011ProducerExactlyOnceITCase.testExactlyOnceRegularSink does not finish on Travis Key: FLINK-7896 URL: https://issues.apache.org/jira/browse/FLINK-7896

[jira] [Closed] (FLINK-7832) SlotManager should return number of registered slots

[ https://issues.apache.org/jira/browse/FLINK-7832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-7832. Resolution: Done Added via e7a2f57eec05f47c94339e03865d09943acf5aaf > SlotManager should return num

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

[ https://issues.apache.org/jira/browse/FLINK-7196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7196. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via a1d48317964df584c66d2cc9d7f539d31fa3d713

[jira] [Resolved] (FLINK-7262) remove unused FallbackLibraryCacheManager

[ https://issues.apache.org/jira/browse/FLINK-7262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7262. -- Resolution: Fixed Fix Version/s: 1.4.0 Fixed via 6c5ecc2f4a0a6888d8c4517bbe050fb2553faf98

[jira] [Commented] (FLINK-10481) Wordcount end-to-end test in docker env unstable

[ https://issues.apache.org/jira/browse/FLINK-10481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16641036#comment-16641036 ] Till Rohrmann commented on FLINK-10481: --- Maybe we can harden the test case to chec

[jira] [Updated] (FLINK-10404) Declarative resource management

[ https://issues.apache.org/jira/browse/FLINK-10404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10404: -- Description: This is the umbrella issue to track the progress on implementing declarative res

[jira] [Created] (FLINK-10498) Decouple ExecutionGraph from JobMaster

Till Rohrmann created FLINK-10498: - Summary: Decouple ExecutionGraph from JobMaster Key: FLINK-10498 URL: https://issues.apache.org/jira/browse/FLINK-10498 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-10499) Introduce declarative resource management switch for StandaloneJobClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-10499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10499: -- Summary: Introduce declarative resource management switch for StandaloneJobClusterEntrypoint

[jira] [Created] (FLINK-10499) Introduce declarative resource management switch

Till Rohrmann created FLINK-10499: - Summary: Introduce declarative resource management switch Key: FLINK-10499 URL: https://issues.apache.org/jira/browse/FLINK-10499 Project: Flink Issue Type

[jira] [Created] (FLINK-10500) Let ExecutionGraphDriver react to fail signal

Till Rohrmann created FLINK-10500: - Summary: Let ExecutionGraphDriver react to fail signal Key: FLINK-10500 URL: https://issues.apache.org/jira/browse/FLINK-10500 Project: Flink Issue Type: S

<    4   5   6   7   8   9   10   11   12   13   >