[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-06 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73788475 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java --- @@ -0,0 +1,97 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410657#comment-15410657 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-06 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73788502 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java --- @@ -0,0 +1,97 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410659#comment-15410659 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[GitHub] flink pull request #2332: [FLINK-2055] Implement Streaming HBaseSink

2016-08-06 Thread ramkrish86
Github user ramkrish86 commented on a diff in the pull request: https://github.com/apache/flink/pull/2332#discussion_r73788575 --- Diff: flink-streaming-connectors/flink-connector-hbase/src/main/java/org/apache/flink/streaming/connectors/hbase/HBaseMapper.java --- @@ -0,0 +1,97 @@

[jira] [Commented] (FLINK-2055) Implement Streaming HBaseSink

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-2055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410661#comment-15410661 ] ASF GitHub Bot commented on FLINK-2055: --- Github user ramkrish86 commented on a diff

[jira] [Commented] (FLINK-4322) Unify CheckpointCoordinator and SavepointCoordinator

2016-08-06 Thread ramkrishna.s.vasudevan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410662#comment-15410662 ] ramkrishna.s.vasudevan commented on FLINK-4322: --- Ok, got it. I understand. T

[jira] [Commented] (FLINK-3950) Add Meter Metric Type

2016-08-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410688#comment-15410688 ] Ivan Mushketyk commented on FLINK-3950: --- In Dropwizard Metrics Meter is implemented

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410689#comment-15410689 ] ASF GitHub Bot commented on FLINK-3318: --- GitHub user mushketyk opened a pull request

[GitHub] flink pull request #2339: [FLINK-3318] Implement one or many and optional qu...

2016-08-06 Thread mushketyk
GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2339 [FLINK-3318] Implement one or many and optional quantifiers Thanks for contributing to Apache Flink. Before you open your pull request, please take the following check list into consideration.

[GitHub] flink issue #2339: [FLINK-3318] Implement one or many and optional quantifie...

2016-08-06 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2339 So far I've only implemented one or many and optional quantifiers. I would like to implement other quantifiers, but I would like to make sure that I am on the right track before I proceed any furth

[jira] [Commented] (FLINK-3318) Add support for quantifiers to CEP's pattern API

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410690#comment-15410690 ] ASF GitHub Bot commented on FLINK-3318: --- Github user mushketyk commented on the issu

[jira] [Commented] (FLINK-3899) Document window processing with Reduce/FoldFunction + WindowFunction

2016-08-06 Thread Daniel Blazevski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410696#comment-15410696 ] Daniel Blazevski commented on FLINK-3899: - [~aljoscha] I see, would it be enough

[jira] [Commented] (FLINK-3703) Add sequence matching semantics to discard matched events

2016-08-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410704#comment-15410704 ] Ivan Mushketyk commented on FLINK-3703: --- Hi [~till.rohrmann], Thank you for your re

[jira] [Commented] (FLINK-4029) Multi-field "sum" function just like "keyBy"

2016-08-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-4029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410705#comment-15410705 ] Ivan Mushketyk commented on FLINK-4029: --- Hi, Can anyone give an advice about how th

[jira] [Commented] (FLINK-3414) Add Scala API for CEP's pattern definition

2016-08-06 Thread Ivan Mushketyk (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410706#comment-15410706 ] Ivan Mushketyk commented on FLINK-3414: --- Hi [~till.rohrmann] Do you have any though

[GitHub] flink issue #2244: [FLINK-3874] Add a Kafka TableSink with JSON serializatio...

2016-08-06 Thread mushketyk
Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2244 This PR has not been reviewed during the last 14 days. Can anyone please review it? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as wel

[jira] [Commented] (FLINK-3874) Add a Kafka TableSink with JSON serialization

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-3874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410707#comment-15410707 ] ASF GitHub Bot commented on FLINK-3874: --- Github user mushketyk commented on the issu

[GitHub] flink pull request #2053: [FLINK-1707] Affinity Propagation

2016-08-06 Thread joseprupi
Github user joseprupi commented on a diff in the pull request: https://github.com/apache/flink/pull/2053#discussion_r73792319 --- Diff: flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/AffinityPropagation.java --- @@ -0,0 +1,535 @@ +/* + * Licensed

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

2016-08-06 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410727#comment-15410727 ] ASF GitHub Bot commented on FLINK-1707: --- Github user joseprupi commented on a diff i