[
https://issues.apache.org/jira/browse/FLINK-6139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934135#comment-15934135
]
ASF GitHub Bot commented on FLINK-6139:
---
GitHub user tzulitai opened a pull request:
Tzu-Li (Gordon) Tai created FLINK-6139:
--
Summary: Documentation for building / preparing Flink for MapR
Key: FLINK-6139
URL: https://issues.apache.org/jira/browse/FLINK-6139
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934109#comment-15934109
]
Luke Hutchison edited comment on FLINK-6114 at 3/21/17 5:18 AM:
Hi Greg,
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934109#comment-15934109
]
Luke Hutchison edited comment on FLINK-6114 at 3/21/17 5:17 AM:
Hi Greg,
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934109#comment-15934109
]
Luke Hutchison commented on FLINK-6114:
---
Hi Greg, the code that caused the exception was doing the
[
https://issues.apache.org/jira/browse/FLINK-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934093#comment-15934093
]
ASF GitHub Bot commented on FLINK-6138:
---
GitHub user sunjincheng121 opened a pull request:
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3581
[FLINK-6138][table] Create the ListStateDescriptor with the aggregatiâ¦
â¦onStateType instead of a serializer.
Thanks for contributing to Apache Flink. Before you open your pull
sunjincheng created FLINK-6138:
--
Summary: Improve
UnboundedNonPartitionedProcessingOverProcessFunction
Key: FLINK-6138
URL: https://issues.apache.org/jira/browse/FLINK-6138
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934068#comment-15934068
]
sunjincheng edited comment on FLINK-5990 at 3/21/17 4:29 AM:
-
In this JIRA.
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934071#comment-15934071
]
Luke Hutchison edited comment on FLINK-6115 at 3/21/17 4:15 AM:
It's quite
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934071#comment-15934071
]
Luke Hutchison commented on FLINK-6115:
---
It's quite easy to end up with null values in tuples though
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934068#comment-15934068
]
sunjincheng edited comment on FLINK-5990 at 3/21/17 4:14 AM:
-
In this JIRA.
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934068#comment-15934068
]
sunjincheng edited comment on FLINK-5990 at 3/21/17 4:14 AM:
-
In this JIRA.
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934068#comment-15934068
]
sunjincheng commented on FLINK-5990:
In this JIRA. I'll definition two concepts:
1. out-of-order
2.
[
https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934064#comment-15934064
]
ASF GitHub Bot commented on FLINK-6124:
---
Github user shaoxuan-wang commented on a diff in the pull
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3579#discussion_r107069266
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -916,6 +916,10 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934059#comment-15934059
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107068594
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934054#comment-15934054
]
Haohui Mai commented on FLINK-5998:
---
Sorry for the delay I'm just busy on other issues -- I'll take care
[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934049#comment-15934049
]
ASF GitHub Bot commented on FLINK-5791:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/3580
[FLINK-5791] Support an optimal matching based slot manager for flip6 yarn
mode
This pr is for
jira-#[5791](https://issues.apache.org/jira/browse/FLINK-5791)
Main changes:
1. Add a
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934047#comment-15934047
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934048#comment-15934048
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a diff in the pull
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3574#discussion_r107066745
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -89,6 +95,18 @@ object
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3574#discussion_r107066582
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -150,12
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r107061507
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/logical/operators.scala
---
@@ -511,15 +511,15 @@ case class Join(
Github user sunjincheng121 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r107062397
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934032#comment-15934032
]
ASF GitHub Bot commented on FLINK-6124:
---
GitHub user docete opened a pull request:
GitHub user docete opened a pull request:
https://github.com/apache/flink/pull/3579
[FLINK-6124] [Table API & SQL] support max/min aggregations for strinâ¦
currently min/max aggregations on string type is not supported and should
be added.
When min/max aggregations are used on
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15934017#comment-15934017
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user sunjincheng121 commented on a diff in the pull
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r107060990
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/exceptions.scala
---
@@ -165,3 +165,31 @@ case class
[
https://issues.apache.org/jira/browse/FLINK-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933989#comment-15933989
]
ASF GitHub Bot commented on FLINK-6068:
---
Github user KurtYoung commented on the issue:
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3409#discussion_r107059962
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/java/BatchTableEnvironment.scala
---
@@ -178,4 +178,32 @@ class
Github user KurtYoung commented on the issue:
https://github.com/apache/flink/pull/3553
Since `IF` is not sql standard, i think we could let java user just use
`case when`
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well.
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933978#comment-15933978
]
lincoln.lee commented on FLINK-6101:
Agree with you, using an internal alias in groupBy() seems a
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933959#comment-15933959
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on the issue:
Github user shixiaogang commented on the issue:
https://github.com/apache/flink/pull/3524
Hi @StephanEwen The main reason is that we must have methods to delete
those unshared objects in failed `PendingCheckpoint`s. The `discardState()`
method is called when either the
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933934#comment-15933934
]
canbinzheng commented on FLINK-6117:
@[~vijikarthi]
It seems that I have no permission to assign my
[
https://issues.apache.org/jira/browse/FLINK-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933858#comment-15933858
]
Su Ralph commented on FLINK-6102:
-
I'm using protobuf-java 3.x. But i'm not suggesting based my own use
[
https://issues.apache.org/jira/browse/FLINK-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933853#comment-15933853
]
Su Ralph commented on FLINK-6125:
-
Cofirmed that on MAC, using maven 3.3.3 to build flink would have this
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933763#comment-15933763
]
Fabian Hueske commented on FLINK-6101:
--
I agree, it would be good to fix this.
IMO, it would be nice
[
https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933752#comment-15933752
]
ASF GitHub Bot commented on FLINK-6097:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3560
Hi @sunjincheng121, thanks for explaining the issue, but I did not
completely understand the problem. The `ProjectionTranslator` is working on
Table API expressions and `LogicalNodes` which are
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933744#comment-15933744
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3567
It would be awesome if we could make IntelliJ pick up the style config
automatically. By committing some files under ".Idea", we might be able to
do that...
On Mar 20, 2017 11:29
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3560#discussion_r107033984
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/ProjectionTranslator.scala
---
@@ -227,18 +227,23 @@ object
[
https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933738#comment-15933738
]
ASF GitHub Bot commented on FLINK-6097:
---
Github user fhueske commented on a diff in the pull
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3567
@aljoscha should we host the new checkstyle under tools/maven/ alongside
the existing checkstyle? There is already a ticket (FLINK-6137) to add a custom
checkstyle to flink-cep and I don't see any
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933723#comment-15933723
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933686#comment-15933686
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933669#comment-15933669
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107023706
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateWindowFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107023660
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateWindowFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107018893
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107023949
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateWindowFunction.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933679#comment-15933679
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933685#comment-15933685
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107025846
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/WindowAggregateTest.scala
---
@@ -239,4 +252,179 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107018019
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107017477
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -17,23 +17,52 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933675#comment-15933675
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107019299
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933677#comment-15933677
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933666#comment-15933666
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933683#comment-15933683
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933671#comment-15933671
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107019651
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107024971
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -317,4 +317,92 @@ class SqlITCase
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933688#comment-15933688
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107026831
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -785,7 +785,7 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107017278
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -106,6 +135,10 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933674#comment-15933674
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933678#comment-15933678
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107020183
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933680#comment-15933680
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933689#comment-15933689
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933670#comment-15933670
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107018828
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933687#comment-15933687
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107023458
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107022459
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107019094
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933668#comment-15933668
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933690#comment-15933690
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107020368
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933681#comment-15933681
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107022916
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933665#comment-15933665
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933667#comment-15933667
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933673#comment-15933673
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933672#comment-15933672
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107023802
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateWindowFunction.scala
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933682#comment-15933682
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107022806
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933676#comment-15933676
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107024511
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -317,4 +317,92 @@ class SqlITCase
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107017957
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15933684#comment-15933684
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107023400
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataStreamProcTimeAggregateGlobalWindowFunction.scala
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r107020630
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@
1 - 100 of 437 matches
Mail list logo
