Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93653375
Haha no problem. I will make sure it is more reviewable in the future PRs.
---
If your project is set up for it, you can reply to this email and have your
reply appear on G
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93653085
Ah yes, it should be fine. I should have replied this as more generic
comment for future PRs.
Sorry if I confused you @gyfora
---
If your project is set up for
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93652334
It is already merged.
---
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 fea
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93635634
This is great patch, but as @mxm mentioned before, it almost impossible to
review patches with this size.
If the PR could not be chopped into separate PRs, lets t
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496993#comment-14496993
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/603#issuecomment-93568853
The failed test has been resolved.
---
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 no
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
niraj rai reassigned FLINK-992:
---
Assignee: niraj rai (was: Henry Saputra)
> Create CollectionDataSets by reading (client) local files.
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
niraj rai reassigned FLINK-1818:
Assignee: niraj rai
> Provide API to cancel running job
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496862#comment-14496862
]
ASF GitHub Bot commented on FLINK-1753:
---
GitHub user rmetzger opened a pull request:
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/603
[FLINK-1753] Extend KafkaITCase, reworked PersistentKafkaSource (initially)
Added large messages test and reworked PersistentKafkaSource.
A Flink user I'm talking with offline is affected by
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496492#comment-14496492
]
Henry Saputra commented on FLINK-992:
-
HI [~nrai], yes you could start working on this
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496378#comment-14496378
]
niraj rai commented on FLINK-992:
-
Hi, if no one is working, I can work on this.
> Create
[
https://issues.apache.org/jira/browse/FLINK-1869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496299#comment-14496299
]
Akshay Dixit commented on FLINK-1869:
-
Hi, I'd like to take a crack at this issue if n
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/602#issuecomment-93406145
Looks good to merge
---
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 fea
GitHub user akshaydixi opened a pull request:
https://github.com/apache/flink/pull/602
fixed a few typos in internal_general_arch.md
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/akshaydixi/flink typo
Alternatively you can rev
[
https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14496157#comment-14496157
]
ASF GitHub Bot commented on FLINK-1655:
---
Github user akshaydixi closed the pull requ
Github user akshaydixi closed the pull request at:
https://github.com/apache/flink/pull/508
---
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 tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412522
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412479
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412920
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412288
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412374
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412749
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r28412028
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
GitHub user matadorhong opened a pull request:
https://github.com/apache/flink/pull/601
[FLINK-1891]Add the input storageDirectory empty check
Add the input storageDirectory empty check, if input of storageDirectory is
empty, we should use tmp as the base dir
And also fix the co
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14495989#comment-14495989
]
ASF GitHub Bot commented on FLINK-1891:
---
GitHub user matadorhong opened a pull reque
Sibao Hong created FLINK-1891:
-
Summary: Add isEmpty check when the input dir
Key: FLINK-1891
URL: https://issues.apache.org/jira/browse/FLINK-1891
Project: Flink
Issue Type: Bug
Compon
[
https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1655.
---
Resolution: Done
> Rename StreamInvokable to StreamOperator
>
[
https://issues.apache.org/jira/browse/FLINK-1876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora resolved FLINK-1876.
---
Resolution: Done
> Refactor StreamGraph to be node centric
> ---
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/594
---
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 enabl
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93270919
+1 for merge
On Apr 15, 2015 10:44 AM, "Gyula Fora" wrote:
> I will merge this later today if no objections .
>
> â
> Reply to this email direct
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/595#issuecomment-93265798
Yes @hsaputra. One of the goals is to support resume/recovery of a job from
an intermediate result already produced. Another goal is to rework the deploy
logic of the `Executi
Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/594#issuecomment-93264219
I will merge this later today if no objections .
---
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
33 matches
Mail list logo
