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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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

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

[ 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

[ 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

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

[ 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

[ 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

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

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

[ 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

[ 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

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

[ 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

[ 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

[ 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

[ 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

[ 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

[ 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 >

[jira] [Created] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available

Robert Metzger created FLINK-4097: - Summary: Cassandra Sink throws NPE on closing if server is not available Key: FLINK-4097 URL: https://issues.apache.org/jira/browse/FLINK-4097 Project: Flink

[jira] [Updated] (FLINK-3964) Job submission times out with recursive.file.enumeration

[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3964: -- Component/s: DataSet API Batch Connectors and Input/Output Formats > Job

[jira] [Updated] (FLINK-3964) Job submission times out with recursive.file.enumeration

[ https://issues.apache.org/jira/browse/FLINK-3964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3964: -- Affects Version/s: 1.0.0 > Job submission times out with recursive.file.enumeration >

[jira] [Resolved] (FLINK-3752) Add Per-Kafka-Partition Watermark Generation to the docs

[ https://issues.apache.org/jira/browse/FLINK-3752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3752. --- Resolution: Fixed Resolved in http://git-wip-us.apache.org/repos/asf/flink/commit/7ec6d7b5

[jira] [Updated] (FLINK-2917) Make non-copying behaviour default for stream operator

[ https://issues.apache.org/jira/browse/FLINK-2917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2917: -- Fix Version/s: (was: 1.1.0) > Make non-copying behaviour default for stream operator >

[jira] [Updated] (FLINK-3588) Add a streaming (exactly-once) JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-3588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3588: -- Fix Version/s: (was: 1.1.0) > Add a streaming (exactly-once) JDBC connector >

[jira] [Updated] (FLINK-3588) Add a streaming (exactly-once) JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-3588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3588: -- Issue Type: New Feature (was: Improvement) > Add a streaming (exactly-once) JDBC connector >

[jira] [Updated] (FLINK-3674) Add an interface for EventTime aware User Function

[ https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3674: -- Fix Version/s: (was: 1.1.0) > Add an interface for EventTime aware User Function >

[jira] [Updated] (FLINK-3661) Make Scala 2.11.x the default Scala version

[ https://issues.apache.org/jira/browse/FLINK-3661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3661: -- Fix Version/s: (was: 1.1.0) > Make Scala 2.11.x the default Scala version >

[jira] [Updated] (FLINK-3662) Bump Akka version to 2.4.x for Scala 2.11.x

[ https://issues.apache.org/jira/browse/FLINK-3662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3662: -- Fix Version/s: (was: 1.1.0) > Bump Akka version to 2.4.x for Scala 2.11.x >

[jira] [Commented] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333680#comment-15333680 ] Robert Metzger commented on FLINK-3864: --- Have you started working on this? Will this go into the

[jira] [Updated] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3864: -- Component/s: YARN Client > Yarn tests don't check for prohibited strings in log output >

[jira] [Updated] (FLINK-3875) Add a TableSink for Elasticsearch

[ https://issues.apache.org/jira/browse/FLINK-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3875: -- Fix Version/s: (was: 1.1.0) > Add a TableSink for Elasticsearch >

[jira] [Updated] (FLINK-3874) Add a Kafka TableSink with JSON serialization

[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3874: -- Fix Version/s: (was: 1.1.0) > Add a Kafka TableSink with JSON serialization >

[jira] [Updated] (FLINK-3873) Add a Kafka TableSink with Avro serialization

[ https://issues.apache.org/jira/browse/FLINK-3873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3873: -- Fix Version/s: (was: 1.1.0) > Add a Kafka TableSink with Avro serialization >

[jira] [Updated] (FLINK-3720) Add warm starts for models

[ https://issues.apache.org/jira/browse/FLINK-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3720: -- Fix Version/s: (was: 1.1.0) > Add warm starts for models > -- > >

[jira] [Resolved] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3933. --- Resolution: Fixed This has been merged in

[jira] [Updated] (FLINK-3933) Add an auto-type-extracting DeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-3933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3933: -- Component/s: Streaming Connectors > Add an auto-type-extracting DeserializationSchema >

[jira] [Commented] (FLINK-3395) Polishing the web UI

[ https://issues.apache.org/jira/browse/FLINK-3395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333700#comment-15333700 ] Robert Metzger commented on FLINK-3395: --- The PR opened by Stephan has the wrong issue id. So its

[jira] [Commented] (FLINK-3995) Properly Structure Test Utils and Dependencies

[ https://issues.apache.org/jira/browse/FLINK-3995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333701#comment-15333701 ] Robert Metzger commented on FLINK-3995: --- There is a pull request for this one, with the wrong JIRA

[jira] [Commented] (FLINK-4021) Problem of setting autoread for netty channel when more tasks sharing the same Tcp connection

[ https://issues.apache.org/jira/browse/FLINK-4021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333658#comment-15333658 ] Robert Metzger commented on FLINK-4021: --- [~uce], is this an issue that should go into 1.1.0 ? >

[jira] [Updated] (FLINK-3894) Remove Program Packaging via Plans

[ https://issues.apache.org/jira/browse/FLINK-3894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3894: -- Fix Version/s: (was: 1.1.0) > Remove Program Packaging via Plans >

[jira] [Updated] (FLINK-3871) Add Kafka TableSource with Avro serialization

[ https://issues.apache.org/jira/browse/FLINK-3871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3871: -- Fix Version/s: (was: 1.1.0) > Add Kafka TableSource with Avro serialization >

[jira] [Commented] (FLINK-3827) Flink modules include unused dependencies

[ https://issues.apache.org/jira/browse/FLINK-3827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333677#comment-15333677 ] Robert Metzger commented on FLINK-3827: --- [~till.rohrmann] What's the status here. Do you still think

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

[ https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2821: -- Fix Version/s: (was: 1.1.0) > Change Akka configuration to allow accessing actors from

[jira] [Updated] (FLINK-2155) Add an additional checkstyle validation for illegal imports

[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-2155: -- Fix Version/s: (was: 1.1.0) > Add an additional checkstyle validation for illegal imports >

[jira] [Updated] (FLINK-3895) Remove Docs for Program Packaging via Plans

[ https://issues.apache.org/jira/browse/FLINK-3895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3895: -- Fix Version/s: (was: 1.1.0) > Remove Docs for Program Packaging via Plans >

[jira] [Updated] (FLINK-3967) Provide RethinkDB Sink for Flink

[ https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3967: -- Fix Version/s: (was: 1.1.0) > Provide RethinkDB Sink for Flink >

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333692#comment-15333692 ] Robert Metzger commented on FLINK-3950: --- [~Zentol] is this in the scope of the 1.1 release or for

[jira] [Commented] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333740#comment-15333740 ] Robert Metzger commented on FLINK-4038: --- Can you work on FLINK-4038 - FLINK-4040 until the 1.1.

[jira] [Comment Edited] (FLINK-4038) Impossible to set more than 1 JVM argument in env.java.opts

[ https://issues.apache.org/jira/browse/FLINK-4038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333740#comment-15333740 ] Robert Metzger edited comment on FLINK-4038 at 6/16/16 1:12 PM: [~gyfora]

[jira] [Assigned] (FLINK-3924) Remove protobuf shading from Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3924: - Assignee: Robert Metzger > Remove protobuf shading from Kinesis connector >

[jira] [Commented] (FLINK-3924) Remove protobuf shading from Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-3924?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333752#comment-15333752 ] Robert Metzger commented on FLINK-3924: --- I'm assigning this to myself > Remove protobuf shading

[jira] [Updated] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

[ https://issues.apache.org/jira/browse/FLINK-4022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4022: -- Component/s: Streaming Connectors Kafka Connector > Partition discovery /

[jira] [Commented] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available

[ https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342007#comment-15342007 ] Robert Metzger commented on FLINK-4097: --- Oh yes. You are right. Maybe it would make sense to add a

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

[ https://issues.apache.org/jira/browse/FLINK-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342103#comment-15342103 ] Robert Metzger commented on FLINK-4034: --- I don't think always updating to the biggest version is a

[jira] [Commented] (FLINK-4097) Cassandra Sink throws NPE on closing if server is not available

[ https://issues.apache.org/jira/browse/FLINK-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342052#comment-15342052 ] Robert Metzger commented on FLINK-4097: --- Why are you not a fan of it? > Cassandra Sink throws NPE

[jira] [Updated] (FLINK-3675) YARN ship folder incosistent behavior

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3675: -- Priority: Critical (was: Major) > YARN ship folder incosistent behavior >

[jira] [Updated] (FLINK-3675) YARN ship folder incosistent behavior

[ https://issues.apache.org/jira/browse/FLINK-3675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3675: -- Fix Version/s: 1.1.0 > YARN ship folder incosistent behavior >

[jira] [Commented] (FLINK-2313) Change Streaming Driver Execution Model

[ https://issues.apache.org/jira/browse/FLINK-2313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15342789#comment-15342789 ] Robert Metzger commented on FLINK-2313: --- Another important feature here would be to make the job id,

[jira] [Created] (FLINK-4110) Provide testing skeleton in quickstarts

Robert Metzger created FLINK-4110: - Summary: Provide testing skeleton in quickstarts Key: FLINK-4110 URL: https://issues.apache.org/jira/browse/FLINK-4110 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346083#comment-15346083 ] Robert Metzger commented on FLINK-4051: --- I'll close the issue. Thank you for investigating this,

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

[ https://issues.apache.org/jira/browse/FLINK-4051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4051. --- Resolution: Invalid Assignee: (was: Subhankar Biswas) > RabbitMQ Source might not

[jira] [Updated] (FLINK-4061) about flink jdbc connect oracle db exists a crital bug

[ https://issues.apache.org/jira/browse/FLINK-4061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4061: -- Priority: Major (was: Blocker) > about flink jdbc connect oracle db exists a crital bug >

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

[ https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3311. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in

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

[ https://issues.apache.org/jira/browse/FLINK-3332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3332. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in

[jira] [Commented] (FLINK-2155) Add an additional checkstyle validation for illegal imports

[ https://issues.apache.org/jira/browse/FLINK-2155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333671#comment-15333671 ] Robert Metzger commented on FLINK-2155: --- I'm removing the target 1.1. release for this issue.

[jira] [Commented] (FLINK-3890) Deprecate streaming mode flag from Yarn CLI

[ https://issues.apache.org/jira/browse/FLINK-3890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15333712#comment-15333712 ] Robert Metzger commented on FLINK-3890: --- This will be addressed by

[jira] [Assigned] (FLINK-4027) FlinkKafkaProducer09 sink can lose messages

[ https://issues.apache.org/jira/browse/FLINK-4027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4027: - Assignee: Robert Metzger > FlinkKafkaProducer09 sink can lose messages >

[jira] [Updated] (FLINK-4040) Same env.java.opts is applied for TM , JM and ZK

[ https://issues.apache.org/jira/browse/FLINK-4040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4040: -- Component/s: YARN Client > Same env.java.opts is applied for TM , JM and ZK >

[jira] [Commented] (FLINK-3210) Unnecessary call to deserializer#deserialize() in LegacyFetcher#SimpleConsumerThread#run()

[ https://issues.apache.org/jira/browse/FLINK-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15089566#comment-15089566 ] Robert Metzger commented on FLINK-3210: --- I think this issue is invalid. A null value indicates a

[jira] [Commented] (FLINK-3248) RMQSource does not provide a constructor for credentials or other options

[ https://issues.apache.org/jira/browse/FLINK-3248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105076#comment-15105076 ] Robert Metzger commented on FLINK-3248: --- I would prefer the {{ConnectionFactory}} variant. How would

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

[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15105079#comment-15105079 ] Robert Metzger commented on FLINK-3067: --- [~gyfora], did you see this issue again or can we close it?

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

[ https://issues.apache.org/jira/browse/FLINK-3220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3220: - Assignee: Robert Metzger > Flink does not start on Hortonworks Sandbox 2.3.2 due to

[jira] [Assigned] (FLINK-3241) Scala 2.11 Flink binaries pull in Scala 2.10 dependencies

[ https://issues.apache.org/jira/browse/FLINK-3241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-3241: - Assignee: Robert Metzger > Scala 2.11 Flink binaries pull in Scala 2.10 dependencies >

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