[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717027#comment-14717027 ] Robert Metzger commented on FLINK-2585: --- if the log contains confidential

[jira] [Commented] (FLINK-2584) ASM dependency is not shaded away

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14716872#comment-14716872 ] Robert Metzger commented on FLINK-2584: --- The problem was that we upgraded the

[jira] [Commented] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717388#comment-14717388 ] Robert Metzger commented on FLINK-2585: --- [~StephanEwen]: Kafka is only logging the

[jira] [Comment Edited] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14717398#comment-14717398 ] Robert Metzger edited comment on FLINK-2585 at 8/27/15 7:54 PM:

[jira] [Resolved] (FLINK-2585) KafkaSource not working

2015-08-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2585. --- Resolution: Not A Problem KafkaSource not working ---

[jira] [Commented] (FLINK-2017) Add predefined required parameters to ParameterTool

2015-08-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14718227#comment-14718227 ] Robert Metzger commented on FLINK-2017: --- Sorry for the late reply. Should check

[jira] [Created] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2015-08-29 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2597: - Summary: Add a test for Avro-serialized Kafka messages Key: FLINK-2597 URL: https://issues.apache.org/jira/browse/FLINK-2597 Project: Flink Issue Type:

[jira] [Created] (FLINK-2598) NPE when arguments are missing for a -m yarn-cluster job

2015-08-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2598: - Summary: NPE when arguments are missing for a -m yarn-cluster job Key: FLINK-2598 URL: https://issues.apache.org/jira/browse/FLINK-2598 Project: Flink

[jira] [Updated] (FLINK-2557) Manual type information via returns fails in DataSet API

2015-08-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2557: -- Description: I changed the WordCount example as below and get an exception: Tokenizer is

[jira] [Assigned] (FLINK-2326) Mutitenancy on Yarn

2015-08-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2326: - Assignee: Robert Metzger Mutitenancy on Yarn ---

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-08-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14713546#comment-14713546 ] Robert Metzger commented on FLINK-2392: --- Potential cause for the deadlock -

[jira] [Created] (FLINK-2581) Add warning to the YARN client when using an older Hadoop version

2015-08-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2581: - Summary: Add warning to the YARN client when using an older Hadoop version Key: FLINK-2581 URL: https://issues.apache.org/jira/browse/FLINK-2581 Project: Flink

[jira] [Created] (FLINK-2601) IOManagerAsync may produce NPE during shutdown

2015-09-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2601: - Summary: IOManagerAsync may produce NPE during shutdown Key: FLINK-2601 URL: https://issues.apache.org/jira/browse/FLINK-2601 Project: Flink Issue Type:

[jira] [Updated] (FLINK-2601) IOManagerAsync may produce NPE during shutdown

2015-09-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2601: -- Description: While analyzing a failed YARN test, I detected that it failed because it found

[jira] [Comment Edited] (FLINK-2621) Add support for positional arguments to ParameterTool

2015-09-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14730709#comment-14730709 ] Robert Metzger edited comment on FLINK-2621 at 9/4/15 12:18 PM: Looks

[jira] [Commented] (FLINK-2621) Add support for positional arguments to ParameterTool

2015-09-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14730709#comment-14730709 ] Robert Metzger commented on FLINK-2621: --- Looks good. I think that the check for conditional

[jira] [Commented] (FLINK-2621) Add support for positional arguments to ParameterTool

2015-09-04 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14730723#comment-14730723 ] Robert Metzger commented on FLINK-2621: --- I wrote on the ML again. I would prefer to have support by

[jira] [Created] (FLINK-2609) Automatic type registration is only called from the batch execution environment

2015-09-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2609: - Summary: Automatic type registration is only called from the batch execution environment Key: FLINK-2609 URL: https://issues.apache.org/jira/browse/FLINK-2609

[jira] [Created] (FLINK-2629) Refactor YARN ApplicationMasterActor to use the async AM<-->RM client

2015-09-07 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2629: - Summary: Refactor YARN ApplicationMasterActor to use the async AM<-->RM client Key: FLINK-2629 URL: https://issues.apache.org/jira/browse/FLINK-2629 Project:

[jira] [Updated] (FLINK-2632) Web Client does not respect the class loader of submitted jobs

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2632: -- Priority: Critical (was: Major) > Web Client does not respect the class loader of submitted

[jira] [Created] (FLINK-2611) YARN reports failed final state for successful jobs

2015-09-03 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2611: - Summary: YARN reports failed final state for successful jobs Key: FLINK-2611 URL: https://issues.apache.org/jira/browse/FLINK-2611 Project: Flink Issue

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

2015-09-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727226#comment-14727226 ] Robert Metzger commented on FLINK-2021: --- No, I think nobody is working on this. Before changing all

[jira] [Commented] (FLINK-2021) Rework examples to use new ParameterTool

2015-09-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14727331#comment-14727331 ] Robert Metzger commented on FLINK-2021: --- Sure ;) > Rework examples to use new ParameterTool >

[jira] [Comment Edited] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14735098#comment-14735098 ] Robert Metzger edited comment on FLINK-2617 at 9/8/15 4:39 PM: --- Which

[jira] [Commented] (FLINK-2617) ConcurrentModificationException when using HCatRecordReader to access a hive table

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14735098#comment-14735098 ] Robert Metzger commented on FLINK-2617: --- Which version of HCatalog are you using? >

[jira] [Commented] (FLINK-2591) Add configuration parameter for default number of yarn containers

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14734983#comment-14734983 ] Robert Metzger commented on FLINK-2591: --- Thank you. I'll assign you to the JIRA. > Add

[jira] [Commented] (FLINK-2632) Web Client does not respect the class loader of submitted jobs

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14735000#comment-14735000 ] Robert Metzger commented on FLINK-2632: --- The wrong classloader is passed here {code} try {

[jira] [Updated] (FLINK-2591) Add configuration parameter for default number of yarn containers

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2591: -- Assignee: Will Miao > Add configuration parameter for default number of yarn containers >

[jira] [Created] (FLINK-2639) Building Flink for specific HDP versions fails

2015-09-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2639: - Summary: Building Flink for specific HDP versions fails Key: FLINK-2639 URL: https://issues.apache.org/jira/browse/FLINK-2639 Project: Flink Issue Type:

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

2015-09-08 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14735341#comment-14735341 ] Robert Metzger commented on FLINK-2600: --- We can set the surefire/failsafe settings on a per maven

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

2015-09-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14738555#comment-14738555 ] Robert Metzger commented on FLINK-2624: --- I see the problem with multiple consumers on the queue.

[jira] [Commented] (FLINK-2624) RabbitMQ source / sink should participate in checkpointing

2015-09-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14738549#comment-14738549 ] Robert Metzger commented on FLINK-2624: --- Why can't you just extend from {{RichSourceFunction}} ?

[jira] [Assigned] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2392: - Assignee: Robert Metzger > Instable test in flink-yarn-tests >

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14736410#comment-14736410 ] Robert Metzger commented on FLINK-2392: --- I've changed the shutdown behavior of the YARN mini

[jira] [Commented] (FLINK-2606) Extend StormFileSpout to handle HDFS

2015-09-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14736454#comment-14736454 ] Robert Metzger commented on FLINK-2606: --- If we are sure that Storm's HdfsSpout is properly working

[jira] [Created] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException

2015-09-10 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2656: - Summary: FlinkKafkaConsumer is failing with OutOfRangeException Key: FLINK-2656 URL: https://issues.apache.org/jira/browse/FLINK-2656 Project: Flink Issue

[jira] [Comment Edited] (FLINK-2667) Rework configuration parameters

2015-09-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743859#comment-14743859 ] Robert Metzger edited comment on FLINK-2667 at 9/14/15 5:21 PM: - For

[jira] [Commented] (FLINK-2667) Rework configuration parameters

2015-09-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14743859#comment-14743859 ] Robert Metzger commented on FLINK-2667: --- - For those changes where you change from {{*.mb} to

[jira] [Assigned] (FLINK-2660) Yarn Tests fail with Hadoop 2.3.0

2015-09-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2660: - Assignee: Robert Metzger > Yarn Tests fail with Hadoop 2.3.0 >

[jira] [Commented] (FLINK-1831) runtime.taskmanager.RegistrationTests fails spuriously

2015-09-16 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14768887#comment-14768887 ] Robert Metzger commented on FLINK-1831: --- I'm not re-opening this issue, but I saw this test failing

[jira] [Reopened] (FLINK-2639) Building Flink for specific HDP versions fails

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-2639: --- > Building Flink for specific HDP versions fails > --

[jira] [Updated] (FLINK-2639) Building Flink for specific HDP versions fails

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2639: -- Fix Version/s: 0.9.2 > Building Flink for specific HDP versions fails >

[jira] [Commented] (FLINK-2639) Building Flink for specific HDP versions fails

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14740508#comment-14740508 ] Robert Metzger commented on FLINK-2639: --- Pushed fix to "release-0.9" for 0.9.2:

[jira] [Closed] (FLINK-2639) Building Flink for specific HDP versions fails

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-2639. - Resolution: Fixed > Building Flink for specific HDP versions fails >

[jira] [Updated] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2597: -- Assignee: Vimal > Add a test for Avro-serialized Kafka messages >

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14740605#comment-14740605 ] Robert Metzger commented on FLINK-2597: --- I don't think anybody is working on this. I've assigned the

[jira] [Updated] (FLINK-2445) Add tests for HadoopOutputFormats

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2445: -- Assignee: Martin Liesenberg > Add tests for HadoopOutputFormats >

[jira] [Assigned] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2656: - Assignee: Robert Metzger > FlinkKafkaConsumer is failing with OutOfRangeException >

[jira] [Commented] (FLINK-2445) Add tests for HadoopOutputFormats

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14740609#comment-14740609 ] Robert Metzger commented on FLINK-2445: --- I gave you contributor permissions in our JIRA & assigned

[jira] [Resolved] (FLINK-2656) FlinkKafkaConsumer is failing with OutOfRangeException

2015-09-11 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2656. --- Resolution: Fixed Fix Version/s: 0.9.2 0.10 Merged to master in

[jira] [Issue Comment Deleted] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2015-09-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2597: -- Comment: was deleted (was: Hi Vimal, sorry, I didn't want to put you under pressure for

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2015-09-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14909222#comment-14909222 ] Robert Metzger commented on FLINK-2597: --- Hi Vimal, sorry, I didn't want to put you under pressure

[jira] [Resolved] (FLINK-1753) Add more tests for Kafka Connectors

2015-09-29 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-1753. --- Resolution: Fixed Yes, I'm closing the issue. > Add more tests for Kafka Connectors >

[jira] [Assigned] (FLINK-2798) Prepare new web dashboard for executing in on YARN

2015-10-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2798: - Assignee: Robert Metzger > Prepare new web dashboard for executing in on YARN >

[jira] [Created] (FLINK-2798) Prepare new web dashboard for executing in on YARN

2015-10-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2798: - Summary: Prepare new web dashboard for executing in on YARN Key: FLINK-2798 URL: https://issues.apache.org/jira/browse/FLINK-2798 Project: Flink Issue

[jira] [Updated] (FLINK-2798) Prepare new web dashboard for executing in on YARN

2015-10-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2798: -- Issue Type: Improvement (was: Bug) > Prepare new web dashboard for executing in on YARN >

[jira] [Resolved] (FLINK-2740) Create data consumer for Apache NiFi

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

[jira] [Created] (FLINK-2811) Add page with configuration overview

2015-10-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2811: - Summary: Add page with configuration overview Key: FLINK-2811 URL: https://issues.apache.org/jira/browse/FLINK-2811 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-1052) Access to stdout and log information of Taskmanagers from the web interface

2015-10-02 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-1052. - Resolution: Won't Fix > Access to stdout and log information of Taskmanagers from the web

[jira] [Resolved] (FLINK-714) Allow executing Cascading/Scalding jobs with Stratosphere

2015-09-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-714. -- Resolution: Fixed Assignee: Fabian Hueske Absolutely. Thank you for spotting this Slim.

[jira] [Created] (FLINK-2821) Change Akka configuration to allow accessing actors from different URLs

2015-10-05 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2821: - Summary: Change Akka configuration to allow accessing actors from different URLs Key: FLINK-2821 URL: https://issues.apache.org/jira/browse/FLINK-2821 Project:

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

2015-09-18 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2703: - Summary: Remove log4j classes from fat jar / document how to use Flink with logback Key: FLINK-2703 URL: https://issues.apache.org/jira/browse/FLINK-2703 Project:

[jira] [Comment Edited] (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=14904425#comment-14904425 ] Robert Metzger edited comment on FLINK-2731 at 9/23/15 12:28 PM: - Yes.

[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=14904425#comment-14904425 ] Robert Metzger commented on FLINK-2731: --- Yes. > Add JobManager log file access >

[jira] [Commented] (FLINK-2749) CliFrontendAddressConfigurationTest fails on GCE

2015-09-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14904649#comment-14904649 ] Robert Metzger commented on FLINK-2749: --- I don't understand why its only failing there and not on

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

2015-09-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14904645#comment-14904645 ] Robert Metzger commented on FLINK-2732: --- Hey Piotr, is it the first time that you are working with

[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=14904646#comment-14904646 ] Robert Metzger commented on FLINK-2731: --- have a look at this comment:

[jira] [Commented] (FLINK-2597) Add a test for Avro-serialized Kafka messages

2015-09-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14906016#comment-14906016 ] Robert Metzger commented on FLINK-2597: --- What's the status of this JIRA? Are you still working on it

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

2015-09-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14906012#comment-14906012 ] Robert Metzger commented on FLINK-2732: --- sounds good to me. Thank you for switching! > Add access

[jira] [Resolved] (FLINK-2200) Flink API with Scala 2.11 - Maven Repository

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

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14906559#comment-14906559 ] Robert Metzger commented on FLINK-2392: --- There was another failure in

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902907#comment-14902907 ] Robert Metzger commented on FLINK-2392: --- Fixed in

[jira] [Updated] (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:all-tabpanel ] Robert Metzger updated FLINK-2731: -- Assignee: Martin Liesenberg > Add JobManager log file access > -- >

[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=14904217#comment-14904217 ] Robert Metzger commented on FLINK-2731: --- Hi, I've assigned the issue to Martin. Regarding your

[jira] [Commented] (FLINK-2742) Flink Configuration URL Not Found

2015-09-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14904126#comment-14904126 ] Robert Metzger commented on FLINK-2742: --- Hi, where did you find the link to that page? > Flink

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900547#comment-14900547 ] Robert Metzger commented on FLINK-2392: --- I pushed a commit to resolve this issue:

[jira] [Commented] (FLINK-2618) ExternalSortITCase failure

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900682#comment-14900682 ] Robert Metzger commented on FLINK-2618: --- I observed another failure:

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900582#comment-14900582 ] Robert Metzger commented on FLINK-2392: --- The problem here is that the CliFrontend is not logging the

[jira] [Commented] (FLINK-2612) ZooKeeperLeaderElectionITCase failure

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900674#comment-14900674 ] Robert Metzger commented on FLINK-2612: --- Another case:

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902138#comment-14902138 ] Robert Metzger commented on FLINK-2392: --- I've addressed the issue in this commit:

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902148#comment-14902148 ] Robert Metzger commented on FLINK-2392: --- YARN test get stuck:

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902614#comment-14902614 ] Robert Metzger commented on FLINK-2392: --- Till asked me in an offline conversation whether we can

[jira] [Resolved] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2722. --- Resolution: Fixed Fix Version/s: 0.10 resolved for release-0.10.0-milestone-1 in

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902367#comment-14902367 ] Robert Metzger commented on FLINK-2392: --- I've addressed 3 valid cases that can cause the

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902365#comment-14902365 ] Robert Metzger commented on FLINK-2392: --- The problem here was that the yarn tests didn't produce

[jira] [Resolved] (FLINK-2325) PersistentKafkaSource throws ArrayIndexOutOfBoundsException if reading from a topic that is created after starting the Source

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2325. --- Resolution: Fixed Fix Version/s: 0.9.1 0.10 I just verified the

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-22 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14902372#comment-14902372 ] Robert Metzger commented on FLINK-2392: --- This fix introduced a new issue {code}

[jira] [Created] (FLINK-2733) ZooKeeperLeaderElectionTest.testZooKeeperReelection fails

2015-09-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2733: - Summary: ZooKeeperLeaderElectionTest.testZooKeeperReelection fails Key: FLINK-2733 URL: https://issues.apache.org/jira/browse/FLINK-2733 Project: Flink

[jira] [Created] (FLINK-2735) KafkaProducerITCase.testCustomPartitioning sporadically fails

2015-09-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2735: - Summary: KafkaProducerITCase.testCustomPartitioning sporadically fails Key: FLINK-2735 URL: https://issues.apache.org/jira/browse/FLINK-2735 Project: Flink

[jira] [Updated] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2722: -- Fix Version/s: 0.9.2 > Use InetAddress.getLocalHost() first when detecting TaskManager IP

[jira] [Reopened] (FLINK-2648) CombineTaskTest.testCancelCombineTaskSorting

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-2648: --- The test failed again: {code} CombineTaskTest.testCancelCombineTaskSorting:195 null {code} in

[jira] [Created] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address

2015-09-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-2722: - Summary: Use InetAddress.getLocalHost() first when detecting TaskManager IP address Key: FLINK-2722 URL: https://issues.apache.org/jira/browse/FLINK-2722 Project:

[jira] [Commented] (FLINK-2722) Use InetAddress.getLocalHost() first when detecting TaskManager IP address

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900925#comment-14900925 ] Robert Metzger commented on FLINK-2722: --- Pushed fix for 0.9.2 in

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900606#comment-14900606 ] Robert Metzger commented on FLINK-2392: --- This is another occurrence of the {{testJavaAPI}} test

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900750#comment-14900750 ] Robert Metzger commented on FLINK-2392: --- I've set the logging up for apache/flink. Just search the

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900437#comment-14900437 ] Robert Metzger commented on FLINK-2392: --- This one looks really weird. There are no obvious reasons

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900438#comment-14900438 ] Robert Metzger commented on FLINK-2392: --- Here, I don't have any logs because the run is probably

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900453#comment-14900453 ] Robert Metzger commented on FLINK-2392: --- I agree. I'll set this up soon. > Instable test in

[jira] [Commented] (FLINK-2392) Instable test in flink-yarn-tests

2015-09-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14900419#comment-14900419 ] Robert Metzger commented on FLINK-2392: --- This one failed with the following issue: The TaskManager

[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=14904258#comment-14904258 ] Robert Metzger commented on FLINK-2731: --- Ah... I'm sorry. I actually confused the JIRAs. There is a

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