Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88614200
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -162,24 +191,107 @@ obj
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676109#comment-15676109
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88614416
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/logical/call.scala
---
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676114#comment-15676114
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88614846
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676121#comment-15676121
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88614874
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88614862
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676123#comment-15676123
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676124#comment-15676124
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88615630
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -0,0 +1,386 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676137#comment-15676137
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88615712
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/dataset/DataSetCorrelate.scala
---
@@ -0,0 +1,136 @@
+/*
+
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676139#comment-15676139
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676144#comment-15676144
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88615926
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ * Licen
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88616007
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ * Licen
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676146#comment-15676146
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88617047
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/schema/FlinkTableFunctionImpl.scala
---
@@ -0,0 +1,77 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676164#comment-15676164
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88617248
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/validate/FunctionCatalog.scala
---
@@ -47,13 +52,50 @@ class FunctionCatalog
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88617192
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/table.scala
---
@@ -611,6 +612,130 @@ class Table(
}
/**
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676170#comment-15676170
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676167#comment-15676167
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676175#comment-15676175
]
Alexander Shoshin commented on FLINK-3133:
--
Hi )
Thanks, Maximilian. I think tha
[
https://issues.apache.org/jira/browse/FLINK-3702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676177#comment-15676177
]
ASF GitHub Bot commented on FLINK-3702:
---
Github user mbalassi commented on a diff in
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/2094#discussion_r88617516
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessorFactory.java
---
@@ -0,0 +1,197 @@
+/*
+ * Licen
Biao Liu created FLINK-5093:
---
Summary: java.util.ConcurrentModificationException is thrown when
stopping TimerService
Key: FLINK-5093
URL: https://issues.apache.org/jira/browse/FLINK-5093
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu reassigned FLINK-5076:
---
Assignee: Biao Liu
> Shutting down TM when shutting down new mini cluster
> -
[
https://issues.apache.org/jira/browse/FLINK-5076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-5076:
Issue Type: Bug (was: Improvement)
> Shutting down TM when shutting down new mini cluster
> ---
Github user AlexanderShoshin commented on the issue:
https://github.com/apache/flink/pull/2811
Thanks, Fabian.
It's my mistake that I used a cross function. I will try to make the same
with a map function.
---
If your project is set up for it, you can reply to this email and have
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676205#comment-15676205
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user AlexanderShoshin commented on t
[
https://issues.apache.org/jira/browse/FLINK-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske resolved FLINK-4587.
--
Resolution: Not A Problem
Problem was solved by using the correct Maven version.
> Yet another
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Description:
It would be good to have the option to generate test coverage reports for Flink.
w
[
https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-5093:
Description:
In stop method of TimerService, removing Timeout instance while iterating the
map will cause a
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Summary: Add integration with Sonarqube (was: Add maven profile with code
coverage report generatio
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Description:
Add integration with https://analysis.apache.org/ SonarQube:
-add generate test covera
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Summary: Add integration with Sonarqube and code coverage (was: Add
integration with Sonarqube)
>
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Description:
Add integration with SonarQube:
- add generate test coverage reports for Flink with ne
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Description:
Add integration with SonarQube:
- add generate test coverage reports for Flink with ne
[
https://issues.apache.org/jira/browse/FLINK-5092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boris Osipov updated FLINK-5092:
Description:
It would be good to have the opportunity to generate test coverage reports for
Flink a
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88622767
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/functions/TableFunction.scala
---
@@ -0,0 +1,119 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676269#comment-15676269
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676275#comment-15676275
]
ASF GitHub Bot commented on FLINK-4541:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2811
Great! Looking forward to an update :-)
Thanks, Fabian
---
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 hav
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/2653#discussion_r88623426
--- Diff: flink-libraries/flink-table/pom.xml ---
@@ -154,6 +154,10 @@ under the License.
maven-shade-plugin
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676289#comment-15676289
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-5093:
Description:
In stop method of TimerService, removing Timeout instance while iterating the
map will cause a
[
https://issues.apache.org/jira/browse/FLINK-4832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676435#comment-15676435
]
Anton Mushin commented on FLINK-4832:
-
Hi [~twalthr],
I have trouble with next code
{c
GitHub user ifndef-SleePy opened a pull request:
https://github.com/apache/flink/pull/2828
[FLINK-5093] java.util.ConcurrentModificationException is thrown when
stopping TimerService
[FLINK-5093] Fix bug about java.util.ConcurrentModificationException thrown
while stopping TimerSer
[
https://issues.apache.org/jira/browse/FLINK-5093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676440#comment-15676440
]
ASF GitHub Bot commented on FLINK-5093:
---
GitHub user ifndef-SleePy opened a pull req
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2797
---
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-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676452#comment-15676452
]
ASF GitHub Bot commented on FLINK-5056:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5054.
---
Resolution: Fixed
Fixed in 13ebb36bb6c7fbe591d9e7834a2fc34d8469bc00
> Make the BucketingSink
[
https://issues.apache.org/jira/browse/FLINK-5056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5056.
---
Resolution: Fixed
Fixed in 13ebb36bb6c7fbe591d9e7834a2fc34d8469bc00
> BucketingSink deletes v
Github user zentol closed the pull request at:
https://github.com/apache/flink/pull/1833
---
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-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676468#comment-15676468
]
ASF GitHub Bot commented on FLINK-2609:
---
Github user zentol closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5094:
-
Component/s: Streaming
> Support RichReduceFunction and RichFoldFunction as incremental window
>
Fabian Hueske created FLINK-5094:
Summary: Support RichReduceFunction and RichFoldFunction as
incremental window aggregation functions
Key: FLINK-5094
URL: https://issues.apache.org/jira/browse/FLINK-5094
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5094:
-
Description:
Support {{RichReduceFunction}} and {{RichFoldFunction}} as incremental window
aggreg
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/2829
Hotfix 2016 11 18
Prevent RecordWriter#flush() to clear the serializer twice.
Also add some documentation to RecordWriter, RecordSerializer and
SpanningRecordSerializer.
You can merge this pull r
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/2829#discussion_r88649329
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java
---
@@ -151,6 +176,15 @@ private Ser
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/2829#discussion_r88649470
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java
---
@@ -151,6 +176,15 @@ private Seri
Github user fpompermaier commented on the issue:
https://github.com/apache/flink/pull/2829
Could this be a possible fix for FLINK-4719?
---
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 fe
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/2829
Could you modify the PR title to something more descriptive?
---
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 ha
[
https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676633#comment-15676633
]
ASF GitHub Bot commented on FLINK-4719:
---
Github user fpompermaier commented on the i
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/2829
I don't expect this to change any behaviour as clearing the serializer
twice does actually not hurt and is only some waste of resources so FLINK-4719
should not be affected at all
---
If your project
[
https://issues.apache.org/jira/browse/FLINK-4719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676660#comment-15676660
]
ASF GitHub Bot commented on FLINK-4719:
---
Github user NicoK commented on the issue:
Chesnay Schepler created FLINK-5095:
---
Summary: Add explicit notifyOfAddedX methods to MetricReporter
interface
Key: FLINK-5095
URL: https://issues.apache.org/jira/browse/FLINK-5095
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-5095:
Priority: Minor (was: Major)
> Add explicit notifyOfAddedX methods to MetricReporter interf
Kostas Kloudas created FLINK-5096:
-
Summary: Make the RollingSink rescalable.
Key: FLINK-5096
URL: https://issues.apache.org/jira/browse/FLINK-5096
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676678#comment-15676678
]
Stephan Ewen commented on FLINK-2821:
-
+1 for getting rid of {{jobmanager.rpc.bind-add
[
https://issues.apache.org/jira/browse/FLINK-2821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676689#comment-15676689
]
Stephan Ewen commented on FLINK-2821:
-
Concerning HA setups: Publishing the JobManager
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676692#comment-15676692
]
Stephan Ewen commented on FLINK-5090:
-
I have added min/max/avg across the channels fo
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676696#comment-15676696
]
Stephan Ewen commented on FLINK-3617:
-
How pressing is that? Is it a serious problem t
Vasia Kalavri created FLINK-5097:
Summary: The TypeExtractor is missing input type information in
some Graph methods
Key: FLINK-5097
URL: https://issues.apache.org/jira/browse/FLINK-5097
Project: Flin
[
https://issues.apache.org/jira/browse/FLINK-4679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676708#comment-15676708
]
Jark Wu commented on FLINK-4679:
Hi [~fhueske] [~twalthr], if I understand correctly, the
[
https://issues.apache.org/jira/browse/FLINK-3617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676714#comment-15676714
]
Fabian Hueske commented on FLINK-3617:
--
Don't know. [~jgrier] who reported the issue
Till Rohrmann created FLINK-5098:
Summary: Detect network problems to eagerly time out ask operations
Key: FLINK-5098
URL: https://issues.apache.org/jira/browse/FLINK-5098
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-5098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676758#comment-15676758
]
ASF GitHub Bot commented on FLINK-5098:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2830
[FLINK-5098] [akka] Detect unreachable remote actors to fail ask calls
eagerly
This PR adds to every sent ask message an additional Identify message which
is used to
detect whether the tar
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676759#comment-15676759
]
Jark Wu commented on FLINK-5094:
Hi [~fhueske], this may need to modify the implementation
[
https://issues.apache.org/jira/browse/FLINK-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676772#comment-15676772
]
Fabian Hueske commented on FLINK-5094:
--
Yes, the incremental aggregation functions ar
[
https://issues.apache.org/jira/browse/FLINK-4591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-4591.
--
Resolution: Won't Fix
> Select star does not work with grouping
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676805#comment-15676805
]
Roman Maier commented on FLINK-5002:
Please check the implementation of this issue:
ht
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2831
[FLINK-5010] [akka] Introduce default configuration values for Akka's
deathwatch
Set the akka deathwatch interval to 10s, the akka deathwatch pause to 60s
and the tcp
connection timeout to
[
https://issues.apache.org/jira/browse/FLINK-5010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676830#comment-15676830
]
ASF GitHub Bot commented on FLINK-5010:
---
GitHub user tillrohrmann opened a pull requ
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88658743
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -231,6 +297,64 @@ obje
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88637570
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateTimeWindowFunction.scala
---
@@ -0,0 +1
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88659308
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,123 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88653721
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0 +1,69
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88635921
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateAllTimeWindowFunction.scala
---
@@ -48,6 +48,6 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88659144
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,123 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88633784
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateMapFunction.scala
---
@@ -30,9 +30,9 @@ class Aggr
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88636193
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/AggregateTimeWindowFunction.scala
---
@@ -52,6 +52,6 @@ cla
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88657597
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/nodes/datastream/DataStreamAggregate.scala
---
@@ -135,50 +128,123 @@ cl
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88638112
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0 +1,69
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/2792#discussion_r88641722
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/runtime/aggregate/IncrementalAggregateReduceFunction.scala
---
@@ -0,0 +1,69
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676841#comment-15676841
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-4937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15676843#comment-15676843
]
ASF GitHub Bot commented on FLINK-4937:
---
Github user fhueske commented on a diff in
1 - 100 of 154 matches
Mail list logo
