[jira] [Commented] (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:comment-tabpanel=15020572#comment-15020572 ] Robert Metzger commented on FLINK-3038: --- This plugin could do the job:

[jira] [Commented] (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:comment-tabpanel=15020585#comment-15020585 ] Robert Metzger commented on FLINK-3038: --- I started working on this but there are too many modules

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

2015-11-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-2660. --- Resolution: Fixed This has been resolved some time ago. > Yarn Tests fail with Hadoop 2.3.0

[jira] [Assigned] (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 reassigned FLINK-3038: - Assignee: Robert Metzger > Add maven plugin to ensure our modules define all used

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

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

[jira] [Assigned] (FLINK-2996) Add config entry to define BlobServer port

2015-11-23 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-2996: - Assignee: Robert Metzger > Add config entry to define BlobServer port >

[jira] [Created] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API

2015-11-22 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3058: - Summary: Add Kafka consumer for new 0.9.0.0 Kafka API Key: FLINK-3058 URL: https://issues.apache.org/jira/browse/FLINK-3058 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-3058) Add Kafka consumer for new 0.9.0.0 Kafka API

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023971#comment-15023971 ] Robert Metzger commented on FLINK-3058: --- Kafka 0.9.0.0 has been released:

[jira] [Commented] (FLINK-3066) Kafka source fails on leader change

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024043#comment-15024043 ] Robert Metzger commented on FLINK-3066: --- Hi Gyula, this behavior has been implemented like this by

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

2015-11-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3061: - Summary: Kafka Consumer is not failing if broker is not available Key: FLINK-3061 URL: https://issues.apache.org/jira/browse/FLINK-3061 Project: Flink

[jira] [Created] (FLINK-3062) Kafka Producer is not failing if broker is not available/no partitions available

2015-11-23 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3062: - Summary: Kafka Producer is not failing if broker is not available/no partitions available Key: FLINK-3062 URL: https://issues.apache.org/jira/browse/FLINK-3062

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024155#comment-15024155 ] Robert Metzger commented on FLINK-3054: --- There is some nonsensical stuff going on with the Kafka

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024086#comment-15024086 ] Robert Metzger commented on FLINK-3067: --- I'll check if the fix from Stephan is really setting the

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024180#comment-15024180 ] Robert Metzger commented on FLINK-3067: --- With the dependency management, it seems that this affects

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3067: -- Component/s: Kafka Connector > Kafka source fails during checkpoint notifications with NPE >

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024131#comment-15024131 ] Robert Metzger commented on FLINK-3067: --- If I'm not mistaken, it seems that we are still using the

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15024185#comment-15024185 ] Robert Metzger commented on FLINK-3067: --- If this approach doesn't fix it, we can also think about

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3067: - Assignee: Robert Metzger > Kafka source fails during checkpoint notifications with NPE >

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

2015-11-24 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3067: -- Affects Version/s: 0.10.0 > Kafka source fails during checkpoint notifications with NPE >

[jira] [Resolved] (FLINK-2996) Add config entry to define BlobServer port

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

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

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

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

2015-11-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3073: - Summary: Activate streaming mode by default Key: FLINK-3073 URL: https://issues.apache.org/jira/browse/FLINK-3073 Project: Flink Issue Type: Improvement

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

2015-11-24 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3074: - Summary: Make ApplicationMaster/JobManager akka port configurable Key: FLINK-3074 URL: https://issues.apache.org/jira/browse/FLINK-3074 Project: Flink

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

2015-11-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013753#comment-15013753 ] Robert Metzger commented on FLINK-2732: --- Mh, what you are saying sounds good. Maybe

[jira] [Commented] (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:comment-tabpanel=15013940#comment-15013940 ] Robert Metzger commented on FLINK-3032: --- Merged on master:

[jira] [Commented] (FLINK-2646) Rich functions should provide a method "closeAfterFailure()"

2015-11-19 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15013528#comment-15013528 ] Robert Metzger commented on FLINK-2646: --- Big +1 for this feature! > Rich functions should provide a

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

2015-11-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3056: - Summary: Show bytes sent/received as MBs/GB and so on in web interface Key: FLINK-3056 URL: https://issues.apache.org/jira/browse/FLINK-3056 Project: Flink

[jira] [Commented] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given

2016-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15093538#comment-15093538 ] Robert Metzger commented on FLINK-937: -- Its not solved, but I would like to close it as Wontfix. >

[jira] [Closed] (FLINK-937) Change the YARN Client to allocate all cluster resources, if no argument given

2016-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-937. Resolution: Won't Fix > Change the YARN Client to allocate all cluster resources, if no argument

[jira] [Assigned] (FLINK-1712) Restructure Maven Projects

2016-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-1712: - Assignee: Robert Metzger > Restructure Maven Projects > -- > >

[jira] [Updated] (FLINK-1712) Restructure Maven Projects

2016-01-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-1712: -- Description: Project consolidation The new structure could be flink-core flink-java

[jira] [Created] (FLINK-3220) Flink does not start on Hortonworks Sandbox 2.3.2 due to missing class

2016-01-12 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3220: - Summary: Flink does not start on Hortonworks Sandbox 2.3.2 due to missing class Key: FLINK-3220 URL: https://issues.apache.org/jira/browse/FLINK-3220 Project:

[jira] [Commented] (FLINK-4035) Bump Kafka producer in Kafka sink to Kafka 0.10.0.0

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322421#comment-15322421 ] Robert Metzger commented on FLINK-4035: --- I haven't looked into the Kafka 0.10 changes in detail. If

[jira] [Created] (FLINK-4044) Rename RabbitMQ connector to AMQP connector

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4044: - Summary: Rename RabbitMQ connector to AMQP connector Key: FLINK-4044 URL: https://issues.apache.org/jira/browse/FLINK-4044 Project: Flink Issue Type:

[jira] [Created] (FLINK-4041) Failure while asking ResourceManager for RegisterResource

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4041: - Summary: Failure while asking ResourceManager for RegisterResource Key: FLINK-4041 URL: https://issues.apache.org/jira/browse/FLINK-4041 Project: Flink

[jira] [Comment Edited] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322345#comment-15322345 ] Robert Metzger edited comment on FLINK-3763 at 6/9/16 10:52 AM: The

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322345#comment-15322345 ] Robert Metzger commented on FLINK-3763: --- The Javadoc of the close() method (we are calling) states

[jira] [Updated] (FLINK-4045) Test AMQP connector using Apache ActiveMQ emebdded broker

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4045: -- Summary: Test AMQP connector using Apache ActiveMQ emebdded broker (was: Test AMQP connector

[jira] [Created] (FLINK-4045) Test AMQP connector using Apache ActiveMQ

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4045: - Summary: Test AMQP connector using Apache ActiveMQ Key: FLINK-4045 URL: https://issues.apache.org/jira/browse/FLINK-4045 Project: Flink Issue Type:

[jira] [Created] (FLINK-4043) Generalize RabbitMQ connector into AMQP connector

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4043: - Summary: Generalize RabbitMQ connector into AMQP connector Key: FLINK-4043 URL: https://issues.apache.org/jira/browse/FLINK-4043 Project: Flink Issue

[jira] [Resolved] (FLINK-3854) Support Avro key-value rolling sink writer

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3854. --- Resolution: Fixed Assignee: Igor Berman Fix Version/s: 1.1.0 Resolved in

[jira] [Created] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4037: - Summary: Introduce ArchivedExecutionGraph without any user classes Key: FLINK-4037 URL: https://issues.apache.org/jira/browse/FLINK-4037 Project: Flink

[jira] [Commented] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322456#comment-15322456 ] Robert Metzger commented on FLINK-4034: --- Hi, thank you for opening this issue. We rely on the

[jira] [Updated] (FLINK-4034) Dependency convergence on com.101tec:zkclient and com.esotericsoftware.kryo:kryo

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4034: -- Component/s: Build System > Dependency convergence on com.101tec:zkclient and >

[jira] [Created] (FLINK-4049) Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4049: - Summary: Mark RichInputFormat.openInputFormat and closeInputFormat as @PublicEvolving Key: FLINK-4049 URL: https://issues.apache.org/jira/browse/FLINK-4049

[jira] [Created] (FLINK-4048) Remove Hadoop dependencies from ExecutionEnvironment

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4048: - Summary: Remove Hadoop dependencies from ExecutionEnvironment Key: FLINK-4048 URL: https://issues.apache.org/jira/browse/FLINK-4048 Project: Flink Issue

[jira] [Created] (FLINK-4051) RabbitMQ Source might not react to cancel signal

2016-06-09 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4051: - Summary: RabbitMQ Source might not react to cancel signal Key: FLINK-4051 URL: https://issues.apache.org/jira/browse/FLINK-4051 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322767#comment-15322767 ] Robert Metzger commented on FLINK-3763: --- Good point. I'll open a new JIRA for the issue. > RabbitMQ

[jira] [Resolved] (FLINK-4011) Unable to access completed job in web frontend

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

[jira] [Commented] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue

2016-06-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316384#comment-15316384 ] Robert Metzger commented on FLINK-4025: --- I guess this issue is subsumed by / duplicated by

[jira] [Comment Edited] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue

2016-06-06 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15316384#comment-15316384 ] Robert Metzger edited comment on FLINK-4025 at 6/6/16 11:51 AM: I guess

[jira] [Commented] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

2016-06-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15318631#comment-15318631 ] Robert Metzger commented on FLINK-3530: --- I have a similar failure like this:

[jira] [Assigned] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

2016-06-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3530: - Assignee: Robert Metzger > Kafka09ITCase.testBigRecordJob fails on Travis >

[jira] [Commented] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue

2016-06-07 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15318978#comment-15318978 ] Robert Metzger commented on FLINK-4025: --- I understand. I'll merge your change first and then the

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324145#comment-15324145 ] Robert Metzger commented on FLINK-3763: --- Stephan raised a good point in FLINK-4051. The

[jira] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal

2016-06-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15324146#comment-15324146 ] Robert Metzger commented on FLINK-4051: --- I'll ask the user again for detailed logs. > RabbitMQ

[jira] [Updated] (FLINK-3839) Support wildcards in classpath parameters

2016-06-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3839: -- Assignee: Robert Thorman > Support wildcards in classpath parameters >

[jira] [Commented] (FLINK-3839) Support wildcards in classpath parameters

2016-06-10 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15325203#comment-15325203 ] Robert Metzger commented on FLINK-3839: --- Hi Robert, the contribution guide is a good start. I gave

[jira] [Resolved] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

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

[jira] [Resolved] (FLINK-3530) Kafka09ITCase.testBigRecordJob fails on Travis

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3530. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in Flink 1.1.0

[jira] [Commented] (FLINK-3990) ZooKeeperLeaderElectionTest kills the JVM

2016-06-09 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15322562#comment-15322562 ] Robert Metzger commented on FLINK-3990: --- The linked logs contain a different failure. Maybe you

[jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes

2016-06-03 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314026#comment-15314026 ] Robert Metzger commented on FLINK-4015: --- Hi Sebastian, do you have set the number of retires set to

[jira] [Commented] (FLINK-1673) Colocate Flink Kafka consumer

2016-05-25 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15300236#comment-15300236 ] Robert Metzger commented on FLINK-1673: --- I can not remember any user asking for this feature. I

[jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

2016-05-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305211#comment-15305211 ] Robert Metzger commented on FLINK-3704: --- Another instance:

[jira] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase

2016-05-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305212#comment-15305212 ] Robert Metzger commented on FLINK-3212: --- Another case:

[jira] [Updated] (FLINK-3985) A metric with the name * was already registered

2016-05-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3985: -- Labels: test-stability (was: ) > A metric with the name * was already registered >

[jira] [Created] (FLINK-3985) A metric with the name * was already registered

2016-05-28 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3985: - Summary: A metric with the name * was already registered Key: FLINK-3985 URL: https://issues.apache.org/jira/browse/FLINK-3985 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3985) A metric with the name * was already registered

2016-05-28 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15305214#comment-15305214 ] Robert Metzger commented on FLINK-3985: --- The same issue in this build:

[jira] [Closed] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-4065. - Resolution: Invalid > Unstable Kafka09ITCase.testMultipleSourcesOnePartition test >

[jira] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327604#comment-15327604 ] Robert Metzger commented on FLINK-4051: --- On the other hand, the Javadoc of take() states that the

[jira] [Commented] (FLINK-4065) Unstable Kafka09ITCase.testMultipleSourcesOnePartition test

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327572#comment-15327572 ] Robert Metzger commented on FLINK-4065: --- 4 days ago, I improved the Kafka tests stability a bit

[jira] [Commented] (FLINK-4066) RabbitMQ source, customize queue arguments

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327585#comment-15327585 ] Robert Metzger commented on FLINK-4066: --- I'm closing this JIRA as invalid. The requested feature has

[jira] [Updated] (FLINK-4066) RabbitMQ source, customize queue arguments

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4066: -- Fix Version/s: 1.1.0 > RabbitMQ source, customize queue arguments >

[jira] [Resolved] (FLINK-4066) RabbitMQ source, customize queue arguments

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4066. --- Resolution: Duplicate > RabbitMQ source, customize queue arguments >

[jira] [Commented] (FLINK-4051) RabbitMQ Source might not react to cancel signal

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327788#comment-15327788 ] Robert Metzger commented on FLINK-4051: --- Great, Thank you! > RabbitMQ Source might not react to

[jira] [Commented] (FLINK-4050) FlinkKafkaProducer API Refactor

2016-06-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329195#comment-15329195 ] Robert Metzger commented on FLINK-4050: --- Hi Elias, thank you for opening this JIRA. I agree with you

[jira] [Commented] (FLINK-3297) Streaming connector for ZeroMQ

2016-06-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329269#comment-15329269 ] Robert Metzger commented on FLINK-3297: --- LGPL is still an issue for us:

[jira] [Commented] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes

2016-06-14 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15329250#comment-15329250 ] Robert Metzger commented on FLINK-4015: --- I don't think we can reliably guarantee that there are no

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-06-13 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15327589#comment-15327589 ] Robert Metzger commented on FLINK-3763: --- Okay. I'll investigate this issue and then decide how to

[jira] [Resolved] (FLINK-3452) Procuring more Travis CI build capacity for Flink

2016-05-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3452. --- Resolution: Fixed I'm closing this issue. Infra has addressed it with Travis. > Procuring

[jira] [Commented] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2016-05-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306687#comment-15306687 ] Robert Metzger commented on FLINK-3991: --- I think we should review all deprecated configuration keys

[jira] [Commented] (FLINK-3763) RabbitMQ Source/Sink standardize connection parameters

2016-05-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306702#comment-15306702 ] Robert Metzger commented on FLINK-3763: --- Hi [~ArnaudL] and [~robatts], Without being an RabbitMQ

[jira] [Commented] (FLINK-3989) Add guide to write a custom streaming connector in DataStream API documentation

2016-05-30 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15306605#comment-15306605 ] Robert Metzger commented on FLINK-3989: --- Big +1! > Add guide to write a custom streaming connector

[jira] [Created] (FLINK-3991) Remove deprecated configuration keys from ConfigConstants

2016-05-30 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3991: - Summary: Remove deprecated configuration keys from ConfigConstants Key: FLINK-3991 URL: https://issues.apache.org/jira/browse/FLINK-3991 Project: Flink

[jira] [Commented] (FLINK-3190) Retry rate limits for DataStream API

2016-05-26 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15302566#comment-15302566 ] Robert Metzger commented on FLINK-3190: --- [~packet], since you've requested this feature, would you

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

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

[jira] [Created] (FLINK-3983) Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration

2016-05-27 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3983: - Summary: Allow users to set any (relevant) configuration parameter of the KinesisProducerConfiguration Key: FLINK-3983 URL: https://issues.apache.org/jira/browse/FLINK-3983

[jira] [Comment Edited] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

2016-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15304731#comment-15304731 ] Robert Metzger edited comment on FLINK-3923 at 5/27/16 8:38 PM: This has

[jira] [Resolved] (FLINK-3923) Unify configuration conventions of the Kinesis producer to the same as the consumer

2016-05-27 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3923. --- Resolution: Fixed Fix Version/s: 1.1.0 This has been resolved in

[jira] [Created] (FLINK-4011) Unable to access completed job in web frontend

2016-06-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4011: - Summary: Unable to access completed job in web frontend Key: FLINK-4011 URL: https://issues.apache.org/jira/browse/FLINK-4011 Project: Flink Issue Type:

[jira] [Created] (FLINK-4004) Do not pass custom flink kafka connector properties to Kafka to avoid warnings

2016-06-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4004: - Summary: Do not pass custom flink kafka connector properties to Kafka to avoid warnings Key: FLINK-4004 URL: https://issues.apache.org/jira/browse/FLINK-4004

[jira] [Updated] (FLINK-2672) Add partitioned output format to HDFS RollingSink

2016-06-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2672: -- Component/s: filesystem-connector > Add partitioned output format to HDFS RollingSink >

[jira] [Updated] (FLINK-3854) Support Avro key-value rolling sink writer

2016-06-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3854: -- Component/s: (was: esystem-connector) filesystem-connector > Support Avro

[jira] [Created] (FLINK-4001) Add event time support to filesystem connector

2016-06-01 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4001: - Summary: Add event time support to filesystem connector Key: FLINK-4001 URL: https://issues.apache.org/jira/browse/FLINK-4001 Project: Flink Issue Type:

[jira] [Commented] (FLINK-3758) Add possibility to register accumulators in custom triggers

2016-06-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15309998#comment-15309998 ] Robert Metzger commented on FLINK-3758: --- I think metrics and accumulators are going to co-exist.

[jira] [Updated] (FLINK-2706) Add support for streaming RollingFileSink to truncate / append on UNIX file systems

2016-06-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2706: -- Component/s: filesystem-connector > Add support for streaming RollingFileSink to truncate /

[jira] [Updated] (FLINK-3854) Support Avro key-value rolling sink writer

2016-06-01 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3854: -- Component/s: esystem-connector > Support Avro key-value rolling sink writer >

[jira] [Updated] (FLINK-3311) Add a connector for streaming data into Cassandra

2016-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3311: -- Component/s: Cassandra Connector > Add a connector for streaming data into Cassandra >

[jira] [Updated] (FLINK-3332) Provide an exactly-once Cassandra connector

2016-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3332: -- Component/s: Cassandra Connector > Provide an exactly-once Cassandra connector >

[jira] [Updated] (FLINK-4091) flink-connector-cassandra has conflicting guava version

2016-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4091: -- Component/s: Cassandra Connector > flink-connector-cassandra has conflicting guava version >

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