[jira] [Commented] (FLINK-2731) Add JobManager log file access

2015-09-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14904271#comment-14904271 ] Robert Metzger commented on FLINK-2731: --- I agree. Can you create the sub issue and assign it to you?

[jira] [Commented] (FLINK-2823) YARN client should report a proper exception if Hadoop Env variables are not set

2015-10-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14945014#comment-14945014 ] Robert Metzger commented on FLINK-2823: --- I think {{HADOOP_HOME}} is deprecated with the Hadoop 2

[jira] [Resolved] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-10-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2703. --- Resolution: Fixed Fix Version/s: 0.10 The issue has been resolved in

[jira] [Commented] (FLINK-2703) Remove log4j classes from fat jar / document how to use Flink with logback

2015-10-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14943554#comment-14943554 ] Robert Metzger commented on FLINK-2703: --- Sorry. I forgot to close it. > Remove log4j classes from

[jira] [Resolved] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

2015-12-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2963. --- Resolution: Fixed Fix Version/s: 1.0.0 > Dependence on

[jira] [Commented] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

2015-12-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15045112#comment-15045112 ] Robert Metzger commented on FLINK-2963: --- I see. My check was only there for commons.lang, not for

[jira] [Created] (FLINK-3129) Add tooling to ensure interface stability

2015-12-07 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3129: - Summary: Add tooling to ensure interface stability Key: FLINK-3129 URL: https://issues.apache.org/jira/browse/FLINK-3129 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-2963) Dependence on SerializationUtils#deserialize() should be avoided

2015-12-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2963: - Assignee: Robert Metzger > Dependence on SerializationUtils#deserialize() should be

[jira] [Resolved] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record

2015-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3101. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved for 1.0.0 in

[jira] [Resolved] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer

2015-12-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3102. --- Resolution: Fixed Fix Version/s: 1.0.0 Resovled for 1.0 in

[jira] [Created] (FLINK-3146) Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x

2015-12-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3146: - Summary: Expose the Kafka consumer lag as a metric in the web interface for Kafka 0.8.x Key: FLINK-3146 URL: https://issues.apache.org/jira/browse/FLINK-3146

[jira] [Assigned] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record

2015-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3101: - Assignee: Robert Metzger > Flink Kafka consumer crashes with NPE when it sees deleted

[jira] [Commented] (FLINK-3101) Flink Kafka consumer crashes with NPE when it sees deleted record

2015-12-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15036259#comment-15036259 ] Robert Metzger commented on FLINK-3101: --- Thank you for the bug report, I'll look into the issue. >

[jira] [Created] (FLINK-3102) Allow reading from multiple topics with one FlinkKafkaConsumer

2015-12-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3102: - Summary: Allow reading from multiple topics with one FlinkKafkaConsumer Key: FLINK-3102 URL: https://issues.apache.org/jira/browse/FLINK-3102 Project: Flink

[jira] [Commented] (FLINK-3115) Update Elasticsearch connector to 2.X

2015-12-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15041600#comment-15041600 ] Robert Metzger commented on FLINK-3115: --- I think we need to add a second module for the updated EL

[jira] [Resolved] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager

2015-12-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2954. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/b9639eb5 >

[jira] [Commented] (FLINK-2897) Use distinct initial indices for OutputEmitter round-robin

2015-12-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044836#comment-15044836 ] Robert Metzger commented on FLINK-2897: --- I think there was one open remark with your pull request,

[jira] [Created] (FLINK-3151) YARN kills Flink TM containers due to memory overuse (outside heap/offheap)

2015-12-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3151: - Summary: YARN kills Flink TM containers due to memory overuse (outside heap/offheap) Key: FLINK-3151 URL: https://issues.apache.org/jira/browse/FLINK-3151 Project:

[jira] [Updated] (FLINK-2380) Allow to configure default FS for file inputs

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2380: -- Labels: starter (was: ) > Allow to configure default FS for file inputs >

[jira] [Commented] (FLINK-2380) Allow to configure default FS for file inputs

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15048351#comment-15048351 ] Robert Metzger commented on FLINK-2380: --- Quick note: The property is not called {{fs.default.name}}

