[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14486156#comment-14486156
]
ASF GitHub Bot commented on FLINK-1694:
---
Github user vasia commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14486461#comment-14486461
]
ASF GitHub Bot commented on FLINK-1670:
---
Github user mbalassi commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14486464#comment-14486464
]
ASF GitHub Bot commented on FLINK-1670:
---
Github user mbalassi commented on a diff in
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/547#issuecomment-91048962
Thanks so much for the review @fhueske, @StephanEwen!
I'll make the suggested changes and merge :-)
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14486181#comment-14486181
]
Gyula Fora commented on FLINK-1793:
---
I pushed a fix to a bug in the file source
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/581#discussion_r28028612
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
---
@@ -1165,6 +1168,7
Márton Balassi created FLINK-1849:
-
Summary: Refactor StreamingRuntimeContext
Key: FLINK-1849
URL: https://issues.apache.org/jira/browse/FLINK-1849
Project: Flink
Issue Type: Improvement
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/581#issuecomment-91082306
Thanks for picking up the issue, @ggevay. I would like to add to the list
Stephan mentioned:
I personally prefer the name collect for the method, it can still
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/547#issuecomment-90883704
I like the change as well! Good to go!
---
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
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485092#comment-14485092
]
ASF GitHub Bot commented on FLINK-1694:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-1319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485131#comment-14485131
]
Stephan Ewen commented on FLINK-1319:
-
In principle this is good, but I would put it
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485164#comment-14485164
]
Stephan Ewen commented on FLINK-1818:
-
This is basically a simple addition to the
[
https://issues.apache.org/jira/browse/FLINK-1812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485167#comment-14485167
]
Stephan Ewen commented on FLINK-1812:
-
Exactly. The wrapping shell script would
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90858070
What about the timeout? Are we confident that a longer timeout will be
sufficient a large number of possible jobs?
---
If your project is set up for it, you can reply
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/547#discussion_r27955651
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java ---
@@ -1118,30 +1119,52 @@ public boolean filter(EdgeK, EV edge) {
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/577#issuecomment-90882862
Looks good to me
---
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
Faye Beligianni created FLINK-1844:
--
Summary: Add Normaliser to ML library
Key: FLINK-1844
URL: https://issues.apache.org/jira/browse/FLINK-1844
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485084#comment-14485084
]
Stephan Ewen commented on FLINK-1843:
-
Keeping the Execution graph on the JobManager
[
https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485085#comment-14485085
]
ASF GitHub Bot commented on FLINK-1813:
---
Github user StephanEwen commented on the
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485088#comment-14485088
]
ASF GitHub Bot commented on FLINK-377:
--
Github user StephanEwen commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485163#comment-14485163
]
Stephan Ewen commented on FLINK-1819:
-
I agree, that would be a very good addition.
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485153#comment-14485153
]
Stephan Ewen commented on FLINK-1827:
-
I agree, that would be a good fix.
Is that
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1818:
Labels: starter (was: )
Provide API to cancel running job
-
[
https://issues.apache.org/jira/browse/FLINK-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485166#comment-14485166
]
Stephan Ewen commented on FLINK-1818:
-
Given that this follows the code in the
GitHub user fobeligi opened a pull request:
https://github.com/apache/flink/pull/579
Ml branch
Implementation of StandardScaler and respective tests for FLINK-1809 JIRA.
You can merge this pull request into a Git repository by running:
$ git pull
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90883545
Yeah, it happens frequently that the Java side dies without calling
`close()`, for example when the TaskManager encounters an unrecoverable error
and terminates.
Till Rohrmann created FLINK-1842:
Summary: ApplicationMaster for YARN FIFO tests does not shut down
properly
Key: FLINK-1842
URL: https://issues.apache.org/jira/browse/FLINK-1842
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485000#comment-14485000
]
ASF GitHub Bot commented on FLINK-703:
--
Github user mxm commented on the pull request:
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/572#issuecomment-90863864
Looks good @chiwanpark. Could you add some documentation besides the java
doc? For example, here:
[
https://issues.apache.org/jira/browse/FLINK-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-1832:
Assignee: Fabian Hueske
start-local.bat/start-local.sh does not work if there is a white
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90859901
I can't say for sure whether the current timeout is enough, we don't have
enough data for that.
we could make it configurable, that way a user can just increase it
[
https://issues.apache.org/jira/browse/FLINK-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484998#comment-14484998
]
ASF GitHub Bot commented on FLINK-1694:
---
Github user fhueske commented on the pull
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90865196
i guess it's nice to have in case the java side dies *somehow* without
calling close() on the java function.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485009#comment-14485009
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/570#issuecomment-90865992
Have the latest commits fixed it? :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485015#comment-14485015
]
ASF GitHub Bot commented on FLINK-951:
--
Github user uce commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485014#comment-14485014
]
ASF GitHub Bot commented on FLINK-703:
--
Github user fhueske commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484908#comment-14484908
]
ASF GitHub Bot commented on FLINK-1840:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/575
---
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
[
https://issues.apache.org/jira/browse/FLINK-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484907#comment-14484907
]
ASF GitHub Bot commented on FLINK-1832:
---
Github user asfgit closed the pull request
Maximilian Michels created FLINK-1843:
-
Summary: Job History gets cleared too fast
Key: FLINK-1843
URL: https://issues.apache.org/jira/browse/FLINK-1843
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484985#comment-14484985
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/547#discussion_r27955499
--- Diff: docs/gelly_guide.md ---
@@ -343,29 +343,86 @@ Vertex-centric Iterations
Gelly wraps Flink's [Spargel API](spargel_guide.html) to provide methods
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484980#comment-14484980
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-1840.
--
Resolution: Fixed
Fixed with 0afed4dcf9f9639fc90a8f18933be0516b9d7cd3
Job execution fails on
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90844274
The python process is now being terminated using kill -9, instead of
process.destroy(). This should prevent python processes from lingering
indefinitely.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484986#comment-14484986
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14484996#comment-14484996
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/547#issuecomment-90863498
LGTM
I browsed the diffs and didn't find anything crucial. Just a typo and one
possible simplification.
The change makes vertex iterations much easier to use
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485390#comment-14485390
]
Maximilian Michels commented on FLINK-1793:
---
Some more debug information. Upon
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973465
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973910
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973935
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973879
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485309#comment-14485309
]
Fabian Hueske commented on FLINK-1848:
--
That gives {{file:/c:/my/dir}}.
If I use that
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485320#comment-14485320
]
Maximilian Michels commented on FLINK-1793:
---
Here's an example of a cancellation
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/580#issuecomment-90949839
Fixed @hsaputra's remark.
---
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
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90903241
What does the timeout measure? The time while no data was coming? Can the
protocol send heartbeats if no data is available?
Would it be simpler to switch to
[
https://issues.apache.org/jira/browse/FLINK-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485203#comment-14485203
]
ASF GitHub Bot commented on FLINK-1823:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/580
[FLINK-1823] Remove linq from Table API documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink fix-table-doc
[
https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485217#comment-14485217
]
Stephan Ewen commented on FLINK-1847:
-
Also, {{collect}} should have parenthesis. It
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/577
---
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
[
https://issues.apache.org/jira/browse/FLINK-1813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485226#comment-14485226
]
ASF GitHub Bot commented on FLINK-1813:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485225#comment-14485225
]
Stephan Ewen commented on FLINK-1847:
-
Same holds for {{count()}}.
Both changes are
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90921879
The timeout measures how long java or python are stuck in a blocking udp
operation. this generally means how long it takes for the python side to
compute one chunk of
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-90900778
Yeah, and several minutes doesn't cut it, as we've seen. On a WordCount
example on not very large data a 5 minute timeout was not enough.
---
If your project is set up
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485182#comment-14485182
]
ASF GitHub Bot commented on FLINK-377:
--
Github user aljoscha commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485228#comment-14485228
]
Stephan Ewen commented on FLINK-1847:
-
I am actually seeing a common Scala pitfall
[
https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485260#comment-14485260
]
Fabian Hueske commented on FLINK-1848:
--
Yes, thought so as well and tried that
[
https://issues.apache.org/jira/browse/FLINK-1827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485261#comment-14485261
]
Flavio Pompermaier commented on FLINK-1827:
---
I know that the problem is in
[
https://issues.apache.org/jira/browse/FLINK-1800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485187#comment-14485187
]
ASF GitHub Bot commented on FLINK-1800:
---
Github user StephanEwen commented on the
Markus Holzemer created FLINK-1846:
--
Summary: Sinks inside of iterations
Key: FLINK-1846
URL: https://issues.apache.org/jira/browse/FLINK-1846
Project: Flink
Issue Type: Improvement
Stephan Ewen created FLINK-1847:
---
Summary: Change Scala collect() method to return a Seq
Key: FLINK-1847
URL: https://issues.apache.org/jira/browse/FLINK-1847
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485248#comment-14485248
]
ASF GitHub Bot commented on FLINK-377:
--
Github user zentol commented on the pull
Stephan Ewen created FLINK-1845:
---
Summary: NonReusingSortMergeCoGroupIterator uses
ReusingKeyGroupedIterator
Key: FLINK-1845
URL: https://issues.apache.org/jira/browse/FLINK-1845
Project: Flink
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/555#issuecomment-90901571
+1 for Ufuk's suggestion
I would remove Beta from Spargel, it is actually very stable. Question is
whether it stays or gets subsumed by Gelly
---
If your
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/564#issuecomment-90900980
Very good, +1
---
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-1841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi closed FLINK-1841.
-
Resolution: Fixed
Fix Version/s: 0.9
Fixed via b566884
WindowJoinITCase fails
[
https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485252#comment-14485252
]
Stephan Ewen commented on FLINK-1848:
-
I think that is legit. If java.net.URI rejects
[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485197#comment-14485197
]
ASF GitHub Bot commented on FLINK-377:
--
Github user StephanEwen commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485198#comment-14485198
]
Markus Holzemer commented on FLINK-1846:
I used my reworking of the iteration
Fabian Hueske created FLINK-1848:
Summary: Paths containing a Windows drive letter cannot be used in
FileOutputFormats
Key: FLINK-1848
URL: https://issues.apache.org/jira/browse/FLINK-1848
Project:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27974561
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reopened FLINK-1793:
-
Okay, this looks like the source is actually not canceled, but just waits for
the input to be
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485339#comment-14485339
]
Stephan Ewen commented on FLINK-1793:
-
Okay, this looks like the source is actually
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-1793.
-
Resolution: Not A Problem
My bad, they are cancelled eventually. It can take up to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973786
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973815
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27974957
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27975475
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
Github user hsaputra commented on the pull request:
https://github.com/apache/flink/pull/580#issuecomment-90941421
Looks like there is accidental file included in this PR:
flink-staging/flink-table/src/main/scala/org/apache/flink/api/table/Table.scala
---
If your project is set
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1793:
Priority: Critical (was: Major)
Streaming jobs can't be canceled
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-1793:
Summary: Streaming File Source cannot be canceled (was: Streaming jobs
can't be canceled)
[
https://issues.apache.org/jira/browse/FLINK-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485344#comment-14485344
]
ASF GitHub Bot commented on FLINK-1823:
---
Github user hsaputra commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485355#comment-14485355
]
Márton Balassi commented on FLINK-1793:
---
Ok, let me look into it.
Streaming File
[
https://issues.apache.org/jira/browse/FLINK-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14485278#comment-14485278
]
Stephan Ewen commented on FLINK-1848:
-
Agree...
What is the result of {{new
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973978
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27974938
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27974882
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/preprocess/Standardizer.scala
---
@@ -0,0 +1,101 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/579#discussion_r27973680
--- Diff:
flink-staging/flink-ml/src/test/scala/org/apache/flink/ml/preprocess/StandardizerSuite.scala
---
@@ -0,0 +1,189 @@
+/*
+ * Licensed to
1 - 100 of 111 matches
Mail list logo
