[
https://issues.apache.org/jira/browse/FLINK-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584809#comment-15584809
]
Jark Wu commented on FLINK-4825:
Hi [~twalthr] , I also found the result of {{CAST(TRUE AS
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83800845
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1289,113 @@ public void run() {
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83800506
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1289,113 @@ public void run() {
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83800264
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -289,6 +294,10 @@ public Task(
ConfigC
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584856#comment-15584856
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584857#comment-15584857
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584852#comment-15584852
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584855#comment-15584855
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584851#comment-15584851
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83801277
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
---
@@ -565,6 +568,50 @@ public void testOnPartitionStateUpdate(
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584854#comment-15584854
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83803660
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
---
@@ -565,6 +568,50 @@ public void testOnPartitionStateUpdate(
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83800396
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1183,47 +1220,48 @@ public String toString() {
*/
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584853#comment-15584853
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83800757
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1289,113 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER closed FLINK-4792.
--
Resolution: Fixed
> Update documentation - FlinkML/QuickStart Guide
> --
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83807199
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -804,199 +792,15 @@ public boolean restore
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584893#comment-15584893
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83807634
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/OperatorStateHandle.java
---
@@ -38,8 +38,8 @@
private final StreamStateH
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15584899#comment-15584899
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user StefanRRichter commented on a d
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/2654
[hotfix] [kafka] Fix RackAwareMode instantiation in Kafka 0.10 test
The IDE is complaining that `new kafka.admin.RackAwareMode.Enforced$()` has
private access.
Looking at Kafka's own tests
[[1
Thomas FOURNIER created FLINK-4850:
--
Summary: FlinkML - SVM predict Operation for Vector and not
LaveledVector
Key: FLINK-4850
URL: https://issues.apache.org/jira/browse/FLINK-4850
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4850:
---
Description:
It seems that SVM has predict operation for Vector and not LabeledVector.
It impa
[
https://issues.apache.org/jira/browse/FLINK-4833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585028#comment-15585028
]
Robert Metzger commented on FLINK-4833:
---
But why is the error now happening to frequ
[
https://issues.apache.org/jira/browse/FLINK-4723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585045#comment-15585045
]
Robert Metzger commented on FLINK-4723:
---
I would not merge it because of the offset
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83819873
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorStateHandles.java
---
@@ -0,0 +1,105 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585058#comment-15585058
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585088#comment-15585088
]
ASF GitHub Bot commented on FLINK-4844:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2648#discussion_r83822468
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/OneInputStreamOperatorTestHarness.java
---
@@ -199,30 +228,56 @@ public E
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585097#comment-15585097
]
Gábor Hermann commented on FLINK-1807:
--
Hi all,
I have a workaround in mind for a "r
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83824750
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1289,113 @@ public void run() {
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83824704
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1289,113 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585115#comment-15585115
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83824787
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1289,113 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585118#comment-15585118
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585117#comment-15585117
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585120#comment-15585120
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83824898
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
---
@@ -565,6 +568,50 @@ public void testOnPartitionStateUpdate() throws
[
https://issues.apache.org/jira/browse/FLINK-4283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585134#comment-15585134
]
Alexander Shoshin commented on FLINK-4283:
--
It will look like this:
https://githu
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585220#comment-15585220
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user ggevay commented on the issue:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2642
Could you please explain why are the first and last commit
(65b3ff78f100ed1b13ec2fcc727f4869823b5918 and
ba4f429043f3985db5ab37a3902a6fee15a7440e) necessary? Are they related to
FLINK-3999?
---
If
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4850:
---
Description:
It seems that SVM has predict operation for Vector and not LabeledVector.
It impa
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2652
Thanks for the valuable feedback. Some of the errors were a little sloppy
on my side. Sorry for that. I addressed all your comments.
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585275#comment-15585275
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2652
Should we have one class `TaskManagerOptions`? To not spread the config
over too many classes.
---
If your project is set up for it, you can reply to this email and have your
reply appear on Git
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585283#comment-15585283
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83839720
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1299,124 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585309#comment-15585309
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83840545
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
---
@@ -565,6 +568,128 @@ public void testOnPartitionStateUpdate
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585320#comment-15585320
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83840872
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
---
@@ -565,6 +568,128 @@ public void testOnPartitionStateUpdate() throw
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585325#comment-15585325
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83841451
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1251,33 +1299,124 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585332#comment-15585332
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/2652#discussion_r83842005
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/taskmanager/TaskTest.java
---
@@ -565,6 +568,128 @@ public void testOnPartitionStateUpdate
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585342#comment-15585342
]
Till Rohrmann commented on FLINK-1807:
--
This could work as a workaround but I think i
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585344#comment-15585344
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2652
Renamed the `TaskOptions` class to `TaskManagerOptions` so that we can
easily migrate the task manager options as a follow up.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585346#comment-15585346
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585352#comment-15585352
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2652
What do you think about a followup test, where we ensure that a fatal error
notification on the TaskManager actually results in a process kill?
---
If your project is set up for it, you can repl
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2652
We have the `TaskManagerProcessReapingTest` which tests that the
TaskManager process properly exits when the TaskManager actor dies. In
addition, there is `TaskManagerTest#testTerminationOnFatalError`, w
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585380#comment-15585380
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585403#comment-15585403
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2652
Yeah, this sort of covers it. Just afraid of such a situation here:
https://twitter.com/thepracticaldev/status/687672086152753152
---
If your project is set up for it, you can reply to this emai
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2652
Haha, that picture convinced me to actually add the test :smile:
---
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-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585425#comment-15585425
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Shoshin reassigned FLINK-2118:
Assignee: Alexander Shoshin
> Table API fails on composite filter conditions
>
Till Rohrmann created FLINK-4851:
Summary: Add FatalErrorHandler and MetricRegistry to
ResourceManager
Key: FLINK-4851
URL: https://issues.apache.org/jira/browse/FLINK-4851
Project: Flink
Is
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/2510
@ggevay
Do you have some time to check the last commit in this PR?
---
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 proj
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585520#comment-15585520
]
ASF GitHub Bot commented on FLINK-4829:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2649
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585534#comment-15585534
]
Maximilian Michels commented on FLINK-4829:
---
To mitigate the problem, we have be
[
https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585538#comment-15585538
]
ASF GitHub Bot commented on FLINK-4851:
---
GitHub user tillrohrmann opened a pull requ
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585514#comment-15585514
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ramkrish86 commented on the iss
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83855317
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/TimelyFlatMapTest.java
---
@@ -0,0 +1,442 @@
+/*
+ * Lic
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83858860
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerService.java
---
@@ -0,0 +1,60 @@
+/*
+ * L
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83860732
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/HeapInternalTimerServiceTest.java
---
@@ -0,0 +1,509 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585558#comment-15585558
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83856028
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/TimelyFlatMapTest.java
---
@@ -0,0 +1,442 @@
+/*
+ * Lic
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83859446
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,325 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585563#comment-15585563
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1558#comment-1558
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585560#comment-15585560
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83858268
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimer.java
---
@@ -0,0 +1,90 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585557#comment-15585557
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83857663
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/TimelyFlatMapFunction.java
---
@@ -0,0 +1,78 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585562#comment-15585562
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585559#comment-15585559
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585556#comment-15585556
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83860194
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
---
@@ -0,0 +1,325 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585554#comment-15585554
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83861268
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -390,4 +425,141 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585561#comment-15585561
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585564#comment-15585564
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83862277
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
---
@@ -390,4 +425,141 @@ public voi
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2510
Sorry, I'm extremely busy these days. I'm not sure when will I have time,
unfortunately.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15585571#comment-15585571
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ggevay commented on the issue:
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/2570#discussion_r83854971
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/Triggerable.java
---
@@ -15,38 +15,26 @@
* See the License
[
https://issues.apache.org/jira/browse/FLINK-4850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER updated FLINK-4850:
---
Description:
It seems that SVM has predict operation for Vector and not LabeledVector.
It impa
1 - 100 of 141 matches
Mail list logo
