Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60799066
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15254608#comment-15254608
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-213581650
Regarding the Jackson / dependency issue: You don't need to worry about it
know. I'll take another look at the problem and make sure it'll work once we
merge it.
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60799474
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60799388
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java
---
[
https://issues.apache.org/jira/browse/FLINK-3753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-3753:
--
Description:
{code}
// this is harsh, but this watchdog is a last resort
if (toKill.isAlive()) {
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15254633#comment-15254633
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15255146#comment-15255146
]
Ronak Nathani commented on FLINK-1746:
--
Thanks [~till.rohrmann]! Look forward to working on this! :)
[
https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15254984#comment-15254984
]
David E Drummond commented on FLINK-1743:
-
Thanks for the warm welcome [~trohrm...@apache.org]!
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253557#comment-15253557
]
Konstantin Knauf commented on FLINK-3669:
-
Aljoscha, could you have a look at
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1923#issuecomment-213288408
Good fix, Till! Changes look good, +1 to merge soon for 1.0.3.
---
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-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3701:
--
Fix Version/s: 1.1.0
> Cant call execute after first execution
>
[
https://issues.apache.org/jira/browse/FLINK-3701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-3701:
--
Affects Version/s: 1.1.0
> Cant call execute after first execution
>
[
https://issues.apache.org/jira/browse/FLINK-3793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri reassigned FLINK-3793:
Assignee: Vasia Kalavri
> Re-organize the Table API and SQL docs
>
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253449#comment-15253449
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user uce commented on the pull request:
Github user zentol commented on the pull request:
https://github.com/apache/flink/pull/1925#issuecomment-213315680
+1
---
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
[
https://issues.apache.org/jira/browse/FLINK-1749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1749:
-
Assignee: (was: narayana reddy)
> Add Boosting algorithm for ensemble learning to machine
[
https://issues.apache.org/jira/browse/FLINK-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253584#comment-15253584
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user rmetzger commented on the pull request:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1903#discussion_r60728363
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputFormatVertex.java
---
@@ -64,13 +65,19 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253806#comment-15253806
]
ASF GitHub Bot commented on FLINK-3754:
---
Github user yjshen commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253807#comment-15253807
]
ASF GitHub Bot commented on FLINK-3777:
---
Github user fhueske commented on a diff in the pull
Github user yjshen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1916#discussion_r60728312
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -199,12 +151,12 @@ class Table(
*
[
https://issues.apache.org/jira/browse/FLINK-1749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253589#comment-15253589
]
Till Rohrmann commented on FLINK-1749:
--
Hi [~dedrummond],
I think Narayana is no longer working on
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253666#comment-15253666
]
Aljoscha Krettek commented on FLINK-3669:
-
Hi,
it's almost done but I think we need both the
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60726049
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253808#comment-15253808
]
ASF GitHub Bot commented on FLINK-3754:
---
Github user yjshen commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253601#comment-15253601
]
Aljoscha Krettek commented on FLINK-3669:
-
I'm checking it out.
> WindowOperator registers a lot
Aljoscha Krettek created FLINK-3803:
---
Summary: Checkpoint Stats Tracker Reads from Wrong Configuration
Key: FLINK-3803
URL: https://issues.apache.org/jira/browse/FLINK-3803
Project: Flink
Github user yjshen commented on a diff in the pull request:
https://github.com/apache/flink/pull/1916#discussion_r60728611
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/operators.scala
---
@@ -0,0 +1,188 @@
+/*
+ * Licensed
Till Rohrmann created FLINK-3804:
Summary: Update YARN documentation
Key: FLINK-3804
URL: https://issues.apache.org/jira/browse/FLINK-3804
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253665#comment-15253665
]
Till Rohrmann commented on FLINK-1729:
--
Hi [~h...@insightdatascience.com],
great to hear that you
[
https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1729:
-
Assignee: hoa nguyen (was: Till Rohrmann)
> Assess performance of classification algorithms
>
[
https://issues.apache.org/jira/browse/FLINK-1729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-1729:
Assignee: Till Rohrmann
> Assess performance of classification algorithms
>
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1903#issuecomment-213399764
Hi @fpompermaier, I thought about this again. I don't think it is a good
idea to tie `closeInputFormat()` to `configure()` because `configure()` is
called at different
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253820#comment-15253820
]
ASF GitHub Bot commented on FLINK-3777:
---
Github user fhueske commented on the pull request:
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1923#issuecomment-213346413
Maybe I have to increase the timeout for Travis here. Will do it.
---
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-3800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253597#comment-15253597
]
ASF GitHub Bot commented on FLINK-3800:
---
Github user tillrohrmann commented on the pull request:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1903#discussion_r60728010
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/DataSourceNode.java
---
@@ -187,6 +194,10 @@ else if (len >= 0) {
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253801#comment-15253801
]
ASF GitHub Bot commented on FLINK-3777:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1903#discussion_r60727958
--- Diff:
flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/DataSourceNode.java
---
@@ -150,6 +151,12 @@ protected void
[
https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1743:
-
Assignee: David E Drummond (was: Ozturk Gokal)
> Add multinomial logistic regression to machine
[
https://issues.apache.org/jira/browse/FLINK-1743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253594#comment-15253594
]
Till Rohrmann commented on FLINK-1743:
--
I haven't seen any updates on this issue for a long time.
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253779#comment-15253779
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1923#issuecomment-213342621
Code looks good.
It seems that the test is still a bit unstable:
```
Tests in error:
LeaderChangeJobRecoveryTest.before:73 û Timeout Futures timed
[
https://issues.apache.org/jira/browse/FLINK-3669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253604#comment-15253604
]
Aljoscha Krettek commented on FLINK-3669:
-
Btw, in the future if you reference me like this
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253654#comment-15253654
]
Till Rohrmann commented on FLINK-1746:
--
Hi [~ronaknnath...@gmail.com],
great to hear that you want
[
https://issues.apache.org/jira/browse/FLINK-1746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-1746:
-
Assignee: Ronak Nathani (was: Raghav Chalapathy)
> Add linear discriminant analysis to machine
[
https://issues.apache.org/jira/browse/FLINK-3072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-3072.
-
Resolution: Invalid
> DbStateBackendTest
> --
>
> Key: FLINK-3072
>
[
https://issues.apache.org/jira/browse/FLINK-3193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-3193.
-
Resolution: Invalid
> Add optional bloomfilter to sql state backend
>
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1925#issuecomment-213371505
Thanks for the fix @NathanHowell. Good 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
[
https://issues.apache.org/jira/browse/FLINK-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253802#comment-15253802
]
ASF GitHub Bot commented on FLINK-3777:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253868#comment-15253868
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60733038
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60738627
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60739128
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/preprocessing/SplitterITSuite.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253932#comment-15253932
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60731025
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253836#comment-15253836
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253835#comment-15253835
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user rawkintrevo commented on the pull request:
https://github.com/apache/flink/pull/1849#issuecomment-213411019
The transformer needs to scale the label too... I might not be correctly
understanding your last paragraph / what you are proposing.
I agree with paragraph
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253889#comment-15253889
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253888#comment-15253888
]
Greg Hogan commented on FLINK-3618:
---
This looks to be a simple change with no dissension, but is
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60735615
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60737947
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253913#comment-15253913
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60737984
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253937#comment-15253937
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60739509
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/preprocessing/SplitterITSuite.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1898#issuecomment-213434810
Thanks for your contribution @rawkintrevo. Good work. I had some minor
inline comments. I'm mainly concerned about the efficiency of
`multiRandomSplit` because it
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253841#comment-15253841
]
Fabian Hueske commented on FLINK-2828:
--
I started with the implementation of the {{TableRef}} design
[
https://issues.apache.org/jira/browse/FLINK-2828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-2828:
Assignee: Fabian Hueske (was: Timo Walther)
> Add interfaces for Table API input formats
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253843#comment-15253843
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on the pull request:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60732321
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java
---
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253856#comment-15253856
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60732384
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java
---
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253886#comment-15253886
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60736953
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253903#comment-15253903
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253911#comment-15253911
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60739818
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253943#comment-15253943
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253954#comment-15253954
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253857#comment-15253857
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60732457
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253858#comment-15253858
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/1911#discussion_r60733595
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253870#comment-15253870
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253920#comment-15253920
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60738393
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60738251
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60738935
--- Diff:
flink-libraries/flink-ml/src/test/scala/org/apache/flink/ml/preprocessing/SplitterITSuite.scala
---
@@ -0,0 +1,73 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-2259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253927#comment-15253927
]
ASF GitHub Bot commented on FLINK-2259:
---
Github user tillrohrmann commented on a diff in the pull
Github user StefanRRichter commented on the pull request:
https://github.com/apache/flink/pull/1905#issuecomment-213443445
The current version should cover all of your feedback and could be pulled
@tillrohrmann .
---
If your project is set up for it, you can reply to this email and
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253838#comment-15253838
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253839#comment-15253839
]
ASF GitHub Bot commented on FLINK-3229:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1911#issuecomment-213407614
I could not get the example to work with the current jackson version. Only
after upgrading it to `2.7.3` it was working.
Did you test the kinesis consumer using a
[
https://issues.apache.org/jira/browse/FLINK-3754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253850#comment-15253850
]
ASF GitHub Bot commented on FLINK-3754:
---
Github user yjshen commented on the pull request:
[
https://issues.apache.org/jira/browse/FLINK-2157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253849#comment-15253849
]
ASF GitHub Bot commented on FLINK-2157:
---
Github user rawkintrevo commented on the pull request:
Github user yjshen commented on the pull request:
https://github.com/apache/flink/pull/1916#issuecomment-213411425
For ease of review, I would like to explain this RP with more details.
While table api are called to construct a query, it was first constructed
as a operator
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/1898#discussion_r60732832
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/preprocessing/Splitter.scala
---
@@ -0,0 +1,215 @@
+/*
+ * Licensed to
1 - 100 of 173 matches
Mail list logo
