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
[
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
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
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
[
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
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-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
[
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
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-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
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-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
[
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-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-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 edited comment on FLINK-4194 at 8/28/16 3:39 PM:
---
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
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
[
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
[
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-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
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-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 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
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
[
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
[
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
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-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_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=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_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=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_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
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
[
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_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=15444737#comment-15444737
]
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=15444743#comment-15444743
]
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=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_r76551568
--- 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_r76551557
--- 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=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_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=15444782#comment-15444782
]
ASF GitHub Bot commented on FLINK-3920:
---
Github user chiwanpark commented on a diff
[
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
51 matches
Mail list logo