[jira] [Assigned] (FLINK-3150) Make YARN container invocation configurable

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3150: - Assignee: Robert Metzger > Make YARN container invocation configurable >

[jira] [Created] (FLINK-3150) Make YARN container invocation configurable

2015-12-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3150: - Summary: Make YARN container invocation configurable Key: FLINK-3150 URL: https://issues.apache.org/jira/browse/FLINK-3150 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-3074) Make ApplicationMaster/JobManager akka port configurable

2015-12-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3074. --- Resolution: Fixed Fixed for 1.0 in

[jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3121: - Summary: Watermark forwarding does not work for sources not producing any data Key: FLINK-3121 URL: https://issues.apache.org/jira/browse/FLINK-3121 Project: Flink

[jira] [Created] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

2015-12-05 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3123: - Summary: Allow setting custom start-offsets for the Kafka consumer Key: FLINK-3123 URL: https://issues.apache.org/jira/browse/FLINK-3123 Project: Flink

[jira] [Commented] (FLINK-2344) Deprecate/Remove the old Pact Pair type

2015-12-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15042780#comment-15042780 ] Robert Metzger commented on FLINK-2344: --- Is this the

[jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager

2015-12-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15042787#comment-15042787 ] Robert Metzger commented on FLINK-3090: --- I agree. We have some users running Flink on Cloudera, I'm

[jira] [Commented] (FLINK-3073) Activate streaming mode by default

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15034151#comment-15034151 ] Robert Metzger commented on FLINK-3073: --- I would remove all the code for specific startup modes and

[jira] [Created] (FLINK-3095) Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable

2015-12-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3095: - Summary: Test ZooKeeperLeaderElectionTest.testZooKeeperReelectionWithReplacement unstable Key: FLINK-3095 URL: https://issues.apache.org/jira/browse/FLINK-3095

[jira] [Created] (FLINK-3096) ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints

2015-12-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3096: - Summary: ChaosMonkeyITCase fails in checkCleanRecoveryState with Unclean checkpoints Key: FLINK-3096 URL: https://issues.apache.org/jira/browse/FLINK-3096 Project:

[jira] [Comment Edited] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15034349#comment-15034349 ] Robert Metzger edited comment on FLINK-2732 at 12/1/15 6:51 PM: Hi

[jira] [Commented] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15034351#comment-15034351 ] Robert Metzger commented on FLINK-3038: --- I'm closing this issue because its not feasible to add all

[jira] [Closed] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3038. - Resolution: Won't Fix > Add maven plugin to ensure our modules define all used dependencies >

[jira] [Assigned] (FLINK-3093) Introduce annotations for interface stability

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3093: - Assignee: Robert Metzger > Introduce annotations for interface stability >

[jira] [Commented] (FLINK-2732) Add access to the TaskManagers' log file and out file in the web dashboard.

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15034349#comment-15034349 ] Robert Metzger commented on FLINK-2732: --- Hi [~mliesenberg], thank you for the summary of where you

[jira] [Created] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

2015-12-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3158: - Summary: Shading does not remove google guava from flink-dist fat jar Key: FLINK-3158 URL: https://issues.apache.org/jira/browse/FLINK-3158 Project: Flink

[jira] [Commented] (FLINK-3003) Add container allocation timeout to YARN CLI

2015-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15055746#comment-15055746 ] Robert Metzger commented on FLINK-3003: --- Gang scheduling support in YARN would be the right way to

[jira] [Commented] (FLINK-3170) Expose task manager metrics via JMX

2015-12-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15056336#comment-15056336 ] Robert Metzger commented on FLINK-3170: --- How about using the https://github.com/dropwizard/metrics

[jira] [Reopened] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-3067: --- The issue is still not resolved. Next approach: We update ZK using Apache Curator. > Kafka

[jira] [Updated] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3123: -- Assignee: (was: Robert Metzger) > Allow setting custom start-offsets for the Kafka consumer

[jira] [Resolved] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3023. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in master:

[jira] [Resolved] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3077. --- Resolution: Fixed Resolved for 1.0.0 in

[jira] [Commented] (FLINK-3168) Make checkpointing properties configurable from flink-conf.yaml

2015-12-15 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058054#comment-15058054 ] Robert Metzger commented on FLINK-3168: --- As a workaround for now, you could use the

[jira] [Commented] (FLINK-3158) Shading does not remove google guava from flink-dist fat jar

2015-12-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15050615#comment-15050615 ] Robert Metzger commented on FLINK-3158: --- There is a check in our travis build to ensure guava is not

[jira] [Resolved] (FLINK-3156) FlinkKafkaConsumer fails with NPE on notifyCheckpointComplete

2015-12-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3156. --- Resolution: Fixed Fix Version/s: 1.0.0 Fixed for 1.0 in

[jira] [Created] (FLINK-3159) YARN AM should shutdown itself after a the job for which the AM was started has finished

2015-12-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3159: - Summary: YARN AM should shutdown itself after a the job for which the AM was started has finished Key: FLINK-3159 URL: https://issues.apache.org/jira/browse/FLINK-3159

[jira] [Commented] (FLINK-3090) Create a Parcel Distribution for Cloudera Manager

2016-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081570#comment-15081570 ] Robert Metzger commented on FLINK-3090: --- There seems to be more interest in this:

[jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2016-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081011#comment-15081011 ] Robert Metzger commented on FLINK-3188: --- Thank you for providing a test case. I'll open a pull

[jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2016-01-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15081172#comment-15081172 ] Robert Metzger commented on FLINK-3188: --- I've now opened a pull request from your changes:

[jira] [Resolved] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2016-01-05 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3188. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved for 1.0.0 in

[jira] [Created] (FLINK-3204) TaskManagers are not shutting down properly on YARN

2016-01-06 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3204: - Summary: TaskManagers are not shutting down properly on YARN Key: FLINK-3204 URL: https://issues.apache.org/jira/browse/FLINK-3204 Project: Flink Issue

[jira] [Closed] (FLINK-3205) Remove the flink-staging module

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3205. - Resolution: Duplicate Fix Version/s: (was: 1.0.0) Duplicate of FLINK-1712 > Remove

[jira] [Updated] (FLINK-2833) Unstage Gelly and Module refactoring

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2833: -- Issue Type: Sub-task (was: Task) Parent: FLINK-3205 > Unstage Gelly and Module

[jira] [Updated] (FLINK-2877) Move Streaming API out of Staging

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2877: -- Issue Type: Sub-task (was: Improvement) Parent: FLINK-3205 > Move Streaming API out of

[jira] [Created] (FLINK-3205) Remove the flink-staging module

2016-01-06 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3205: - Summary: Remove the flink-staging module Key: FLINK-3205 URL: https://issues.apache.org/jira/browse/FLINK-3205 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-2877) Move Streaming API out of Staging

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2877: -- Parent Issue: FLINK-1712 (was: FLINK-3205) > Move Streaming API out of Staging >

[jira] [Updated] (FLINK-2833) Unstage Gelly and Module refactoring

2016-01-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2833: -- Parent Issue: FLINK-1712 (was: FLINK-3205) > Unstage Gelly and Module refactoring >

[jira] [Commented] (FLINK-3093) Introduce annotations for interface stability

2016-01-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15087541#comment-15087541 ] Robert Metzger commented on FLINK-3093: --- Annotations for flink-core have been merged in

[jira] [Commented] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2015-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15066567#comment-15066567 ] Robert Metzger commented on FLINK-3188: --- Thank you for providing a patch for the issue. Do you know

[jira] [Assigned] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

2015-12-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3188: - Assignee: Robert Metzger > Deletes in Kafka source should be passed on to

[jira] [Resolved] (FLINK-3067) Kafka source fails during checkpoint notifications with NPE

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3067. --- Resolution: Fixed Fix Version/s: 1.0.0 0.10.2 Merged fix for 0.10.2

[jira] [Commented] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15026934#comment-15026934 ] Robert Metzger commented on FLINK-3079: --- Cool. I didn't know this one. Kafka itself also provides a

[jira] [Resolved] (FLINK-3000) Add ShutdownHook to YARN CLI to prevent lingering sessions

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3000. --- Resolution: Fixed Fix Version/s: (was: 0.10.1) 1.0.0 Resolved

[jira] [Commented] (FLINK-2960) Communicate with JobManager through YARN proxy

2015-11-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15028477#comment-15028477 ] Robert Metzger commented on FLINK-2960: --- I'm sorry, it won't happen again. > Communicate with

[jira] [Commented] (FLINK-3055) ExecutionVertex has duplicate method getParallelSubtaskIndex and getSubTaskIndex

2015-11-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15028522#comment-15028522 ] Robert Metzger commented on FLINK-3055: --- I don't know why I added a second getter for this. Most

[jira] [Assigned] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling

2015-11-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3081: - Assignee: Robert Metzger > Kafka Periodic Offset Committer does not properly terminate

[jira] [Updated] (FLINK-3025) Flink Kafka consumer may get stuck due to Kafka/Zookeeper client bug

2015-11-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3025: -- Fix Version/s: (was: 0.10.1) > Flink Kafka consumer may get stuck due to Kafka/Zookeeper

[jira] [Updated] (FLINK-3003) Add container allocation timeout to YARN CLI

2015-11-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3003: -- Fix Version/s: (was: 0.10.1) > Add container allocation timeout to YARN CLI >

[jira] [Assigned] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2954: - Assignee: Robert Metzger > Not able to pass custom environment variables in cluster to

[jira] [Commented] (FLINK-2960) Communicate with JobManager through YARN proxy

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15027279#comment-15027279 ] Robert Metzger commented on FLINK-2960: --- I would like to avoid doing the communication with YARN

[jira] [Commented] (FLINK-2954) Not able to pass custom environment variables in cluster to processes that spawning TaskManager

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15027281#comment-15027281 ] Robert Metzger commented on FLINK-2954: --- Thank you for the report. I'll fix the issue. > Not able

[jira] [Resolved] (FLINK-2960) Communicate with JobManager through YARN proxy

2015-11-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2960. --- Resolution: Won't Fix Fix Version/s: (was: 0.10.1) (was:

[jira] [Created] (FLINK-3079) Add utility for measuring the raw read throughput from a Kafka topic

2015-11-25 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3079: - Summary: Add utility for measuring the raw read throughput from a Kafka topic Key: FLINK-3079 URL: https://issues.apache.org/jira/browse/FLINK-3079 Project: Flink

[jira] [Resolved] (FLINK-3054) Remove R (return) type variable from SerializationSchema

2015-11-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3054. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/09ea3dd0 >

[jira] [Resolved] (FLINK-3081) Kafka Periodic Offset Committer does not properly terminate on canceling

2015-11-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3081. --- Resolution: Fixed Fixed for 1.0 in

[jira] [Created] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-11-25 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3077: - Summary: Add "version" command to CliFrontend for showing the version of the installation Key: FLINK-3077 URL: https://issues.apache.org/jira/browse/FLINK-3077

[jira] [Created] (FLINK-3078) JobManager does not shutdown when checkpointed jobs are running

2015-11-25 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3078: - Summary: JobManager does not shutdown when checkpointed jobs are running Key: FLINK-3078 URL: https://issues.apache.org/jira/browse/FLINK-3078 Project: Flink

[jira] [Resolved] (FLINK-3061) Kafka Consumer is not failing if broker is not available

2015-11-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3061. --- Resolution: Fixed Resolved for master in

[jira] [Commented] (FLINK-2600) Failing ElasticsearchSinkITCase.testNodeClient test case

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15033652#comment-15033652 ] Robert Metzger commented on FLINK-2600: --- Another incident:

[jira] [Comment Edited] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15033650#comment-15033650 ] Robert Metzger edited comment on FLINK-2839 at 12/1/15 1:07 PM: I saw a

[jira] [Commented] (FLINK-2839) Failing test: OperatorStatsAccumulatorTest.testAccumulatorAllStatistics

2015-12-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15033650#comment-15033650 ] Robert Metzger commented on FLINK-2839: --- I saw a similar failure:

[jira] [Created] (FLINK-3093) Introduce annotations for interface stability

2015-12-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3093: - Summary: Introduce annotations for interface stability Key: FLINK-3093 URL: https://issues.apache.org/jira/browse/FLINK-3093 Project: Flink Issue Type:

[jira] [Commented] (FLINK-2845) TimestampITCase.testWatermarkPropagation

2015-11-18 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15010634#comment-15010634 ] Robert Metzger commented on FLINK-2845: --- The issue happened again:

[jira] [Created] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies

2015-11-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3038: - Summary: Add maven plugin to ensure our modules define all used dependencies Key: FLINK-3038 URL: https://issues.apache.org/jira/browse/FLINK-3038 Project: Flink

[jira] [Created] (FLINK-3037) Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available

2015-11-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3037: - Summary: Make the behavior of the Kafka consumer configurable if the offsets to restore from are not available Key: FLINK-3037 URL:

[jira] [Commented] (FLINK-2989) Job Cancel button doesn't work on Yarn

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009635#comment-15009635 ] Robert Metzger commented on FLINK-2989: --- [~mxm], I've assigned you to the issue. > Job Cancel

[jira] [Updated] (FLINK-2989) Job Cancel button doesn't work on Yarn

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2989: -- Assignee: Maximilian Michels > Job Cancel button doesn't work on Yarn >

[jira] [Commented] (FLINK-2925) Client shows incomplete cause of Exception

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009694#comment-15009694 ] Robert Metzger commented on FLINK-2925: --- I've also looked into this but even if the s3 exception

[jira] [Commented] (FLINK-2952) Runtimes > 24 hours are reported incorrectly in the web frontend

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009675#comment-15009675 ] Robert Metzger commented on FLINK-2952: --- Is it okay to close this issue as won't fix because we have

[jira] [Resolved] (FLINK-2858) Cannot build Flink Scala 2.11 with IntelliJ

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2858. --- Resolution: Fixed Assignee: Alexander Alexandrov The issue has been fixed in

[jira] [Commented] (FLINK-3027) Cancel button in Flink job dashboard does not work

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009641#comment-15009641 ] Robert Metzger commented on FLINK-3027: --- Okay, thank you. Then, this issue is a duplicate of

[jira] [Closed] (FLINK-3027) Cancel button in Flink job dashboard does not work

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-3027. - Resolution: Duplicate > Cancel button in Flink job dashboard does not work >

[jira] [Commented] (FLINK-2924) Create database state backend

2015-11-17 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15009682#comment-15009682 ] Robert Metzger commented on FLINK-2924: --- See PR: https://github.com/apache/flink/pull/1305 > Create

[jira] [Created] (FLINK-3045) Properly expose the key of a kafka message

2015-11-19 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3045: - Summary: Properly expose the key of a kafka message Key: FLINK-3045 URL: https://issues.apache.org/jira/browse/FLINK-3045 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled

2015-11-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2974: - Assignee: Robert Metzger > Add periodic offset commit to Kafka Consumer if checkpointing

[jira] [Created] (FLINK-3054) Remove R (return) type variable from SerializationSchema

2015-11-20 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3054: - Summary: Remove R (return) type variable from SerializationSchema Key: FLINK-3054 URL: https://issues.apache.org/jira/browse/FLINK-3054 Project: Flink

[jira] [Resolved] (FLINK-2974) Add periodic offset commit to Kafka Consumer if checkpointing is disabled

2015-11-20 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2974. --- Resolution: Fixed Fix Version/s: 0.10.1 1.0.0 Resolved for 1.0.0 in

[jira] [Resolved] (FLINK-3032) Flink does not start on Hadoop 2.7.1 (HDP), due to class conflict

2015-11-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3032. --- Resolution: Fixed Fix Version/s: 0.10.1 1.0.0 Fixed for 0.10

[jira] [Commented] (FLINK-3056) Show bytes sent/received as MBs/GB and so on in web interface

2015-11-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15020466#comment-15020466 ] Robert Metzger commented on FLINK-3056: --- I would not make this configurable. Why are you asking? I

[jira] [Updated] (FLINK-3038) Add maven plugin to ensure our modules define all used dependencies

2015-11-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3038: -- Assignee: (was: Robert Metzger) > Add maven plugin to ensure our modules define all used

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