[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692636#comment-15692636
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user shixiaogang commented on the is
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/2768
Oh... I added another field to make the code more clear, but I did not
notice the serialization problem. Thanks very much for your reminder.
Your solution does work though the concept of
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692661#comment-15692661
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user shuai-xu commented on the issue
Github user shuai-xu commented on the issue:
https://github.com/apache/flink/pull/2744
@tillrohrmann, thank for your review, the YarnResourceManager is in another
pr https://github.com/apache/flink/pull/2808, I will modify it according to
your review soon.
---
If your project is s
Github user thvasilo commented on the issue:
https://github.com/apache/flink/pull/2764
Hello @NicoK , do you think you can include
[FLINK-5087](https://issues.apache.org/jira/browse/FLINK-5087) in this PR, or
should we create a new one?
---
If your project is set up for it, you can
[
https://issues.apache.org/jira/browse/FLINK-5008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692688#comment-15692688
]
ASF GitHub Bot commented on FLINK-5008:
---
Github user thvasilo commented on the issue
wouter ligtenberg created FLINK-5152:
Summary: accepting NullValue for EV in Gelly examples
Key: FLINK-5152
URL: https://issues.apache.org/jira/browse/FLINK-5152
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692732#comment-15692732
]
Vasia Kalavri commented on FLINK-5152:
--
Hi [~otherwise777],
this is an example of _we
[
https://issues.apache.org/jira/browse/FLINK-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692737#comment-15692737
]
ASF GitHub Bot commented on FLINK-4928:
---
Github user tillrohrmann commented on the i
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2744
Thanks for addressing my comments @shuai-xu.
What you could do is to base one PR on the other PR that is not a problem.
Then, the second PR can depend on the first one. But the first PR
[
https://issues.apache.org/jira/browse/FLINK-5152?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692739#comment-15692739
]
wouter ligtenberg commented on FLINK-5152:
--
Ah right, sorry i missed that, this t
[
https://issues.apache.org/jira/browse/FLINK-5152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vasia Kalavri closed FLINK-5152.
Resolution: Not A Problem
> accepting NullValue for EV in Gelly examples
> -
Github user VenturaDelMonte commented on the issue:
https://github.com/apache/flink/pull/2756
Hi,
Thank you for both your review and your suggestions! It is good to learn
something new everyday!
Regarding InternalWindowFunction, that's alright, although we may need to
change i
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692823#comment-15692823
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user VenturaDelMonte commented on th
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2623
Sure, I'll take care of it. I saw you giving a +1 and didn't see an issue
myself.
---
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-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692838#comment-15692838
]
ASF GitHub Bot commented on FLINK-2608:
---
Github user mxm commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692849#comment-15692849
]
Nikolay Vasilishin commented on FLINK-4565:
---
Hi, [~fhueske].
We've just decided
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2856
You removed the tests you introduced in #2623. If there were any tests in
`KryoCollectionsSerializerTest` which test `Arrays.asList(..)` they would have
failed prior merging #2623. Could you add a unit t
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2768
@shixiaogang you can also do that, but then the machinery in
`SimpleStateDescriptor` is only used by `ValueStateDescriptor` because this is
really the only descriptor that has a default value. (In m
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692853#comment-15692853
]
ASF GitHub Bot commented on FLINK-5023:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692874#comment-15692874
]
Stefan Richter commented on FLINK-5024:
---
Independently of this, I also talked with A
Robert Metzger created FLINK-5153:
-
Summary: Allow setting custom application tags for Flink on YARN
Key: FLINK-5153
URL: https://issues.apache.org/jira/browse/FLINK-5153
Project: Flink
Issue
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/2767
If you cannot exclude the netty dependency, you could try to shade it away:
https://maven.apache.org/plugins/maven-shade-plugin/
We do this all the time for conflicting dependencies.
--
Github user manuzhang commented on the issue:
https://github.com/apache/flink/pull/2756
@VenturaDelMonte sorry, it was my suggestion to change
`InternalWindowFunction#apply` to `process`. Anyway, great work ð
---
If your project is set up for it, you can reply to this email and h
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692894#comment-15692894
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user StephanEwen commented on the is
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2756
@VenturaDelMonte Yes to `AllWindowedStream` (Issue, PR).
And yes, we need to extend the interface of `InternalWindowFunction` in the
future and we can also change the name to process in a s
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692896#comment-15692896
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user manuzhang commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-4997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692898#comment-15692898
]
ASF GitHub Bot commented on FLINK-4997:
---
Github user aljoscha commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2854
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2860
---
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-5149?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692907#comment-15692907
]
ASF GitHub Bot commented on FLINK-5149:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels updated FLINK-5149:
--
Affects Version/s: 1.2.0
> ContinuousEventTimeTrigger doesn't fire at the end of the win
[
https://issues.apache.org/jira/browse/FLINK-5149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels closed FLINK-5149.
-
Resolution: Fixed
Fix Version/s: 1.1.4
master: 2029c14eb7d5b6788eb9297c271dd16a0d81
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89471865
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/SessionWindowing.scala
---
@@ -0,0 +1,9
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89469371
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/ml/IncrementalLearningSkeleton.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692927#comment-15692927
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692930#comment-15692930
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89464880
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/kafka/ReadFromKafka.scala
---
@@ -0,0 +1,72 @@
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89472254
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/WindowWordCount.scala
---
@@ -0,0 +1,10
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692929#comment-15692929
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692928#comment-15692928
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692925#comment-15692925
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692924#comment-15692924
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89471075
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/windowing/GroupedProcessingTimeWindowExample.scala
--
[
https://issues.apache.org/jira/browse/FLINK-3551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692926#comment-15692926
]
ASF GitHub Bot commented on FLINK-3551:
---
Github user thvasilo commented on a diff in
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89469773
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/ml/IncrementalLearningSkeleton.scala
---
@@ -0,0
Github user thvasilo commented on a diff in the pull request:
https://github.com/apache/flink/pull/2761#discussion_r89465547
--- Diff:
flink-examples/flink-examples-streaming/src/main/scala/org/apache/flink/streaming/scala/examples/kafka/WriteIntoKafka.scala
---
@@ -0,0 +1,81 @@
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Renkai Ge reassigned FLINK-5128:
Assignee: Renkai Ge
> Get Kafka partitions in FlinkKafkaProducer only if a partitioner is set
> ---
[
https://issues.apache.org/jira/browse/FLINK-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692944#comment-15692944
]
Renkai Ge commented on FLINK-5128:
--
I want to work for this.
> Get Kafka partitions in F
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692951#comment-15692951
]
ASF GitHub Bot commented on FLINK-5075:
---
Github user tzulitai commented on the issue
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2822
---
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-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692965#comment-15692965
]
ASF GitHub Bot commented on FLINK-5075:
---
Github user asfgit closed the pull request
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2822
Merging ..
---
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
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5075:
---
Fix Version/s: 1.2.0
> Kinesis consumer incorrectly determines shards as newly discove
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5075:
---
Fix Version/s: 1.1.4
> Kinesis consumer incorrectly determines shards as newly discove
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai resolved FLINK-5075.
Resolution: Fixed
> Kinesis consumer incorrectly determines shards as newly discover
[
https://issues.apache.org/jira/browse/FLINK-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15692971#comment-15692971
]
Tzu-Li (Gordon) Tai commented on FLINK-5075:
Resolved for {{master}} via
http
Github user chermenin commented on the issue:
https://github.com/apache/flink/pull/2856
I removed a method from ITCase only. There is `testJavaArraysAsList` method
in `KryoCollectionsSerializerTest` class to check it. Yep, before merging
#2623, they have not been successful.
---
If
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693008#comment-15693008
]
Fabian Hueske commented on FLINK-4565:
--
Great! Looking forward to it.
> Support for
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/2845
Thanks for the review @zentol ! I integrated your comments and rebased to
the master.
Let's see what travis has to say and then merge it if you have no further
comments ;)
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-5096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693016#comment-15693016
]
ASF GitHub Bot commented on FLINK-5096:
---
Github user kl0u commented on the issue:
Aljoscha Krettek created FLINK-5154:
---
Summary: Duplicate TypeSerializer when writing RocksDB Snapshot
Key: FLINK-5154
URL: https://issues.apache.org/jira/browse/FLINK-5154
Project: Flink
Is
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2664
I thought that transitive dependencies are resolved in the scope of
assembly descriptors. But I'm not so sure about that anymore.
---
If your project is set up for it, you can reply to this email a
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693038#comment-15693038
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user rmetzger commented on the issue
Aljoscha Krettek created FLINK-5155:
---
Summary: Deprecate ValueStateDescriptor constructors with default
value
Key: FLINK-5155
URL: https://issues.apache.org/jira/browse/FLINK-5155
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5155:
Description:
Having the default value in the descriptor is problematic with some serialisers
[
https://issues.apache.org/jira/browse/FLINK-5154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-5154.
---
Resolution: Not A Problem
> Duplicate TypeSerializer when writing RocksDB Snapshot
> -
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89465952
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89461025
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,83 @@
+
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693129#comment-15693129
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89466031
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,83 @@
+
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693130#comment-15693130
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693122#comment-15693122
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89480259
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89482516
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693123#comment-15693123
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693118#comment-15693118
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693121#comment-15693121
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89483366
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,83 @@
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89462392
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala
---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89483891
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala
---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693119#comment-15693119
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89483428
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/RichMapRunner.scala
---
@@ -0,0 +1,52 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693127#comment-15693127
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89465992
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89483310
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693128#comment-15693128
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693126#comment-15693126
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693132#comment-15693132
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693124#comment-15693124
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89461812
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,83 @@
+
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693131#comment-15693131
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89486698
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetSingleRowCrossRule.scala
---
@@ -0,0 +1,83 @@
+
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693120#comment-15693120
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693125#comment-15693125
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89480684
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2811#discussion_r89480767
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetSingleRowCross.scala
---
@@ -0,0 +1,180 @@
+/*
Github user gaborhermann commented on a diff in the pull request:
https://github.com/apache/flink/pull/2838#discussion_r89489117
--- Diff:
flink-libraries/flink-ml/src/main/scala/org/apache/flink/ml/pipeline/Predictor.scala
---
@@ -72,14 +77,142 @@ trait Predictor[Self] extends Es
[
https://issues.apache.org/jira/browse/FLINK-4712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15693161#comment-15693161
]
ASF GitHub Bot commented on FLINK-4712:
---
Github user gaborhermann commented on a dif
Github user mbalassi commented on the issue:
https://github.com/apache/flink/pull/2094
Merging...
---
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
1 - 100 of 153 matches
Mail list logo
