[jira] [Created] (FLINK-4520) Integrate Siddhi as a lightweight CEP Library

Hao Chen created FLINK-4520: --- Summary: Integrate Siddhi as a lightweight CEP Library Key: FLINK-4520 URL: https://issues.apache.org/jira/browse/FLINK-4520 Project: Flink Issue Type: New Feature

[jira] [Comment Edited] (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=15442548#comment-15442548 ] Josep Rubió edited comment on FLINK-1707 at 8/28/16 1:48 AM: -

[jira] [Comment Edited] (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=15442548#comment-15442548 ] Josep Rubió edited comment on FLINK-1707 at 8/28/16 1:47 AM: -

[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=15442548#comment-15442548 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri] I've pushed a new version of AP w

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

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

[GitHub] flink pull request #2430: [FLINK-3874] Rewrite Kafka JSON Table sink tests

GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2430 [FLINK-3874] Rewrite Kafka JSON Table sink tests Turned Kafka JSON Table sink tests into unit tests as discussed here: https://issues.apache.org/jira/browse/FLINK-3874 - [x] General

[jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose

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

[GitHub] flink pull request #2398: [FLINK-4440][gelly] Add Vertex.create and Edge.cre...

Github user mushketyk closed the pull request at: https://github.com/apache/flink/pull/2398 --- 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 e

[jira] [Commented] (FLINK-4440) Make API for edge/vertex creation less verbose

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

[GitHub] flink issue #2398: [FLINK-4440][gelly] Add Vertex.create and Edge.create hel...

Github user mushketyk commented on the issue: https://github.com/apache/flink/pull/2398 Closing according to discussion in JIRA. --- 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-2254) Add Bipartite Graph Support for Gelly

[ https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15441673#comment-15441673 ] Ivan Mushketyk commented on FLINK-2254: --- [~vkalavri] I went through the paper listed

[jira] [Closed] (FLINK-4518) maxLineLength change to 120

[ https://issues.apache.org/jira/browse/FLINK-4518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] shijinkui closed FLINK-4518. Resolution: Duplicate > maxLineLength change to 120 > --- > > Key: F

[jira] [Commented] (FLINK-4519) scala maxLineLength increased to 120

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

[GitHub] flink pull request #2429: [FLINK-4519] scala maxLineLength increased to 120

GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/2429 [FLINK-4519] scala maxLineLength increased to 120 Because Scala function's parameter is more long than Java code, We can set the maxLineLength to 120. The pull request references the rel

[jira] [Created] (FLINK-4519) scala maxLineLength increased to 120

shijinkui created FLINK-4519: Summary: scala maxLineLength increased to 120 Key: FLINK-4519 URL: https://issues.apache.org/jira/browse/FLINK-4519 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4518) maxLineLength change to 120

shijinkui created FLINK-4518: Summary: maxLineLength change to 120 Key: FLINK-4518 URL: https://issues.apache.org/jira/browse/FLINK-4518 Project: Flink Issue Type: Improvement Reporte

[jira] [Commented] (FLINK-4517) scala code refactoring

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

[GitHub] flink pull request #2428: [FLINK-4517] scala code refactoring

GitHub user shijinkui opened a pull request: https://github.com/apache/flink/pull/2428 [FLINK-4517] scala code refactoring the refacter type: 1. case class does't need `new` 2. case block does't need `{ ... }` 3. match-case instead of isInstanceOf referen

[jira] [Commented] (FLINK-4341) Kinesis connector does not emit maximum watermark properly

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

[GitHub] flink issue #2414: [FLINK-4341] Let idle consumer subtasks emit max value wa...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/2414 To include the missing case @rmetzger mentioned, it turns out the fix is actually more complicated than I expected due to correct state determination after every reshard, and requires a bit of rewor

[jira] [Created] (FLINK-4517) scala code refactoring

shijinkui created FLINK-4517: Summary: scala code refactoring Key: FLINK-4517 URL: https://issues.apache.org/jira/browse/FLINK-4517 Project: Flink Issue Type: Improvement Reporter: sh