[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444965#comment-15444965
]
Ivan Mushketyk commented on FLINK-2254:
---
Hi [~vkalavri],
Thank you for a detailed r
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444782#comment-15444782
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 Inde
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444761#comment-15444761
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444762#comment-15444762
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 to
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 to
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444745#comment-15444745
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 to
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444743#comment-15444743
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444737#comment-15444737
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 to
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444739#comment-15444739
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444736#comment-15444736
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 to
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 to
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 to
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444729#comment-15444729
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 Ap
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444726#comment-15444726
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 Ap
[
https://issues.apache.org/jira/browse/FLINK-3920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444720#comment-15444720
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
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 Ap
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1589#comment-1589
]
ASF GitHub Bot commented on FLINK-4375:
---
Github user wenlong88 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1590#comment-1590
]
ASF GitHub Bot commented on FLINK-4375:
---
Github user wenlong88 closed the pull reque
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 your
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 e
[
https://issues.apache.org/jira/browse/FLINK-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444399#comment-15444399
]
ASF GitHub Bot commented on FLINK-4519:
---
Github user shijinkui commented on the issu
Github user shijinkui commented on the issue:
https://github.com/apache/flink/pull/2429
@rehevkor5
https://builds.apache.org/job/flink-github-ci/274/org.apache.flink$flink-connector-kafka-0.8_2.10/testReport/org.apache.flink.streaming.connectors.kafka/Kafka08ITCase/org_apache_flink_str
[
https://issues.apache.org/jira/browse/FLINK-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444180#comment-15444180
]
Vasia Kalavri commented on FLINK-2254:
--
Hi [~ivan.mushketyk],
what you are describin
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444046#comment-15444046
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the iss
[
https://issues.apache.org/jira/browse/FLINK-3929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15444044#comment-15444044
]
ASF GitHub Bot commented on FLINK-3929:
---
Github user vijikarthi commented on the iss
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 d
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 (auth:SIMPLE
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443628#comment-15443628
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4194 at 8/28/16 3:39 PM:
---
[
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 KinesisDeserializa
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-4194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443628#comment-15443628
]
Tzu-Li (Gordon) Tai commented on FLINK-4194:
I'll implement {{isEndOfShard()}}
[
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 K
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-3967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443457#comment-15443457
]
ASF GitHub Bot commented on FLINK-3967:
---
Github user mans2singh commented on the iss
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
---
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443415#comment-15443415
]
Josep Rubió commented on FLINK-1707:
Hi [~vkalavri],
Yeps, I'll do that. I thought yo
[
https://issues.apache.org/jira/browse/FLINK-4521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443338#comment-15443338
]
ASF GitHub Bot commented on FLINK-4521:
---
GitHub user mushketyk opened a pull request
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 HT
[
https://issues.apache.org/jira/browse/FLINK-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443318#comment-15443318
]
Vasia Kalavri commented on FLINK-1707:
--
Hi [~joseprupi],
thanks for the update. Rega
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
Compone
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: Bu
[
https://issues.apache.org/jira/browse/FLINK-4341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15443011#comment-15443011
]
ASF GitHub Bot commented on FLINK-4341:
---
Github user tzulitai commented on the issue
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 pro
51 matches
Mail list logo
