[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444782#comment-15444782 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76552087 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/DistributedRowMatrix.scala --- @@ -159,3 +183,68 @@ case class

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444761#comment-15444761 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444762#comment-15444762 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551557 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,286 @@ +/* + * Licensed

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551568 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,286 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444745#comment-15444745 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551191 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,286 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444743#comment-15444743 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444737#comment-15444737 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551144 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMatrix.scala --- @@ -0,0 +1,286 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444739#comment-15444739 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444736#comment-15444736 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551077 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMapper.scala --- @@ -0,0 +1,107 @@ +/* + * Licensed

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551066 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMapper.scala --- @@ -0,0 +1,107 @@ +/* + * Licensed

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76551085 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/BlockMapper.scala --- @@ -0,0 +1,107 @@ +/* + * Licensed

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444729#comment-15444729 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76550871 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/Block.scala --- @@ -0,0 +1,73 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444726#comment-15444726 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76550821 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/Block.scala --- @@ -0,0 +1,73 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-3920) Distributed Linear Algebra: block-based matrix

[ https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15444720#comment-15444720 ] ASF GitHub Bot commented on FLINK-3920: --- Github user chiwanpark commented on a diff in the pull

[GitHub] flink pull request #2152: [FLINK-3920] Distributed Linear Algebra: block-bas...

Github user chiwanpark commented on a diff in the pull request: https://github.com/apache/flink/pull/2152#discussion_r76550602 --- Diff: flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/math/distributed/Block.scala --- @@ -0,0 +1,73 @@ +/* + * Licensed to the

[jira] [Commented] (FLINK-4375) Introduce rpc protocols implemented by job manager

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

[jira] [Commented] (FLINK-4375) Introduce rpc protocols implemented by job manager

[ https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1590#comment-1590 ] ASF GitHub Bot commented on FLINK-4375: --- Github user wenlong88 closed the pull request at:

[GitHub] flink issue #2375: [FLINK-4375][cluster management]Introduce rpc protocols i...

Github user wenlong88 commented on the issue: https://github.com/apache/flink/pull/2375 discarding this pr, since we define the rpc interfaces in specific subtasks such as task executor registration, etc. --- If your project is set up for it, you can reply to this email and have

[GitHub] flink pull request #2375: [FLINK-4375][cluster management]Introduce rpc prot...

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

[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=15444399#comment-15444399 ] ASF GitHub Bot commented on FLINK-4519: --- Github user shijinkui commented on the issue:

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

Github user shijinkui commented on the issue: https://github.com/apache/flink/pull/2429 @rehevkor5

[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=15444180#comment-15444180 ] Vasia Kalavri commented on FLINK-2254: -- Hi [~ivan.mushketyk], what you are describing in "we may

[jira] [Commented] (FLINK-3930) Implement Service-Level Authorization

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

[jira] [Commented] (FLINK-3929) Support for Kerberos Authentication with Keytab Credential

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

[GitHub] flink issue #2425: FLINK-3930 Added shared secret based authorization for Fl...

Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2425 @mxm - The patch is available for your review. Please take a look. --- 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

[GitHub] flink issue #2275: FLINK-3929 Support for Kerberos Authentication with Keyta...

Github user vijikarthi commented on the issue: https://github.com/apache/flink/pull/2275 > YARNSessionFIFOSecuredITCase gives me the following: 17:49:58,097 INFO SecurityLogger.org.apache.hadoop.ipc.Server - Auth successful for appattempt_1471880990715_0001_01

[jira] [Comment Edited] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15443628#comment-15443628 ] Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 8/28/16 3:39 PM: -

[jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4194: --- Affects Version/s: (was: 1.1.0) > Implement isEndOfStream() for

[jira] [Updated] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4194: --- Fix Version/s: 1.2.0 > Implement isEndOfStream() for KinesisDeserializationSchema >

[jira] [Commented] (FLINK-4194) Implement isEndOfStream() for KinesisDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15443628#comment-15443628 ] Tzu-Li (Gordon) Tai commented on FLINK-4194: I'll implement {{isEndOfShard()}} as an initial

[jira] [Updated] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp / Date

[ https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4523: --- Summary: Allow Kinesis Consumer to start from specific timestamp / Date (was: Allow

[jira] [Updated] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp

[ https://issues.apache.org/jira/browse/FLINK-4523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-4523: --- Description: We had a Kinesis user requesting this feature on an offline chat. To be

[jira] [Created] (FLINK-4523) Allow Kinesis Consumer to start from specific timestamp

Tzu-Li (Gordon) Tai created FLINK-4523: -- Summary: Allow Kinesis Consumer to start from specific timestamp Key: FLINK-4523 URL: https://issues.apache.org/jira/browse/FLINK-4523 Project: Flink

[jira] [Commented] (FLINK-3967) Provide RethinkDB Sink for Flink

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

[GitHub] flink issue #2031: FLINK-3967 - Flink Sink for Rethink Db

Github user mans2singh commented on the issue: https://github.com/apache/flink/pull/2031 Hi @rmetzger - Thanks for the update. Can you please let me know the steps for contributing to bahir ? Can I just fork it and add another project to the root folder ? Thanks

[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=15443415#comment-15443415 ] Josep Rubió commented on FLINK-1707: Hi [~vkalavri], Yeps, I'll do that. I thought you said you did

[jira] [Commented] (FLINK-4521) Fix "Submit new Job" panel in development mode

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

[GitHub] flink pull request #2431: [FLINK-4521] Fix "Submit new Job" panel in develop...

GitHub user mushketyk opened a pull request: https://github.com/apache/flink/pull/2431 [FLINK-4521] Fix "Submit new Job" panel in development mode Submit panel was completely empty in the development mode. This happened because client-side code sent AJAX requests to a development

[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=15443318#comment-15443318 ] Vasia Kalavri commented on FLINK-1707: -- Hi [~joseprupi], thanks for the update. Regarding the

[jira] [Created] (FLINK-4522) Gelly link broken in homepage

Vasia Kalavri created FLINK-4522: Summary: Gelly link broken in homepage Key: FLINK-4522 URL: https://issues.apache.org/jira/browse/FLINK-4522 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4521) Fix "Submit new Job" panel in development mode

Ivan Mushketyk created FLINK-4521: - Summary: Fix "Submit new Job" panel in development mode Key: FLINK-4521 URL: https://issues.apache.org/jira/browse/FLINK-4521 Project: Flink Issue Type:

[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=15443011#comment-15443011 ] 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 @rmetzger, @aljoscha the changes are ready for another review now, thanks! --- 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