[jira] [Resolved] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi resolved FLINK-3405. -- Resolution: Fixed Fix Version/s: 1.0.4 1.1.0 > Extend NiFiSource with

[jira] [Reopened] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suneel Marthi reopened FLINK-3405: -- Sorry, marked as Resolved by mistake. > Extend NiFiSource with interface StoppableFunction > --

[jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305775#comment-15305775 ] ASF GitHub Bot commented on FLINK-3405: --- Github user smarthi commented on the pull r

[GitHub] flink pull request: FLINK-3405: Extend NiFiSource with interface S...

Github user smarthi commented on the pull request: https://github.com/apache/flink/pull/2047#issuecomment-222344951 I started to add some NiFi integration tests which are presently lacking, but realized that it would be better to have that as part of a different jira. --- If your pro

[jira] [Commented] (FLINK-3405) Extend NiFiSource with interface StoppableFunction

[ https://issues.apache.org/jira/browse/FLINK-3405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305774#comment-15305774 ] ASF GitHub Bot commented on FLINK-3405: --- GitHub user smarthi opened a pull request:

[GitHub] flink pull request: FLINK-3405: Extend NiFiSource with interface S...

GitHub user smarthi opened a pull request: https://github.com/apache/flink/pull/2047 FLINK-3405: Extend NiFiSource with interface StoppableFunction Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[jira] [Updated] (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:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-3989: --- Summary: Add guide to write a custom streaming connector in DataStream API documentati

[jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector

[ https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305768#comment-15305768 ] Tzu-Li (Gordon) Tai commented on FLINK-3211: I just noticed the conversation o

[jira] [Created] (FLINK-3989) Add guide to write a custom streaming source / sink in DataStream API documentation

Tzu-Li (Gordon) Tai created FLINK-3989: -- Summary: Add guide to write a custom streaming source / sink in DataStream API documentation Key: FLINK-3989 URL: https://issues.apache.org/jira/browse/FLINK-3989

[jira] [Commented] (FLINK-3229) Kinesis streaming consumer with integration of Flink's checkpointing mechanics

[ https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305762#comment-15305762 ] Tzu-Li (Gordon) Tai commented on FLINK-3229: Great working with the community

[jira] [Commented] (FLINK-3211) Add AWS Kinesis streaming connector

[ https://issues.apache.org/jira/browse/FLINK-3211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305760#comment-15305760 ] Tzu-Li (Gordon) Tai commented on FLINK-3211: [~rmetzger] Hi Robert, I'm back a

[jira] [Updated] (FLINK-3988) Add data set connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yijie Shen updated FLINK-3988: -- Description: I would like to add a connector to DistributedLog, which recently published by twitter. Al

[jira] [Updated] (FLINK-3987) Add data stream connector to DistributedLog

[ https://issues.apache.org/jira/browse/FLINK-3987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yijie Shen updated FLINK-3987: -- Description: I would like to add a connector to DistributedLog, which recently published by twitter. Al

[jira] [Created] (FLINK-3988) Add data set connector to DistributedLog

Jia Zhai created FLINK-3988: --- Summary: Add data set connector to DistributedLog Key: FLINK-3988 URL: https://issues.apache.org/jira/browse/FLINK-3988 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-3987) Add data stream connector to DistributedLog

Jia Zhai created FLINK-3987: --- Summary: Add data stream connector to DistributedLog Key: FLINK-3987 URL: https://issues.apache.org/jira/browse/FLINK-3987 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305595#comment-15305595 ] Chesnay Schepler commented on FLINK-3986: - and in what way is it broken? > Rename

[jira] [Commented] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305594#comment-15305594 ] Chesnay Schepler commented on FLINK-3986: - was it broken in 1.0? > Rename the rea

[jira] [Commented] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305583#comment-15305583 ] Aljoscha Krettek commented on FLINK-3986: - Didn't we decide on removing this even

[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&focusedCommentId=15305418#comment-15305418 ] Chesnay Schepler commented on FLINK-3985: - [~kkrugler] no, the new metric system i

[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&focusedCommentId=15305411#comment-15305411 ] Ken Krugler commented on FLINK-3985: Any chance this is related to the change made for

[jira] [Updated] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-3986: -- Description: The readFileStream(String filePath, long intervalMillis, WatchType watchType) has t

[jira] [Created] (FLINK-3986) Rename the readFileStream(String filePath, long intervalMillis, WatchType watchType) from the StreamExecutionEnvironment

Kostas Kloudas created FLINK-3986: - Summary: Rename the readFileStream(String filePath, long intervalMillis, WatchType watchType) from the StreamExecutionEnvironment Key: FLINK-3986 URL: https://issues.apache.org/

[jira] [Updated] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-3986: -- Summary: Rename the readFileStream from the StreamExecutionEnvironment (was: Rename the readFil

[jira] [Updated] (FLINK-3986) Rename the readFileStream from the StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-3986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas updated FLINK-3986: -- Description: The (String filePath, long intervalMillis, WatchType watchType) > Rename the readFi

[jira] [Commented] (FLINK-3984) Event time of stream transformations is undocumented

[ https://issues.apache.org/jira/browse/FLINK-3984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305235#comment-15305235 ] Aljoscha Krettek commented on FLINK-3984: - +1, we definitely need documentation ab

[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&focusedCommentId=15305214#comment-15305214 ] Robert Metzger commented on FLINK-3985: --- The same issue in this build: https://s3.a

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

[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] [Commented] (FLINK-3212) JobManagerCheckpointRecoveryITCase

[ https://issues.apache.org/jira/browse/FLINK-3212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305212#comment-15305212 ] Robert Metzger commented on FLINK-3212: --- Another case: https://s3.amazonaws.com/arc

[jira] [Commented] (FLINK-3704) JobManagerHAProcessFailureBatchRecoveryITCase.testJobManagerProcessFailure unstable

[ https://issues.apache.org/jira/browse/FLINK-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15305211#comment-15305211 ] Robert Metzger commented on FLINK-3704: --- Another instance: https://s3.amazonaws.com