[jira] [Created] (FLINK-4618) Last kafka message gets consumed twice when restarting job

Melmoth created FLINK-4618: -- Summary: Last kafka message gets consumed twice when restarting job Key: FLINK-4618 URL: https://issues.apache.org/jira/browse/FLINK-4618 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Melmoth updated FLINK-4618: --- Description: There seem to be an issue with the offset management in Flink. When a job is stopped and startet

[jira] [Updated] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Melmoth updated FLINK-4618: --- Description: There seem to be an issue with the offset management in Flink. When a job is stopped and startet

[jira] [Commented] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15490110#comment-15490110 ] Melmoth commented on FLINK-4618: Hi Gordon, what if I update/change the job and re-submit

[jira] [Comment Edited] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15490110#comment-15490110 ] Melmoth edited comment on FLINK-4618 at 9/14/16 10:47 AM: -- Hi Gor

[jira] [Closed] (FLINK-4618) Last kafka message gets consumed twice when restarting job

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Melmoth closed FLINK-4618. -- Resolution: Not A Bug No bug, use savepoints before canceling a task. See Gordons comments. > Last kafka messag

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15503281#comment-15503281 ] Melmoth commented on FLINK-4618: I will try to fix the bug, but I'm also a Flink newbie ;)

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15503798#comment-15503798 ] Melmoth commented on FLINK-4618: The offset handling seems to be done by the Kafka client

[jira] [Created] (FLINK-4707) Including flink-connector-filesystem as dependency fails build

Melmoth created FLINK-4707: -- Summary: Including flink-connector-filesystem as dependency fails build Key: FLINK-4707 URL: https://issues.apache.org/jira/browse/FLINK-4707 Project: Flink Issue Type:

[jira] [Updated] (FLINK-4707) Including flink-connector-filesystem as dependency fails build

[ https://issues.apache.org/jira/browse/FLINK-4707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Melmoth updated FLINK-4707: --- Description: When using flink-connector-filesystem I'm now required to include the maven-bundle-plugin in my

[jira] [Updated] (FLINK-4707) Including flink-connector-filesystem as dependency fails build

[ https://issues.apache.org/jira/browse/FLINK-4707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Melmoth updated FLINK-4707: --- Description: When using flink-connector-filesystem I'm now required to include the maven-bundle-plugin in my

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536832#comment-15536832 ] Melmoth commented on FLINK-4618: Hi tzulitai, I will give it a try this weekend. > Flink

[jira] [Comment Edited] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536832#comment-15536832 ] Melmoth edited comment on FLINK-4618 at 9/30/16 7:37 PM: - Hi [~tzu

[jira] [Commented] (FLINK-4618) FlinkKafkaConsumer09 should start from the next record on startup from offsets in Kafka

[ https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15537081#comment-15537081 ] Melmoth commented on FLINK-4618: I made a PR: https://github.com/apache/flink/pull/2579 >

[jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used

Melmoth created FLINK-4724: -- Summary: When executed in YARN wrong log4j & logback configuration file is used Key: FLINK-4724 URL: https://issues.apache.org/jira/browse/FLINK-4724 Project: Flink Iss

[jira] [Updated] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used

[ https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Melmoth updated FLINK-4724: --- Summary: When executed in YARN wrong log4j & logback configuration file are used (was: When executed in YARN

[jira] [Commented] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file are used

[ https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15544960#comment-15544960 ] Melmoth commented on FLINK-4724: Hi [~eronwright], makes sense, that way always the log4j