[
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
[
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_r83855317
--- 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_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_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-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-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
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-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-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-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
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
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 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-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,
[
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:
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.
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=15586082#comment-15586082
]
ASF GitHub Bot commented on FLINK-4715:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584570#comment-15584570
]
zhuhaifeng commented on FLINK-4840:
---
The TPS is numRecordsInPerSecond, is it will be add into with
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584576#comment-15584576
]
zhuhaifeng commented on FLINK-4840:
---
I agree with you, I will modify this jira and add the throughput
[
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
>
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-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:
[
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
>
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-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 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-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:
[
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-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584635#comment-15584635
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on the issue:
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2653
Because SQL doesn't have standard user-defined table function, we introduce
MS SQL Server's `CROSS/OUTER APPLY` to support UDTF , see
[
https://issues.apache.org/jira/browse/FLINK-4840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15584669#comment-15584669
]
Chesnay Schepler commented on FLINK-4840:
-
That's a good point about the capacity. Can you go into
[
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:
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=15587389#comment-15587389
]
Tzu-Li (Gordon) Tai commented on FLINK-4727:
Resolved for master via
[
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
>
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-4854:
Summary: Efficient Batch Operator in Streaming
Key: FLINK-4854
URL: https://issues.apache.org/jira/browse/FLINK-4854
Project: Flink
Issue Type: Improvement
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
[
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
101 - 145 of 145 matches
Mail list logo
