[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15587764#comment-15587764
]
Gabor Gevay edited comment on FLINK-3999 at 10/19/16 5:47 AM:
--
Won't Fix; See
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabor Gevay resolved FLINK-3999.
Resolution: Won't Fix
See comment here:
Github user ggevay commented on the issue:
https://github.com/apache/flink/pull/2642
OK, I see your point now @StephanEwen.
@nssalian, I'm sorry for opening the jira; I didn't think it through from
this perspective at the time.
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15587758#comment-15587758
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user ggevay commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaowei Jiang updated FLINK-4854:
-
Component/s: DataStream API
> Efficient Batch Operator in Streaming
>
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15587389#comment-15587389
]
Tzu-Li (Gordon) Tai commented on FLINK-4727:
Resolved for master via
Xiaogang Shi created FLINK-4856:
---
Summary: Add MapState for keyed streams
Key: FLINK-4856
URL: https://issues.apache.org/jira/browse/FLINK-4856
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15587370#comment-15587370
]
ASF GitHub Bot commented on FLINK-4727:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2585
---
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-4727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15587354#comment-15587354
]
ASF GitHub Bot commented on FLINK-4727:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2585
The failing tests are unrelated, and related tests are covered and have
passed. Merging this ...
---
If your project is set up for it, you can reply to this email and have your
reply appear on
Xiaowei Jiang created FLINK-4855:
Summary: Add partitionedKeyBy to DataStream
Key: FLINK-4855
URL: https://issues.apache.org/jira/browse/FLINK-4855
Project: Flink
Issue Type: Improvement
Xiaowei Jiang created FLINK-4854:
Summary: Efficient Batch Operator in Streaming
Key: FLINK-4854
URL: https://issues.apache.org/jira/browse/FLINK-4854
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586694#comment-15586694
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user nssalian commented on the issue:
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2642
@StephanEwen ,thanks for that, that makes sense. But it is hard for someone
new to understand the problem you mention. If someone familiar with the
product, could review new JIRAs for clear benefit
[
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 evaluate operation is defined for Vector and not LabeledVector.
It
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586580#comment-15586580
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2642
I am a bit skeptical about these types of changes.
Maintaining stability of Flink is crucially important now. With changes
like these we risk introducing subtle bugs without fixing a bug
[
https://issues.apache.org/jira/browse/FLINK-3930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586564#comment-15586564
]
ASF GitHub Bot commented on FLINK-3930:
---
Github user vijikarthi commented on the issue:
Github user vijikarthi commented on the issue:
https://github.com/apache/flink/pull/2425
Resolved merge conflicts and squashed commits to rebase with master
---
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-4846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas FOURNIER closed FLINK-4846.
--
Resolution: Invalid
> FlinkML - Pass "env" has an implicit parameter in MLUtils.readLibSVM
>
[
https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-4852:
---
Assignee: Aljoscha Krettek
> ClassCastException when assigning Watermarks with
>
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586082#comment-15586082
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2652
Concerning the Kafka test: From the logs, the test fails because a topic
cannot be deleted. The ZooKeeper operation blocks and test times out. I am
pretty sure that this is unrelated, as no
[
https://issues.apache.org/jira/browse/FLINK-4445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15586067#comment-15586067
]
Stephan Ewen commented on FLINK-4445:
-
+1 for option (1)
> Ignore unmatched state when restoring from
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585948#comment-15585948
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2652
Travis gives the green light except for a Kafka failure. @StephanEwen
@rmetzger Do you know whether this is a known issue? Or might it be a
regression from this change?
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/2656
[FLINK-4852] Remove Non-Multiplexing StreamRecordSerializer
This is getting rid of a source `ClassCastExceptions` that cropped up
several times now. We simply always to the multiplexing now which
[
https://issues.apache.org/jira/browse/FLINK-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585929#comment-15585929
]
ASF GitHub Bot commented on FLINK-4852:
---
GitHub user aljoscha opened a pull request:
Github user nssalian commented on the issue:
https://github.com/apache/flink/pull/2642
@ggevay they are not related.. I think it caught from me old branch on to
this one. The 3 in the middle2ef4401,46d91b0,1433a5d are
relevant here. Apologies for the mix up.
[
https://issues.apache.org/jira/browse/FLINK-3999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585754#comment-15585754
]
ASF GitHub Bot commented on FLINK-3999:
---
Github user nssalian commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585716#comment-15585716
]
Gábor Hermann commented on FLINK-1807:
--
Thanks for your reply!
Then, if I understand you correctly,
Till Rohrmann created FLINK-4853:
Summary: Clean up JobManager registration at the ResourceManager
Key: FLINK-4853
URL: https://issues.apache.org/jira/browse/FLINK-4853
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585619#comment-15585619
]
Ted Yu commented on FLINK-4499:
---
+1 on starting with a very small set of rules
> Introduce findbugs maven
Maximilian Michels created FLINK-4852:
-
Summary: ClassCastException when assigning Watermarks with
TimeCharacteristic.ProcessingTime
Key: FLINK-4852
URL: https://issues.apache.org/jira/browse/FLINK-4852
[
https://issues.apache.org/jira/browse/FLINK-4512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4512.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Implemented in fd410d9 (master).
> Add option for
[
https://issues.apache.org/jira/browse/FLINK-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4507.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in fd410d9 (master).
> Deprecate savepoint backend
[
https://issues.apache.org/jira/browse/FLINK-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-4509.
--
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in fd410d9 (master).
> Specify savepoint directory
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2655
[FLINK-4851] [rm] Introduce FatalErrorHandler and MetricRegistry to RM
This PR is based on #2651
This PR introduces a `FatalErrorHandler` and the `MetricRegistry` to the
RM. The
[
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
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585571#comment-15585571
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ggevay commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585561#comment-15585561
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585556#comment-15585556
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585554#comment-15585554
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585564#comment-15585564
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585557#comment-15585557
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
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=15585562#comment-15585562
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585559#comment-15585559
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
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=15585558#comment-15585558
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
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 @@
+/*
+ *
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=15585563#comment-15585563
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1558#comment-1558
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585560#comment-15585560
]
ASF GitHub Bot commented on FLINK-3674:
---
Github user StefanRRichter commented on a diff in the pull
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 @@
+/*
+ *
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 @@
+/*
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 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-3322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585514#comment-15585514
]
ASF GitHub Bot commented on FLINK-3322:
---
Github user ramkrish86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585538#comment-15585538
]
ASF GitHub Bot commented on FLINK-4851:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585534#comment-15585534
]
Maximilian Michels commented on FLINK-4829:
---
To mitigate the problem, we have best-effort
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
[
https://issues.apache.org/jira/browse/FLINK-4829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585520#comment-15585520
]
ASF GitHub Bot commented on FLINK-4829:
---
Github user asfgit closed the pull request at:
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
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585425#comment-15585425
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
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
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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585403#comment-15585403
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585380#comment-15585380
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
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`,
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585352#comment-15585352
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585346#comment-15585346
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585344#comment-15585344
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-1807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585342#comment-15585342
]
Till Rohrmann commented on FLINK-1807:
--
This could work as a workaround but I think it's not 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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585332#comment-15585332
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the pull request:
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() {
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()
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585325#comment-15585325
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585320#comment-15585320
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585309#comment-15585309
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on a diff in the pull
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=15585283#comment-15585283
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen 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
[
https://issues.apache.org/jira/browse/FLINK-4715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585275#comment-15585275
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user uce commented on the issue:
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
[
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
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
1 - 100 of 145 matches
Mail list logo
