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
[
https://issues.apache.org/jira/browse/FLINK-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496157#comment-14496157
]
ASF GitHub Bot commented on FLINK-1655:
---
Github user akshaydixi closed the pull
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 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
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_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_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_r28412749
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/StandardScaler.scala
---
@@ -0,0 +1,178 @@
+/*
+ * Licensed to
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
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
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14496299#comment-14496299
]
Akshay Dixit commented on FLINK-1869:
-
Hi, I'd like to take a crack at this issue if
[
https://issues.apache.org/jira/browse/FLINK-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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-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-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.
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
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496862#comment-14496862
]
ASF GitHub Bot commented on FLINK-1753:
---
GitHub user rmetzger opened a pull request:
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
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
[
https://issues.apache.org/jira/browse/FLINK-1753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14496993#comment-14496993
]
ASF GitHub Bot commented on FLINK-1753:
---
Github user rmetzger commented on the pull
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
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
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
[
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 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
[
https://issues.apache.org/jira/browse/FLINK-1891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14495989#comment-14495989
]
ASF GitHub Bot commented on FLINK-1891:
---
GitHub user matadorhong opened a pull
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
27 matches
Mail list logo