[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15349494#comment-15349494 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on the issue

[GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2131 Hi @rmetzger , I've addressed your initial comments with the last commit. No urgent hurry on the remaining review, please take your time :) Thanks! --- If your project is set up for it, you can

[GitHub] flink issue #2131: [FLINK-3231][streaming-connectors] FlinkKinesisConsumer r...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2131 I've also tested the last commit on the unit & manual tests. --- 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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=15349496#comment-15349496 ] ASF GitHub Bot commented on FLINK-3231: --- Github user tzulitai commented on the issue

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1813 Hi, I've tested this on a local single node installation & cluster installation. It works and have not come across problems. Have a few other questions on the usage of the connector (I h

[jira] [Comment Edited] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349585#comment-15349585 ] Faye Beligianni edited comment on FLINK-1815 at 6/25/16 10:15 AM: --

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349585#comment-15349585 ] Faye Beligianni commented on FLINK-1815: I faced the following problem when I try

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

Github user mjsax commented on the issue: https://github.com/apache/flink/pull/1813 @tzulitai Thank a lot for testing this! Your feedback is really great! 1) I am not a Redis users either -- from my understanding, the second key determined the field that would be updated -- it

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

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349615#comment-15349615 ] ASF GitHub Bot commented on FLINK-3034: --- Github user mjsax commented on the issue:

[jira] [Commented] (FLINK-1815) Add methods to read and write a Graph as adjacency list

[ https://issues.apache.org/jira/browse/FLINK-1815?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349638#comment-15349638 ] Faye Beligianni commented on FLINK-1815: I think I found what was wrong! ignore th

[GitHub] flink issue #1813: [FLINK-3034] Redis Sink Connector

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/1813 Hi @mjsax, Regarding 1): just came to me that for SORTED_SET, a fixed secondary key doesn't make sense, because the secondary key is supposed to define the order of the inserted element in

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

[ https://issues.apache.org/jira/browse/FLINK-3034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349640#comment-15349640 ] ASF GitHub Bot commented on FLINK-3034: --- Github user tzulitai commented on the issue

[jira] [Created] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions

Andrea Sella created FLINK-4119: --- Summary: Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions Key: FLINK-4119 URL: https://issues.apache.org/jira/browse/FLINK-4119

[jira] [Commented] (FLINK-4119) Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions

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

[GitHub] flink pull request #2163: [FLINK-4119] Null checks in close() for Cassandra ...

GitHub user alkagin opened a pull request: https://github.com/apache/flink/pull/2163 [FLINK-4119] Null checks in close() for Cassandra Input/Output Formats, checking arguments via Flink Preconditions Thanks for contributing to Apache Flink. Before you open your pull request, please

[jira] [Closed] (FLINK-3864) Yarn tests don't check for prohibited strings in log output

[ https://issues.apache.org/jira/browse/FLINK-3864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels closed FLINK-3864. - Resolution: Fixed Fixed with d92aeb7aa63490278d9a9e36aae595e6cbe39f32 > Yarn tests don't

[GitHub] flink issue #2138: [FLINK-3757] clarify JavaDoc for addAccumulator method

Github user mxm commented on the issue: https://github.com/apache/flink/pull/2138 Thank you for the suggestion. I incorporated it! --- 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

[jira] [Commented] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name

[ https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349690#comment-15349690 ] ASF GitHub Bot commented on FLINK-3757: --- Github user mxm commented on the issue:

[jira] [Resolved] (FLINK-3757) addAccumulator does not throw Exception on duplicate accumulator name

[ https://issues.apache.org/jira/browse/FLINK-3757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3757. --- Resolution: Fixed Assignee: Maximilian Michels Fix Version/s: 1.1.0 Fi

[jira] [Resolved] (FLINK-3838) CLI parameter parser is munging application params

[ https://issues.apache.org/jira/browse/FLINK-3838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-3838. --- Resolution: Fixed master: dfecca7794f56eb2a4438e3bdca6878379929cfa release-1.0: f5a408

[jira] [Commented] (FLINK-1946) Make yarn tests logging less verbose

[ https://issues.apache.org/jira/browse/FLINK-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349695#comment-15349695 ] Maximilian Michels commented on FLINK-1946: --- Fix with 5b2ad7f03ef67ce529551e7b46

[jira] [Resolved] (FLINK-4041) Failure while asking ResourceManager for RegisterResource

[ https://issues.apache.org/jira/browse/FLINK-4041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels resolved FLINK-4041. --- Resolution: Fixed Fix Version/s: 1.1.0 Resolved with a5aa4e115814539518fcaa88cb

[jira] [Commented] (FLINK-1707) Add an Affinity Propagation Library Method

[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349699#comment-15349699 ] Josep Rubió commented on FLINK-1707: Hi Vasia, Maybe does not make sense to continue

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

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

[GitHub] flink pull request #2164: [FLINK-4118] The docker-flink image is outdated (1...

GitHub user iemejia opened a pull request: https://github.com/apache/flink/pull/2164 [FLINK-4118] The docker-flink image is outdated (1.0.2) and can be slimmed down Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into

[GitHub] flink issue #2164: [FLINK-4118] The docker-flink image is outdated (1.0.2) a...

Github user iemejia commented on the issue: https://github.com/apache/flink/pull/2164 The docker images script was simplified and the image size was reduced. Previous image: flink latest 6475add651c724 minutes a

[jira] [Commented] (FLINK-4118) The docker-flink image is outdated (1.0.2) and can be slimmed down

[ https://issues.apache.org/jira/browse/FLINK-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349826#comment-15349826 ] ASF GitHub Bot commented on FLINK-4118: --- Github user iemejia commented on the issue:

[jira] [Commented] (FLINK-3677) FileInputFormat: Allow to specify include/exclude file name patterns

[ https://issues.apache.org/jira/browse/FLINK-3677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15349840#comment-15349840 ] ASF GitHub Bot commented on FLINK-3677: --- Github user mushketyk commented on the issu

[GitHub] flink issue #2109: [FLINK-3677] FileInputFormat: Allow to specify include/ex...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2109 @kl0u >> and pass the FilePathFilter as an argument to the constructor of the FileInputFormat and then do the filtering the same way you do it I removed configuration override, but added a