[jira] [Created] (FLINK-5339) Ensure Flink works with Log4j version 2

Robert Metzger created FLINK-5339: - Summary: Ensure Flink works with Log4j version 2 Key: FLINK-5339 URL: https://issues.apache.org/jira/browse/FLINK-5339 Project: Flink Issue Type: Improveme

[jira] [Resolved] (FLINK-4429) Move Redis Sink from Flink to Bahir

[ https://issues.apache.org/jira/browse/FLINK-4429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4429. --- Resolution: Fixed Fix Version/s: 1.2.0 Redis is now in Bahir, so I deleted it from Flin

[jira] [Resolved] (FLINK-4446) Move Flume Sink from Flink to Bahir

[ https://issues.apache.org/jira/browse/FLINK-4446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4446. --- Resolution: Fixed Fix Version/s: 1.2.0 Resolved for Flink in http://git-wip-us.apache.

[jira] [Updated] (FLINK-3398) Flink Kafka consumer should support auto-commit opt-outs

[ https://issues.apache.org/jira/browse/FLINK-3398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3398: -- Priority: Critical (was: Blocker) > Flink Kafka consumer should support auto-commit opt-outs >

[jira] [Created] (FLINK-5345) IOManager failed to properly clean up temp file directory

Robert Metzger created FLINK-5345: - Summary: IOManager failed to properly clean up temp file directory Key: FLINK-5345 URL: https://issues.apache.org/jira/browse/FLINK-5345 Project: Flink Iss

[jira] [Commented] (FLINK-4631) NullPointerException during stream task cleanup

[ https://issues.apache.org/jira/browse/FLINK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15751655#comment-15751655 ] Robert Metzger commented on FLINK-4631: --- The issue persists for Flink 1.1.4 RC3 > N

[jira] [Created] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory

Robert Metzger created FLINK-5356: - Summary: librocksdbjni*.so is not deleted from /tmp directory Key: FLINK-5356 URL: https://issues.apache.org/jira/browse/FLINK-5356 Project: Flink Issue Ty

[jira] [Commented] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory

[ https://issues.apache.org/jira/browse/FLINK-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15754996#comment-15754996 ] Robert Metzger commented on FLINK-5356: --- No, I would not backport it. If its fixed i

[jira] [Resolved] (FLINK-5356) librocksdbjni*.so is not deleted from /tmp directory

[ https://issues.apache.org/jira/browse/FLINK-5356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-5356. --- Resolution: Invalid Fix Version/s: 1.2.0 > librocksdbjni*.so is not deleted from /tmp d

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

[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761074#comment-15761074 ] Robert Metzger commented on FLINK-3150: --- I ran into this issue again. I'll try to op

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

[ https://issues.apache.org/jira/browse/FLINK-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3150: -- Labels: qa (was: ) > Make YARN container invocation configurable >

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761442#comment-15761442 ] Robert Metzger commented on FLINK-5353: --- Do you have any information why ES is loosi

[jira] [Commented] (FLINK-5353) Elasticsearch Sink loses well-formed documents when there are malformed documents

[ https://issues.apache.org/jira/browse/FLINK-5353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15761537#comment-15761537 ] Robert Metzger commented on FLINK-5353: --- Okay, I will do some experiments to see wha

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

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

[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&focusedCommentId=15346083#comment-15346083 ] Robert Metzger commented on FLINK-4051: --- I'll close the issue. Thank you for investi

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

[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] [Assigned] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4099: - Assignee: Robert Metzger > CliFrontendYarnAddressConfigurationTest fails > --

[jira] [Updated] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

[ https://issues.apache.org/jira/browse/FLINK-4099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4099: -- Labels: test-stability (was: ) > CliFrontendYarnAddressConfigurationTest fails > --

[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&focusedCommentId=15350807#comment-15350807 ] Robert Metzger commented on FLINK-3297: --- Thanks a lot for starting to work on this.

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

[ https://issues.apache.org/jira/browse/FLINK-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15350807#comment-15350807 ] Robert Metzger edited comment on FLINK-3297 at 6/27/16 11:22 AM: ---

[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&focusedCommentId=15351612#comment-15351612 ] Robert Metzger commented on FLINK-3297: --- Perfect, thanks a lot! > Streaming connect

[jira] [Resolved] (FLINK-4099) CliFrontendYarnAddressConfigurationTest fails

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

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

[ https://issues.apache.org/jira/browse/FLINK-4110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4110: - Assignee: Robert Metzger > Provide testing skeleton in quickstarts >

[jira] [Updated] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner

[ https://issues.apache.org/jira/browse/FLINK-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4114: -- Component/s: YARN Client Issue Type: Improvement (was: Bug) > Need a way to manage multipl

[jira] [Assigned] (FLINK-4085) Set Kinesis Consumer Agent to Flink

[ https://issues.apache.org/jira/browse/FLINK-4085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4085: - Assignee: Robert Metzger > Set Kinesis Consumer Agent to Flink >

[jira] [Created] (FLINK-4127) Clean up configuration and check breaking API changes

Robert Metzger created FLINK-4127: - Summary: Clean up configuration and check breaking API changes Key: FLINK-4127 URL: https://issues.apache.org/jira/browse/FLINK-4127 Project: Flink Issue T

[jira] [Updated] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4127: -- Attachment: flink-java.html flink-core.html > Clean up configuration and check b

[jira] [Updated] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4127: -- Attachment: flink-streaming-scala.html flink-streaming-java.html

[jira] [Commented] (FLINK-4114) Need a way to manage multiple named, long-lived jobs on a single YARN cluster in an automated manner

[ https://issues.apache.org/jira/browse/FLINK-4114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15353064#comment-15353064 ] Robert Metzger commented on FLINK-4114: --- Hi Chris, I'm happy hear that you've found

[jira] [Assigned] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4127: - Assignee: Robert Metzger > Clean up configuration and check breaking API changes > --

[jira] [Updated] (FLINK-4127) Clean up configuration and check breaking API changes

[ https://issues.apache.org/jira/browse/FLINK-4127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4127: -- Component/s: Build System > Clean up configuration and check breaking API changes >

[jira] [Resolved] (FLINK-4080) Kinesis consumer not exactly-once if stopped in the middle of processing aggregated records

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

[jira] [Resolved] (FLINK-4033) Missing Scala example snippets for the Kinesis Connector documentation

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

[jira] [Resolved] (FLINK-4085) Set Kinesis Consumer Agent to Flink

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

[jira] [Commented] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets()

[ https://issues.apache.org/jira/browse/FLINK-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15355119#comment-15355119 ] Robert Metzger commented on FLINK-3294: --- Hi Jens, My code is certainly outdated by

[jira] [Created] (FLINK-4133) Reflect streaming file source changes in documentation

Robert Metzger created FLINK-4133: - Summary: Reflect streaming file source changes in documentation Key: FLINK-4133 URL: https://issues.apache.org/jira/browse/FLINK-4133 Project: Flink Issue

[jira] [Created] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

Robert Metzger created FLINK-4137: - Summary: JobManager web frontend does not shut down on OOM exception on JM Key: FLINK-4137 URL: https://issues.apache.org/jira/browse/FLINK-4137 Project: Flink

[jira] [Commented] (FLINK-3294) KafkaConsumer (0.8) commit offsets using SimpleConsumer.commitOffsets()

[ https://issues.apache.org/jira/browse/FLINK-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15358546#comment-15358546 ] Robert Metzger commented on FLINK-3294: --- Hi Jens, the Kafka 0.9 consumer doesn't co

[jira] [Resolved] (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 resolved FLINK-4027. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved in http://git-wip-us.apache.org/repos/a

[jira] [Assigned] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis

[ https://issues.apache.org/jira/browse/FLINK-4146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4146: - Assignee: Robert Metzger > CliFrontendYarnAddressConfigurationTest picks wrong IP address

[jira] [Updated] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis

[ https://issues.apache.org/jira/browse/FLINK-4146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4146: -- Labels: test-stability (was: ) > CliFrontendYarnAddressConfigurationTest picks wrong IP address

[jira] [Created] (FLINK-4147) Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem

Robert Metzger created FLINK-4147: - Summary: Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem Key: FLINK-4147 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Updated] (FLINK-3397) Failed streaming jobs should fall back to the most recent checkpoint/savepoint

[ https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3397: -- Component/s: State Backends, Checkpointing > Failed streaming jobs should fall back to the most

[jira] [Created] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

Robert Metzger created FLINK-4151: - Summary: Address Travis CI build time: We are exceeding the 2 hours limit Key: FLINK-4151 URL: https://issues.apache.org/jira/browse/FLINK-4151 Project: Flink

[jira] [Updated] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4151: -- Attachment: Pasted image at 2016_07_04 16_31.png > Address Travis CI build time: We are exceedin

[jira] [Assigned] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reassigned FLINK-4151: - Assignee: Robert Metzger > Address Travis CI build time: We are exceeding the 2 hours lim

[jira] [Commented] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362211#comment-15362211 ] Robert Metzger commented on FLINK-4151: --- I attached a screenshot of the Top 20 most

[jira] [Commented] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362290#comment-15362290 ] Robert Metzger commented on FLINK-4151: --- Build #2, executing all tests needs 2 hours

[jira] [Commented] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362295#comment-15362295 ] Robert Metzger commented on FLINK-4151: --- I agree. This way, we will see failing test

[jira] [Created] (FLINK-4152) TaskManager registration exponential backoff doesn't work

Robert Metzger created FLINK-4152: - Summary: TaskManager registration exponential backoff doesn't work Key: FLINK-4152 URL: https://issues.apache.org/jira/browse/FLINK-4152 Project: Flink Iss

[jira] [Updated] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4152: -- Issue Type: Bug (was: Task) > TaskManager registration exponential backoff doesn't work > -

[jira] [Commented] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362433#comment-15362433 ] Robert Metzger commented on FLINK-4152: --- The full aggregated YARN log is more than 3

[jira] [Updated] (FLINK-4152) TaskManager registration exponential backoff doesn't work

[ https://issues.apache.org/jira/browse/FLINK-4152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4152: -- Attachment: logs.tgz > TaskManager registration exponential backoff doesn't work > -

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

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

[jira] [Resolved] (FLINK-4133) Reflect streaming file source changes in documentation

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

[jira] [Resolved] (FLINK-4146) CliFrontendYarnAddressConfigurationTest picks wrong IP address on Travis

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

[jira] [Commented] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362683#comment-15362683 ] Robert Metzger commented on FLINK-4151: --- Regarding our 10 slots, we could ask Apache

[jira] [Commented] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362783#comment-15362783 ] Robert Metzger commented on FLINK-4137: --- Here's the full log: https://gist.github.c

[jira] [Commented] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362824#comment-15362824 ] Robert Metzger commented on FLINK-4137: --- THank you for looking into the problem. I w

[jira] [Closed] (FLINK-3231) Handle Kinesis-side resharding in Kinesis streaming consumer

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

[jira] [Resolved] (FLINK-4020) Remove shard list querying from Kinesis consumer constructor

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

[jira] [Commented] (FLINK-4155) Get Kafka producer partition info in open method instead of constructor

[ https://issues.apache.org/jira/browse/FLINK-4155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15363959#comment-15363959 ] Robert Metzger commented on FLINK-4155: --- I agree that we should change this. FLINK-4

[jira] [Created] (FLINK-4157) FlinkKafkaMetrics cause TaskManager shutdown during cancellation

Robert Metzger created FLINK-4157: - Summary: FlinkKafkaMetrics cause TaskManager shutdown during cancellation Key: FLINK-4157 URL: https://issues.apache.org/jira/browse/FLINK-4157 Project: Flink

[jira] [Created] (FLINK-4160) YARN session doesn't show input validation errors

Robert Metzger created FLINK-4160: - Summary: YARN session doesn't show input validation errors Key: FLINK-4160 URL: https://issues.apache.org/jira/browse/FLINK-4160 Project: Flink Issue Type:

[jira] [Commented] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

[ https://issues.apache.org/jira/browse/FLINK-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15364082#comment-15364082 ] Robert Metzger commented on FLINK-4137: --- Thanks a lot for the good analysis of the i

[jira] [Resolved] (FLINK-4151) Address Travis CI build time: We are exceeding the 2 hours limit

[ https://issues.apache.org/jira/browse/FLINK-4151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-4151. --- Resolution: Fixed Resolved for now by splitting the builds: http://git-wip-us.apache.org/repo

[jira] [Resolved] (FLINK-4137) JobManager web frontend does not shut down on OOM exception on JM

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

[jira] [Resolved] (FLINK-3034) Redis SInk Connector

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3034. --- Resolution: Fixed Fix Version/s: 1.1.0 Merged in: http://git-wip-us.apache.org/repos/as

[jira] [Commented] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

[ https://issues.apache.org/jira/browse/FLINK-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15365978#comment-15365978 ] Robert Metzger commented on FLINK-4156: --- [~aljoscha]: This only happens if the same

[jira] [Updated] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

[ https://issues.apache.org/jira/browse/FLINK-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4156: -- Component/s: YARN Client > Job with -m yarn-cluster registers TaskManagers to another running Ya

[jira] [Commented] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests

[ https://issues.apache.org/jira/browse/FLINK-4168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366040#comment-15366040 ] Robert Metzger commented on FLINK-4168: --- Ufuk just published a hotfix for this issue

[jira] [Updated] (FLINK-4168) ForkableFlinkMiniCluster not available in Kinesis connector tests

[ https://issues.apache.org/jira/browse/FLINK-4168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4168: -- Component/s: Build System > ForkableFlinkMiniCluster not available in Kinesis connector tests >

[jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366086#comment-15366086 ] Robert Metzger commented on FLINK-4170: --- +1 > Remove `CONFIG_` prefix from KinesisC

[jira] [Commented] (FLINK-4169) CEP Does Not Work with RocksDB StateBackend

[ https://issues.apache.org/jira/browse/FLINK-4169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366088#comment-15366088 ] Robert Metzger commented on FLINK-4169: --- Adding rocksdb as test-scoped dependency to

[jira] [Commented] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

[ https://issues.apache.org/jira/browse/FLINK-4156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15366126#comment-15366126 ] Robert Metzger commented on FLINK-4156: --- Isn't this issue the same as FLINK-4166? >

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15367444#comment-15367444 ] Robert Metzger commented on FLINK-4022: --- Hi [~tzulitai], Yes, go ahead and assign t

[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&focusedCommentId=15367445#comment-15367445 ] Robert Metzger commented on FLINK-3924: --- No. I could not find any good solution for

[jira] [Updated] (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 updated FLINK-3924: -- Fix Version/s: (was: 1.1.0) 1.2.0 > Remove protobuf shading from Kinesis

[jira] [Created] (FLINK-4177) CassandraConnectorTest.testCassandraCommitter causing unstable builds

Robert Metzger created FLINK-4177: - Summary: CassandraConnectorTest.testCassandraCommitter causing unstable builds Key: FLINK-4177 URL: https://issues.apache.org/jira/browse/FLINK-4177 Project: Flink

[jira] [Created] (FLINK-4178) CoStreamCheckpointingITCase deadlocks

Robert Metzger created FLINK-4178: - Summary: CoStreamCheckpointingITCase deadlocks Key: FLINK-4178 URL: https://issues.apache.org/jira/browse/FLINK-4178 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk7

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

[jira] [Updated] (FLINK-4176) Travis build fails at flink-connector-kinesis for JDK: openjdk7

[ https://issues.apache.org/jira/browse/FLINK-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-4176: -- Component/s: Streaming Connectors Kinesis Connector Build Syste

[jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15369025#comment-15369025 ] Robert Metzger commented on FLINK-3516: --- Once again https://s3.amazonaws.com/archive

[jira] [Updated] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3516: -- Component/s: JobManager Distributed Coordination > JobManagerHACheckpointRecove

[jira] [Updated] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3516: -- Labels: test-stability (was: ) > JobManagerHACheckpointRecoveryITCase testCheckpointedStreaming

[jira] [Resolved] (FLINK-4019) Expose approximateArrivalTimestamp through the KinesisDeserializationSchema interface

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

[jira] [Created] (FLINK-4186) Expose Kafka metrics through Flink metrics

Robert Metzger created FLINK-4186: - Summary: Expose Kafka metrics through Flink metrics Key: FLINK-4186 URL: https://issues.apache.org/jira/browse/FLINK-4186 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-4170) Remove `CONFIG_` prefix from KinesisConfigConstants variables

[ https://issues.apache.org/jira/browse/FLINK-4170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15370305#comment-15370305 ] Robert Metzger commented on FLINK-4170: --- +1 > Remove `CONFIG_` prefix from KinesisC

[jira] [Resolved] (FLINK-4185) Reflecting rename from Tachyon to Alluxio

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

[jira] [Commented] (FLINK-4178) CoStreamCheckpointingITCase deadlocks

[ https://issues.apache.org/jira/browse/FLINK-4178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15370609#comment-15370609 ] Robert Metzger commented on FLINK-4178: --- It happened again: https://s3.amazonaws.co

[jira] [Resolved] (FLINK-4157) FlinkKafkaMetrics cause TaskManager shutdown during cancellation

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

[jira] [Created] (FLINK-4191) Expose shard information in KinesisDeserializationSchema

Robert Metzger created FLINK-4191: - Summary: Expose shard information in KinesisDeserializationSchema Key: FLINK-4191 URL: https://issues.apache.org/jira/browse/FLINK-4191 Project: Flink Issu

[jira] [Created] (FLINK-4194) KinesisDeserializationSchema.isEndOfStream() is never called

Robert Metzger created FLINK-4194: - Summary: KinesisDeserializationSchema.isEndOfStream() is never called Key: FLINK-4194 URL: https://issues.apache.org/jira/browse/FLINK-4194 Project: Flink

[jira] [Commented] (FLINK-4195) Dedicated Configuration classes for Kinesis Consumer / Producer

[ https://issues.apache.org/jira/browse/FLINK-4195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15371496#comment-15371496 ] Robert Metzger commented on FLINK-4195: --- If we are going to rework the configuration

[jira] [Resolved] (FLINK-4191) Expose shard information in KinesisDeserializationSchema

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

[jira] [Resolved] (FLINK-4018) Configurable idle time between getRecords requests to Kinesis shards

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

[jira] [Commented] (FLINK-3516) JobManagerHACheckpointRecoveryITCase testCheckpointedStreamingSumProgram fails

[ https://issues.apache.org/jira/browse/FLINK-3516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15372521#comment-15372521 ] Robert Metzger commented on FLINK-3516: --- And again https://s3.amazonaws.com/archive.

[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&focusedCommentId=15372606#comment-15372606 ] Robert Metzger commented on FLINK-4015: --- What's the throughput of the Kafka producer

<    1   2   3   4   5   6   7   8   9   10   >