Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/629#discussion_r29834901
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/metrics/distances/CosineDistanceMeasure.scala
---
@@ -0,0 +1,45 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532283#comment-14532283
]
ASF GitHub Bot commented on FLINK-1933:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532341#comment-14532341
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532339#comment-14532339
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
Github user chiwanpark commented on a diff in the pull request:
https://github.com/apache/flink/pull/629#discussion_r29837576
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/metrics/distances/CosineDistanceMeasure.scala
---
@@ -0,0 +1,45 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532352#comment-14532352
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532355#comment-14532355
]
ASF GitHub Bot commented on FLINK-951:
--
Github user rmetzger commented on the pull
[
https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532189#comment-14532189
]
ASF GitHub Bot commented on FLINK-1978:
---
Github user aljoscha commented on the pull
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/655#issuecomment-99757603
Looks good. Can you go ahead and merge 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
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/652#discussion_r29828989
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/SerializedJobExecutionResult.java
---
@@ -63,6 +64,17 @@ public long getNetRuntime() {
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1731:
-
Description:
The Flink repository already contains a kMeans implementation but it is not yet
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532224#comment-14532224
]
PJ Van Aeken commented on FLINK-1962:
-
If there are no problems, feel free to push it.
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532215#comment-14532215
]
Till Rohrmann commented on FLINK-1731:
--
Great to hear that you guys will pick up this
Github user bhatsachin commented on the pull request:
https://github.com/apache/flink/pull/553#issuecomment-99786510
Hey Robert, please correct me if I am wrong. According to this doc,
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532327#comment-14532327
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532326#comment-14532326
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29836966
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/RegularizationType.scala
---
@@ -0,0 +1,171 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532175#comment-14532175
]
Robert Metzger commented on FLINK-964:
--
Yes, we can close this issue.
One of the
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532197#comment-14532197
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/553#issuecomment-99759058
That would be more javaesque than scalaesque. I would rather move the
osMXBean retrieval into the map function of the `fetchCPULoad` option. That
also solves the
[
https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532206#comment-14532206
]
ASF GitHub Bot commented on FLINK-1974:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532261#comment-14532261
]
Till Rohrmann commented on FLINK-1719:
--
Hi [~JonathanH5], could you set the status of
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/553#issuecomment-99787426
Okay, you are right. Then we can keep it this way.
Let me try out your changes one more time, but then I think we are good to
merge.
---
If your project is set
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/652#discussion_r29831647
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/JobExecutionResult.java ---
@@ -47,12 +48,23 @@ public JobExecutionResult(JobID jobID,
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29837206
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/RegularizationType.scala
---
@@ -0,0 +1,171 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-964.
--
Resolution: Won't Fix
Integrate profiling code with web interface
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1731:
-
Description:
The Flink repository already contains a kMeans implementation but it is not yet
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532303#comment-14532303
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user rmetzger commented on the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29837444
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/Solver.scala
---
@@ -0,0 +1,146 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-1792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532173#comment-14532173
]
ASF GitHub Bot commented on FLINK-1792:
---
Github user rmetzger commented on the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/553#issuecomment-99753925
The code looks much better now. The only thing that makes me still unhappy
is the following method
```diff
+ override def getValue: Double = {
+
[
https://issues.apache.org/jira/browse/FLINK-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532251#comment-14532251
]
Till Rohrmann commented on FLINK-1735:
--
Hi [~Felix Neutatz],
great to see that you
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29836296
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/GradientDescent.scala
---
@@ -0,0 +1,254 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-1731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1731:
-
Description:
The Flink repository already contains a kMeans implementation but it is not yet
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29837353
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/RegularizationType.scala
---
@@ -0,0 +1,171 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532320#comment-14532320
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29836811
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/RegularizationType.scala
---
@@ -0,0 +1,171 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532356#comment-14532356
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on the
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/613#issuecomment-99798430
I had only some minor comments. Ping me once you have addressed them. And I
noticed that there are no unit tests for the `PredictionFunction`. Maybe you
can add one.
[
https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14533134#comment-14533134
]
ASF GitHub Bot commented on FLINK-1974:
---
Github user jkirsch commented on the pull
Github user jkirsch commented on the pull request:
https://github.com/apache/flink/pull/652#issuecomment-99967606
I updated to reflect the new name `getNetRuntime` and also reverted the
change which reported the seconds instead of milliseconds.
---
If your project is set up for it,
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14533220#comment-14533220
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user mbalassi commented on the pull
Github user mbalassi commented on the pull request:
https://github.com/apache/flink/pull/659#issuecomment-99984916
@aljoscha I think we have two options:
* Those sources with return constant false in reachedEnd() and killed
externally when the user desires to do so.
*
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/662#issuecomment-14988
+1 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 feature
[
https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14533312#comment-14533312
]
ASF GitHub Bot commented on FLINK-1987:
---
Github user rmetzger commented on the pull
GitHub user andralungu opened a pull request:
https://github.com/apache/flink/pull/662
[FLINK-1987][docs] Fixed broken links
The two html links I replaced were never actually written. In any flink
release. In my opinion it is better to omit this information than to point the
user
[
https://issues.apache.org/jira/browse/FLINK-1987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14533307#comment-14533307
]
ASF GitHub Bot commented on FLINK-1987:
---
GitHub user andralungu opened a pull
Andra Lungu created FLINK-1987:
--
Summary: Broken links in the add_operator section of the
documentation
Key: FLINK-1987
URL: https://issues.apache.org/jira/browse/FLINK-1987
Project: Flink
Fabian Hueske created FLINK-1991:
Summary: Return Table as DataSetTuple
Key: FLINK-1991
URL: https://issues.apache.org/jira/browse/FLINK-1991
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra resolved FLINK-1603.
--
Resolution: Fixed
Looks like it is fixed in main website as part of overhaul
Update how to
Henry Saputra created FLINK-1988:
Summary: Port Record API based tests in the common.io
Key: FLINK-1988
URL: https://issues.apache.org/jira/browse/FLINK-1988
Project: Flink
Issue Type:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/657
---
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 the pull request:
https://github.com/apache/flink/pull/629#issuecomment-99785066
@chiwanpark, looks really good. I had only one comment concerning the
cosine distance.
Furthermore, I was wondering whether we should rename
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532289#comment-14532289
]
ASF GitHub Bot commented on FLINK-1933:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532314#comment-14532314
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532329#comment-14532329
]
ASF GitHub Bot commented on FLINK-1807:
---
Github user tillrohrmann commented on a
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/613#discussion_r29837033
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/optimization/RegularizationType.scala
---
@@ -0,0 +1,171 @@
+/*
+ * Licensed
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/629#issuecomment-99803191
Ping me once you've renamed the classes, then I'll merge the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on
GitHub user jojo19893 opened a pull request:
https://github.com/apache/flink/pull/656
Lossfunctions
We added Logistic Loss Functions and Hinge Loss to the Optimazation
Framework.
See for the implemented Functions:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/659
[FLINK-1977] Rework Stream Operators to always be push based
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink event-time
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532539#comment-14532539
]
ASF GitHub Bot commented on FLINK-1977:
---
GitHub user aljoscha opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532396#comment-14532396
]
ASF GitHub Bot commented on FLINK-1933:
---
Github user chiwanpark commented on the
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/660
[hotfix][scala] Let type analysis work on some Java types
This is mostly to allow Vertex, which is a Java Tuple2 to be used in
the Scala Gelly API.
You can merge this pull request into a Git
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532391#comment-14532391
]
ASF GitHub Bot commented on FLINK-1933:
---
Github user chiwanpark commented on the
[
https://issues.apache.org/jira/browse/FLINK-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532390#comment-14532390
]
ASF GitHub Bot commented on FLINK-1933:
---
Github user chiwanpark commented on the
Github user chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/629#issuecomment-99803730
@tillrohrmann I just renamed the classes. :)
---
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 chiwanpark commented on the pull request:
https://github.com/apache/flink/pull/629#issuecomment-99803806
Oh, the commit logs contains distance measure. I will fix them.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532401#comment-14532401
]
Johannes Günther commented on FLINK-1979:
-
Okay I changed the Pull request to the
[
https://issues.apache.org/jira/browse/FLINK-1978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-1978:
-
Fix Version/s: 0.8.2
POJO serialization NPE
--
Key:
GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/657
[gelly] removes generic type constraints
As per discussion in
[FLINK-1962](https://issues.apache.org/jira/browse/FLINK-1962), I removed the
generic type constraints from the Gelly API.
This will
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532490#comment-14532490
]
ASF GitHub Bot commented on FLINK-1962:
---
GitHub user vasia opened a pull request:
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/629#discussion_r29839310
--- Diff:
flink-staging/flink-ml/src/main/scala/org/apache/flink/ml/math/metrics/distances/CosineDistanceMeasure.scala
---
@@ -0,0 +1,45 @@
+/*
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/629#issuecomment-99805451
Great. I'll merge it then.
---
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-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532402#comment-14532402
]
ASF GitHub Bot commented on FLINK-1933:
---
Github user tillrohrmann commented on the
[
https://issues.apache.org/jira/browse/FLINK-1979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532398#comment-14532398
]
ASF GitHub Bot commented on FLINK-1979:
---
GitHub user jojo19893 opened a pull
[
https://issues.apache.org/jira/browse/FLINK-1974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532458#comment-14532458
]
ASF GitHub Bot commented on FLINK-1974:
---
Github user jkirsch commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532547#comment-14532547
]
Till Rohrmann commented on FLINK-1735:
--
I guess that a tokenizer/sentence splitter
[
https://issues.apache.org/jira/browse/FLINK-1962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532562#comment-14532562
]
Aljoscha Krettek commented on FLINK-1962:
-
I have a pending pull request that
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532593#comment-14532593
]
ASF GitHub Bot commented on FLINK-1977:
---
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/659#discussion_r29850458
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/KafkaSource.java
---
@@
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29850741
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/KafkaSource.java
---
@@
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29851342
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/kafka/api/KafkaSource.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532612#comment-14532612
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29851632
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -36,9
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532674#comment-14532674
]
ASF GitHub Bot commented on FLINK-1977:
---
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/659#discussion_r29854075
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java
---
@@ -17,33 +17,56
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29854889
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OutputHandler.java
---
@@ -210,4 +210,36
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532695#comment-14532695
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user rmetzger commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29854824
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/TwoInputStreamOperator.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532697#comment-14532697
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user mbalassi commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532696#comment-14532696
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532699#comment-14532699
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user mbalassi commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532703#comment-14532703
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29854565
--- Diff:
flink-staging/flink-streaming/flink-streaming-connectors/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeSource.java
---
@@ -1,149
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29855036
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/windowing/StreamDiscretizer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532705#comment-14532705
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user mbalassi commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29855104
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/operators/co/CoStreamWindow.java
---
@@ -174,21
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532708#comment-14532708
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user rmetzger commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14532707#comment-14532707
]
ASF GitHub Bot commented on FLINK-1977:
---
Github user aljoscha commented on a diff in
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/659#discussion_r29855250
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java
---
@@ -0,0
1 - 100 of 234 matches
Mail list logo
