[
https://issues.apache.org/jira/browse/FLINK-3247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110312#comment-15110312
]
Robert Metzger commented on FLINK-3247:
---
I'm not sure, even with Maven 3.0.4, maven
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1528#issuecomment-173509879
Sure makes sense :-)
On Jan 20, 2016 7:23 PM, "Stephan Ewen" wrote:
> Trigger was a mail from Theo on the ML where deserialization failes in the
> r
[
https://issues.apache.org/jira/browse/FLINK-3267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110317#comment-15110317
]
ASF GitHub Bot commented on FLINK-3267:
---
Github user tillrohrmann commented on the p
[
https://issues.apache.org/jira/browse/FLINK-3093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110320#comment-15110320
]
ASF GitHub Bot commented on FLINK-3093:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1428#issuecomment-173511286
Cool, thank you.
I'll rebase the PR, and go over the APIs again as well
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1531#discussion_r50376595
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala ---
@@ -71,12 +71,11 @@ package object scala {
"supported on Case
Github user sksamuel commented on a diff in the pull request:
https://github.com/apache/flink/pull/1531#discussion_r50376844
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala ---
@@ -71,12 +71,11 @@ package object scala {
"supported on Cas
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1531#issuecomment-173515281
Wow, that was quick! :-)
Thanks for the PR and the update.
Looks good to merge, IMO
---
If your project is set up for it, you can reply to this email and have yo
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1531#issuecomment-173515454
+1 for merging. Thanks for your contribution @sksamuel :-)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
Robert Metzger created FLINK-3270:
-
Summary: Add example for reading and writing to Kafka
Key: FLINK-3270
URL: https://issues.apache.org/jira/browse/FLINK-3270
Project: Flink
Issue Type: Impr
[
https://issues.apache.org/jira/browse/FLINK-3266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110349#comment-15110349
]
Gabor Gevay commented on FLINK-3266:
They have names like `ForkJoinPool-168-worker-3`
[
https://issues.apache.org/jira/browse/FLINK-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110362#comment-15110362
]
Till Rohrmann commented on FLINK-2321:
--
You're right [~tvas]. I'll correct it.
> The
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50381597
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/util/HashVsSortMiniBenchmark.java
---
@@ -184,7 +184,7 @@ public void testBuildFirst
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110380#comment-15110380
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50382852
--- Diff: docs/libs/ml/optimization.md ---
@@ -256,6 +271,79 @@ The full list of supported prediction functions can be
found [here](#prediction-
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50382898
--- Diff: docs/libs/ml/optimization.md ---
@@ -256,6 +271,79 @@ The full list of supported prediction functions can be
found [here](#prediction-
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110390#comment-15110390
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1347#issuecomment-173528182
Closing for now, I have a bigger PR coming up
---
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 pr
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110391#comment-15110391
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user aljoscha closed the pull request at:
https://github.com/apache/flink/pull/1347
---
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 en
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50382914
--- Diff: docs/libs/ml/optimization.md ---
@@ -256,6 +271,79 @@ The full list of supported prediction functions can be
found [here](#prediction-
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110389#comment-15110389
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50382928
--- Diff: docs/libs/ml/optimization.md ---
@@ -256,6 +271,79 @@ The full list of supported prediction functions can be
found [here](#prediction-
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110392#comment-15110392
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1532
[hotfix] Fix interaction of Async calls/checkpointing/canceling
Before, it could happen that a Task is canceled during snapshotting.
Some State Backends would silently swallow exceptions resulti
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110397#comment-15110397
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50383721
--- Diff: docs/libs/ml/optimization.md ---
@@ -256,6 +271,79 @@ The full list of supported prediction functions can be
found [here](#prediction-
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110399#comment-15110399
]
Maximilian Michels commented on FLINK-2972:
---
I think we will have to add a const
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50384749
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java
---
@@ -486,11 +518,43 @@ protected boolean processProbeI
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110405#comment-15110405
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1533
[FLINK-3270] Add Kafka example
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink3270
Alternatively you can review and apply
Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/1529#issuecomment-173533784
I agree it would be nice to fix the Scala dependency of `flink-java` before
merging. Let's try to find a solution.
---
If your project is set up for it, you can reply to th
[
https://issues.apache.org/jira/browse/FLINK-3270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110410#comment-15110410
]
ASF GitHub Bot commented on FLINK-3270:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110409#comment-15110409
]
ASF GitHub Bot commented on FLINK-2933:
---
Github user mxm commented on the pull reque
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-3265:
-
Assignee: Robert Metzger
> RabbitMQ Source not threadsafe: ConcurrentModificationExceptio
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50385614
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java
---
@@ -1558,7 +1641,209 @@ public void reset() {
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110415#comment-15110415
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50385880
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashFullOuterJoinBuildFirstDescriptor.java
---
@@ -0,0 +1,66 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50385924
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashFullOuterJoinBuildSecondDescriptor.java
---
@@ -0,0 +1,65 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110416#comment-15110416
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110418#comment-15110418
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110420#comment-15110420
]
Maximilian Michels commented on FLINK-2972:
---
Seems like this doesn't work for so
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1534
[FLINK-3265] Make RabbitMQ source threadsafe
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmetzger/flink flink3265
Alternatively you can re
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger updated FLINK-3265:
--
Component/s: Streaming Connectors
> RabbitMQ Source not threadsafe: ConcurrentModificationExcept
[
https://issues.apache.org/jira/browse/FLINK-3265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110450#comment-15110450
]
ASF GitHub Bot commented on FLINK-3265:
---
GitHub user rmetzger opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110452#comment-15110452
]
Robert Metzger commented on FLINK-2973:
---
[~fhueske]: I think we can close this issue
[
https://issues.apache.org/jira/browse/FLINK-3065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110453#comment-15110453
]
Robert Metzger commented on FLINK-3065:
---
I think this issue is resolved and can be c
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50389332
--- Diff: docs/libs/ml/optimization.md ---
@@ -256,6 +271,79 @@ The full list of supported prediction functions can be
found [here](#prediction-
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110455#comment-15110455
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110458#comment-15110458
]
ASF GitHub Bot commented on FLINK-2972:
---
GitHub user mxm opened a pull request:
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/1535
[FLINK-2972] remove Chill dependency from the test scope
This eliminates the last bit of the Scala dependency of `flink-java`. If
the Chill library can't be found it is replaced by one of the default Kr
[
https://issues.apache.org/jira/browse/FLINK-3065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110460#comment-15110460
]
Ufuk Celebi commented on FLINK-3065:
I think you've resolved it with the Curator chang
[
https://issues.apache.org/jira/browse/FLINK-2973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110461#comment-15110461
]
Fabian Hueske commented on FLINK-2973:
--
Well, the intention was to re-add these bench
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50390580
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/HashTableITCase.java
---
@@ -1534,6 +1534,106 @@ public void testBucketsNotFulf
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110465#comment-15110465
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50390858
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/hash/HashTableITCase.java
---
@@ -1534,6 +1534,106 @@ public void testBucketsNotFulf
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110468#comment-15110468
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
GitHub user stefanobaghino opened a pull request:
https://github.com/apache/flink/pull/1536
[FLINK-2021] Rework examples to use ParameterTool (K-Means)
I've reworked the K-Means examples in Java and Scala to get a feeling of
what it would mean on the whole examples code base. Just a
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110469#comment-15110469
]
ASF GitHub Bot commented on FLINK-2021:
---
GitHub user stefanobaghino opened a pull re
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50391112
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala
---
@@ -107,6 +107,11 @@ class MultipleLin
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110471#comment-15110471
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110472#comment-15110472
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1469#discussion_r50391192
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java
---
@@ -486,11 +518,43 @@ protected boolean processProbeI
[
https://issues.apache.org/jira/browse/FLINK-2871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110473#comment-15110473
]
ASF GitHub Bot commented on FLINK-2871:
---
Github user fhueske commented on the pull r
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1469#issuecomment-173547539
Thanks for the update and the regression test @ChengXiangLi!
Looks good, only minor changes to do, IMO.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110476#comment-15110476
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50391309
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala
---
@@ -107,6 +107,11 @@ class MultipleLin
[
https://issues.apache.org/jira/browse/FLINK-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110498#comment-15110498
]
ramkrishna.s.vasudevan commented on FLINK-3135:
---
Ping for reviews!!
> Add
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50394492
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala
---
@@ -107,6 +107,11 @@ class MultipleLinea
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110507#comment-15110507
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50394801
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -291,31 +297,54 @@ public Centroi
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50394812
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
---
@@ -104,36 +105,52 @@ object KMea
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110516#comment-15110516
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110514#comment-15110514
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50394888
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
---
@@ -104,36 +105,52 @@ object KMea
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110519#comment-15110519
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110520#comment-15110520
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50395017
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -291,31 +297,54 @@ public Centroi
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50395062
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
---
@@ -104,36 +105,52 @@ object KMea
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110521#comment-15110521
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user chiwanpark commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110525#comment-15110525
]
ramkrishna.s.vasudevan commented on FLINK-2168:
---
Is there any one working on
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110534#comment-15110534
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user chiwanpark commented on a diff
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50395674
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -291,31 +297,54 @@ public Centroi
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50399418
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -291,31 +297,54 @@ public Cen
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110570#comment-15110570
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on a d
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110574#comment-15110574
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on a d
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50399628
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
---
@@ -104,36 +105,52 @@ object
Github user stefanobaghino commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50400122
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/clustering/KMeans.scala
---
@@ -104,36 +105,52 @@ object
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110577#comment-15110577
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user stefanobaghino commented on a d
Github user ggevay commented on the pull request:
https://github.com/apache/flink/pull/1517#issuecomment-173571311
I've fixed a minor issue related to closing the table, and improved some
comments.
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-2237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110576#comment-15110576
]
ASF GitHub Bot commented on FLINK-2237:
---
Github user ggevay commented on the pull re
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50401269
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -291,31 +297,54 @@ public Centroid
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110591#comment-15110591
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on a diff in
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1397#issuecomment-173573669
I had some minor comments. I also opened a PR against your branch
@rawkintrevo which shows how one could solve the problem with the enumerations
(https://github.com
[
https://issues.apache.org/jira/browse/FLINK-2021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110599#comment-15110599
]
ASF GitHub Bot commented on FLINK-2021:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1536#discussion_r50401470
--- Diff:
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/clustering/KMeans.java
---
@@ -291,31 +297,54 @@ public Centroid
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110598#comment-15110598
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on the p
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1397#discussion_r50401844
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/regression/MultipleLinearRegression.scala
---
@@ -107,6 +107,11 @@ class MultipleLin
[
https://issues.apache.org/jira/browse/FLINK-1994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110605#comment-15110605
]
ASF GitHub Bot commented on FLINK-1994:
---
Github user tillrohrmann commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15110607#comment-15110607
]
Fabian Hueske commented on FLINK-2168:
--
The internals of the Table API are currently
1 - 100 of 166 matches
Mail list logo
