[jira] [Updated] (FLINK-3123) Allow setting custom start-offsets for the Kafka consumer

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-3123: -- Assignee: (was: Robert Metzger) > Allow setting custom start-offsets for the Kafka consumer

[jira] [Commented] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-12-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054575#comment-15054575 ] ASF GitHub Bot commented on FLINK-3077: --- Github user asfgit closed the pull request

[jira] [Resolved] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3077. --- Resolution: Fixed Resolved for 1.0.0 in http://git-wip-us.apache.org/repos/asf/flink/commit/6

[GitHub] flink pull request: [FLINK-3077][cli] Add version option to Cli.

2015-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1418 --- 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

[jira] [Commented] (FLINK-3077) Add "version" command to CliFrontend for showing the version of the installation

2015-12-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3077?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054564#comment-15054564 ] ASF GitHub Bot commented on FLINK-3077: --- Github user rmetzger commented on the pull

[GitHub] flink pull request: [FLINK-3077][cli] Add version option to Cli.

2015-12-12 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1418#issuecomment-164177365 I'll merge this change ... --- 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

[jira] [Resolved] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-3023. --- Resolution: Fixed Fix Version/s: 1.0.0 Resolved in master: http://git-wip-us.apache.org

[jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054560#comment-15054560 ] ASF GitHub Bot commented on FLINK-3023: --- Github user asfgit closed the pull request

[GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an...

2015-12-12 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/1422 --- 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

[GitHub] flink pull request: [FLINK-3023][web-dashboard] Display version an...

2015-12-12 Thread rmetzger
Github user rmetzger commented on the pull request: https://github.com/apache/flink/pull/1422#issuecomment-164177222 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 e

[jira] [Commented] (FLINK-3023) Show Flink version + commit id for -SNAPSHOT versions in web frontend

2015-12-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054559#comment-15054559 ] ASF GitHub Bot commented on FLINK-3023: --- Github user rmetzger commented on the pull

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

2015-12-12 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054538#comment-15054538 ] ASF GitHub Bot commented on FLINK-3067: --- GitHub user rmetzger opened a pull request:

[GitHub] flink pull request: [FLINK-3067] Use curator for committing offset...

2015-12-12 Thread rmetzger
GitHub user rmetzger opened a pull request: https://github.com/apache/flink/pull/1451 [FLINK-3067] Use curator for committing offsets to ZK from Kafka @aljoscha reported issues with our latest FlinkKafkaConnector: It was still throwing NPE. Therefore, I decided to abandon the [

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

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger reopened FLINK-3067: --- The issue is still not resolved. Next approach: We update ZK using Apache Curator. > Kafka sourc

[jira] [Commented] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-12 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15054424#comment-15054424 ] Robert Metzger commented on FLINK-3121: --- Just for clarification: Your fix resolves t