[
https://issues.apache.org/jira/browse/FLINK-5476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865585#comment-15865585
]
Till Rohrmann commented on FLINK-5476:
--
This initial timeout could also be configurable or the
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/3166
Hi @fhueske,
what do you think about 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 project does not have this
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865577#comment-15865577
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user tonycox commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-5420:
--
Description:
This issue targets making the operators in the CEP library re-scalable. After
[
https://issues.apache.org/jira/browse/FLINK-5762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865561#comment-15865561
]
ASF GitHub Bot commented on FLINK-5762:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3291
Thanks a lot @StephanEwen !
---
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
[
https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865562#comment-15865562
]
ASF GitHub Bot commented on FLINK-5745:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865734#comment-15865734
]
ASF GitHub Bot commented on FLINK-5745:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5794:
---
Issue Type: Sub-task (was: Improvement)
Parent: FLINK-5792
> Improve “UDF" to support with
[
https://issues.apache.org/jira/browse/FLINK-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-5736:
-
Assignee: Robert Metzger
> Fix Javadocs / Scaladocs build (Feb 2017)
>
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865763#comment-15865763
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user StephanEwen commented on the issue:
sunjincheng created FLINK-5795:
--
Summary: Improve “UDTF" to support with parameter constructor
Key: FLINK-5795
URL: https://issues.apache.org/jira/browse/FLINK-5795
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger resolved FLINK-5736.
---
Resolution: Fixed
> Fix Javadocs / Scaladocs build (Feb 2017)
>
[
https://issues.apache.org/jira/browse/FLINK-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865766#comment-15865766
]
Robert Metzger commented on FLINK-5736:
---
The problem was the following:
On the buildbot server
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865794#comment-15865794
]
ASF GitHub Bot commented on FLINK-5690:
---
Github user alpinegizmo commented on a diff in the pull
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/3300#discussion_r101038332
--- Diff: docs/dev/best_practices.md ---
@@ -310,3 +310,17 @@ Next, you need to put the following jar files into the
`lib/` folder:
Note that you
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865804#comment-15865804
]
ASF GitHub Bot commented on FLINK-5567:
---
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/3197#discussion_r101022463
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/stats/FlinkStatistic.scala
---
@@ -0,0 +1,87 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-5690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865802#comment-15865802
]
ASF GitHub Bot commented on FLINK-5690:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865805#comment-15865805
]
ASF GitHub Bot commented on FLINK-5567:
---
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/3197#discussion_r101022558
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/stats/FlinkStatistic.scala
---
@@ -0,0 +1,87 @@
+/*
+ * Licensed
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3301
Thanks for the review. Merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865733#comment-15865733
]
ASF GitHub Bot commented on FLINK-5788:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865743#comment-15865743
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user shixiaogang commented on the issue:
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3305
@StephanEwen Thanks a lot for your comments. I have updated the code as
suggested.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865758#comment-15865758
]
Robert Metzger commented on FLINK-5736:
---
I've fixed the javadocs for the 1.2 build:
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5792:
---
Summary: Improve “UDF/UDTF" to support with parameter constructor (was:
Improve “UDTF" to support
[
https://issues.apache.org/jira/browse/FLINK-5792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-5792:
---
Description:
Currently UDF/UDTF in the codegen phase using a nonparametric constructor to
create the
[
https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865773#comment-15865773
]
ASF GitHub Bot commented on FLINK-5406:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-5406.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed in 1.3.0:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3101
---
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
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3293
+1 to merge this
---
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,
sunjincheng created FLINK-5794:
--
Summary: Improve “UDF" to support with parameter constructor
Key: FLINK-5794
URL: https://issues.apache.org/jira/browse/FLINK-5794
Project: Flink
Issue Type:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3101
Thanks for the update @godfreyhe.
I will go over the code a last time and merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865746#comment-15865746
]
ASF GitHub Bot commented on FLINK-5406:
---
Github user twalthr commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3305
Thanks a lot for the quick turnaround!
This looks good, merging now...
---
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
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3300
Thank you for your feedback. I've addressed both concerns and will merge
the change now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
[
https://issues.apache.org/jira/browse/FLINK-5070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-5070:
---
Component/s: Type Serialization System
Scala API
> Unable to use Scala's
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101068466
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
---
@@ -0,0 +1,131 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101068148
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/ListStateDescriptor.java
---
@@ -40,20 +44,22 @@
* consider using the
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866027#comment-15866027
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866026#comment-15866026
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866031#comment-15866031
]
ASF GitHub Bot commented on FLINK-5790:
---
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/3305#discussion_r101071253
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/ArrayListSerializer.java
---
@@ -109,8 +113,8 @@ public void copy(DataInputView
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866029#comment-15866029
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866024#comment-15866024
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866030#comment-15866030
]
ASF GitHub Bot commented on FLINK-5790:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866028#comment-15866028
]
ASF GitHub Bot commented on FLINK-5790:
---
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/3305#discussion_r101070598
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866025#comment-15866025
]
ASF GitHub Bot commented on FLINK-5790:
---
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/3305#discussion_r101070139
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/ListSerializer.java
---
@@ -0,0 +1,131 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101070284
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101070404
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866032#comment-15866032
]
ASF GitHub Bot commented on FLINK-5790:
---
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/3305#discussion_r101067289
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/ListStateDescriptor.java
---
@@ -62,10 +68,19 @@ public
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866050#comment-15866050
]
ASF GitHub Bot commented on FLINK-4280:
---
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/2509#discussion_r101075446
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@
Yelei Feng created FLINK-5797:
-
Summary: incorrect use of port range selector in BootstrapTool
Key: FLINK-5797
URL: https://issues.apache.org/jira/browse/FLINK-5797
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-5797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yelei Feng reassigned FLINK-5797:
-
Assignee: Yelei Feng
> incorrect use of port range selector in BootstrapTool
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/3305#discussion_r101070858
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/ListTypeInfo.java
---
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866114#comment-15866114
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866042#comment-15866042
]
ASF GitHub Bot commented on FLINK-4280:
---
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/2509#discussion_r101074257
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
---
@@
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/3309
[FLINK-5277] add unit tests for ResultPartition#add() in case of failures
This verifies that the given network buffer is recycled as expected and that
no notifiers are called upon failures to add
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866100#comment-15866100
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user rmetzger commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866101#comment-15866101
]
ASF GitHub Bot commented on FLINK-5277:
---
GitHub user NicoK opened a pull request:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3149
Thanks Robert!
I'll let the test run again and will merge if everything passes. Thanks
@tonycox and @ramkrish86 for digging into this.
---
If your project is set up for it, you can reply to
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/2509
I've tested the change locally and with great success. So once my comments
are addressed, the change is good to be merged
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866112#comment-15866112
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866096#comment-15866096
]
ASF GitHub Bot commented on FLINK-2168:
---
Github user fhueske commented on the issue:
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/2509#discussion_r101075570
--- Diff: docs/dev/connectors/kafka.md ---
@@ -161,6 +161,46 @@ For convenience, Flink provides the following schemas:
The KeyValue objectNode
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866051#comment-15866051
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/3149
I think its fine to change the JVM settings for the hbase module. Other
modules such as elasticsearch are also doing that.
---
If your project is set up for it, you can reply to this email and
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3149
It's not only Java 7. For Hadoop 2.4.1 and Java 7, the builds pass. So it
seems to be a combination of both parameters. Anyway, I think we can configure
the JVM for the tests.
It would be
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866135#comment-15866135
]
Nico Kruber commented on FLINK-4813:
for documentation: until the minikdc dependency is made optional,
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3196
Thanks for the update @beyond1920!
PR is 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 project does not
[
https://issues.apache.org/jira/browse/FLINK-5710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865414#comment-15865414
]
ASF GitHub Bot commented on FLINK-5710:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15865442#comment-15865442
]
ASF GitHub Bot commented on FLINK-4280:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866439#comment-15866439
]
Till Rohrmann commented on FLINK-5239:
--
[~StephanEwen] this is done and can be closed, right?
>
[
https://issues.apache.org/jira/browse/FLINK-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henry Saputra closed FLINK-1612.
Resolution: Not A Problem
> Add guidelines to avoid duplicate class names and more JavaDoc for new
Stephan Ewen created FLINK-5800:
---
Summary: Make sure that the CheckpointStreamFactory is
instantiated once per operator only
Key: FLINK-5800
URL: https://issues.apache.org/jira/browse/FLINK-5800
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866788#comment-15866788
]
ASF GitHub Bot commented on FLINK-5588:
---
GitHub user skonto opened a pull request:
GitHub user skonto opened a pull request:
https://github.com/apache/flink/pull/3313
[FLINK-5588][ml] add a data normalizer to ml library
- Adds a Normalizer.
- Still need to add the Unit Scaler for the features.
You can merge this pull request into a Git repository by running:
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866673#comment-15866673
]
Stephan Ewen commented on FLINK-5253:
-
That means we can drop it for all modes that do that. Not sure
[
https://issues.apache.org/jira/browse/FLINK-5624?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866737#comment-15866737
]
ASF GitHub Bot commented on FLINK-5624:
---
Github user haohui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-5597:
--
Affects Version/s: 1.3.0
> Improve the LocalClusteringCoefficient documentation
>
[
https://issues.apache.org/jira/browse/FLINK-5239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5239.
---
Resolution: Fixed
Fix Version/s: 1.3.0
Old issue, fixed a while back already.
> Properly
GitHub user StephanEwen opened a pull request:
https://github.com/apache/flink/pull/3312
[FLINK-5800] [checkpointing] Create CheckpointSteamFactory only once per
operator
Previously, the factory was created once per checkpoint, and its repeated
initialization logic
(like
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866672#comment-15866672
]
Stephan Ewen commented on FLINK-5253:
-
When the {{flink-conf.yaml}} is anyways generated, we can
[
https://issues.apache.org/jira/browse/FLINK-4813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866678#comment-15866678
]
Stephan Ewen commented on FLINK-4813:
-
[~NicoK] Do you want to go ahead and patch this?
> Having
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos commented on FLINK-5588:
[~till.rohrmann] Have already implemented the
[
https://issues.apache.org/jira/browse/FLINK-5800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866736#comment-15866736
]
ASF GitHub Bot commented on FLINK-5800:
---
GitHub user StephanEwen opened a pull request:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3252
Discussed with @fhueske offline. Thanks a lot for the comments. The V4 PR
implements the following:
* Rebased on top of #3101
* `LogicalWindowAggregateRule` implements `RelOptRule`
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:30 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:30 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866685#comment-15866685
]
Stavros Kontopoulos edited comment on FLINK-5588 at 2/14/17 11:30 PM:
--
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3314
[FLINK-3679] DeserializationSchema should handle zero or more outputs
This PR adds a new interface, `RichKeyedDeserializationSchema`, to enable
the deserializer to produce zero or more outputs. The
[
https://issues.apache.org/jira/browse/FLINK-3679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866919#comment-15866919
]
ASF GitHub Bot commented on FLINK-3679:
---
GitHub user haohui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15866801#comment-15866801
]
ASF GitHub Bot commented on FLINK-5588:
---
Github user skonto commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3251
---
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 - 200 of 279 matches
Mail list logo
