[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4723:
---
Summary: Unify behaviour of committed offsets to Kafka / ZK for Kafka 0.8
and 0.9 cons
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4723:
---
Description:
The proper "behaviour" of the offsets committed back to Kafka / ZK should
[
https://issues.apache.org/jira/browse/FLINK-4724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15539453#comment-15539453
]
Eron Wright commented on FLINK-4724:
-
The log4j-yarn-session.properties file is used
Jordan Ganoff created FLINK-4725:
Summary: BucketingSink throws NPE while restoring state if
basePath does not exist
Key: FLINK-4725
URL: https://issues.apache.org/jira/browse/FLINK-4725
Project: Flin
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4723:
---
Description:
The proper "definition" of the offsets committed back to Kafka / ZK shoul
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4723:
---
Description:
The proper "definition" of the offsets committed back to Kafka / ZK shoul
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-4723:
---
Description:
The proper "definition" of the offsets committed back to Kafka / ZK shoul
Tzu-Li (Gordon) Tai created FLINK-4723:
--
Summary: Unify definition of committed offsets to Kafka / ZK for
Kafka 0.8 and 0.9 consumer
Key: FLINK-4723
URL: https://issues.apache.org/jira/browse/FLINK-4723
[
https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-4618.
Resolution: Fixed
> FlinkKafkaConsumer09 should start from the next record on startu
[
https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15538306#comment-15538306
]
Tzu-Li (Gordon) Tai commented on FLINK-4618:
Resolved for master via
https://
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2579
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15538292#comment-15538292
]
ASF GitHub Bot commented on FLINK-4618:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-4618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15538287#comment-15538287
]
ASF GitHub Bot commented on FLINK-4618:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2579
Merging ...
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if th
Sudhanshu Sekhar Lenka created FLINK-4722:
-
Summary: Consumer group concept not working properly with
FlinkKafkaConsumer09
Key: FLINK-4722
URL: https://issues.apache.org/jira/browse/FLINK-4722
[
https://issues.apache.org/jira/browse/FLINK-4348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15538049#comment-15538049
]
ASF GitHub Bot commented on FLINK-4348:
---
Github user KurtYoung commented on the issu
18 matches
Mail list logo