Github user docete commented on a diff in the pull request:
https://github.com/apache/flink/pull/3579#discussion_r107081399
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -916,6 +916,10 @@ object AggregateUt
[
https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934155#comment-15934155
]
ASF GitHub Bot commented on FLINK-6124:
---
Github user docete commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934151#comment-15934151
]
Haohui Mai commented on FLINK-6102:
---
I would recommend keeping it as is. The problem is
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3582
[FLINK-6139] [doc] Documentation for running Flink with MapR
Includes how to properly build Flink & setup job client to be able to run
Flink on YARN with a MapR cluster.
You can merge this pull re
[
https://issues.apache.org/jira/browse/FLINK-6139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15934109#comment-15934109
]
Luke Hutchison edited comment on FLINK-6114 at 3/21/17 5:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934109#comment-15934109
]
Luke Hutchison edited comment on FLINK-6114 at 3/21/17 5:17 AM:
[
https://issues.apache.org/jira/browse/FLINK-6114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934109#comment-15934109
]
Luke Hutchison commented on FLINK-6114:
---
Hi Greg, the code that caused the exception
[
https://issues.apache.org/jira/browse/FLINK-6138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934093#comment-15934093
]
ASF GitHub Bot commented on FLINK-6138:
---
GitHub user sunjincheng121 opened a pull re
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 req
sunjincheng created FLINK-6138:
--
Summary: Improve
UnboundedNonPartitionedProcessingOverProcessFunction
Key: FLINK-6138
URL: https://issues.apache.org/jira/browse/FLINK-6138
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068
]
sunjincheng edited comment on FLINK-5990 at 3/21/17 4:29 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934071#comment-15934071
]
Luke Hutchison edited comment on FLINK-6115 at 3/21/17 4:15 AM:
[
https://issues.apache.org/jira/browse/FLINK-6115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934071#comment-15934071
]
Luke Hutchison commented on FLINK-6115:
---
It's quite easy to end up with null values
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068
]
sunjincheng edited comment on FLINK-5990 at 3/21/17 4:14 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068
]
sunjincheng edited comment on FLINK-5990 at 3/21/17 4:14 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934068#comment-15934068
]
sunjincheng commented on FLINK-5990:
In this JIRA. I'll definition two concepts:
1. o
[
https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934064#comment-15934064
]
ASF GitHub Bot commented on FLINK-6124:
---
Github user shaoxuan-wang commented on a di
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 Aggr
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934059#comment-15934059
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user sunjincheng121 commented on a d
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&focusedCommentId=15934054#comment-15934054
]
Haohui Mai commented on FLINK-5998:
---
Sorry for the delay I'm just busy on other issues -
[
https://issues.apache.org/jira/browse/FLINK-5791?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 UN
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934047#comment-15934047
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15934048#comment-15934048
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user sunjincheng121 commented on a d
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 Aggre
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 +160,7
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
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-6124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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&focusedCommentId=15934017#comment-15934017
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user sunjincheng121 commented on a d
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 AmbiguousTableSource
[
https://issues.apache.org/jira/browse/FLINK-6068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933989#comment-15933989
]
ASF GitHub Bot commented on FLINK-6068:
---
Github user KurtYoung commented on the issu
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 BatchTabl
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&focusedCommentId=15933978#comment-15933978
]
lincoln.lee commented on FLINK-6101:
Agree with you, using an internal alias in groupB
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933959#comment-15933959
]
ASF GitHub Bot commented on FLINK-6014:
---
Github user shixiaogang commented on the is
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 `PendingCheckp
[
https://issues.apache.org/jira/browse/FLINK-6117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933934#comment-15933934
]
canbinzheng commented on FLINK-6117:
@[~vijikarthi]
It seems that I have no permissio
[
https://issues.apache.org/jira/browse/FLINK-6102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933858#comment-15933858
]
Su Ralph commented on FLINK-6102:
-
I'm using protobuf-java 3.x. But i'm not suggesting bas
[
https://issues.apache.org/jira/browse/FLINK-6125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933853#comment-15933853
]
Su Ralph commented on FLINK-6125:
-
Cofirmed that on MAC, using maven 3.3.3 to build flink
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933763#comment-15933763
]
Fabian Hueske commented on FLINK-6101:
--
I agree, it would be good to fix this.
IMO,
[
https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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 trans
[
https://issues.apache.org/jira/browse/FLINK-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933744#comment-15933744
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user StephanEwen commented on the is
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 ProjectionTrans
[
https://issues.apache.org/jira/browse/FLINK-6097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933738#comment-15933738
]
ASF GitHub Bot commented on FLINK-6097:
---
Github user fhueske commented on a diff in
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&focusedCommentId=15933723#comment-15933723
]
ASF GitHub Bot commented on FLINK-6107:
---
Github user greghogan commented on the issu
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 +1
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 +1
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933686#comment-15933686
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933669#comment-15933669
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933666#comment-15933666
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933683#comment-15933683
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933671#comment-15933671
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933685#comment-15933685
]
ASF GitHub Bot commented on FLINK-5654:
---
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/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 W
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 @@ cla
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&focusedCommentId=15933675#comment-15933675
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107019299
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933677#comment-15933677
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107018893
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@ cla
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 +1
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933679#comment-15933679
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107019651
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@ cla
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 ex
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933688#comment-15933688
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107026831
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -785,7 +785,7 @@ object AggregateUt
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 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933674#comment-15933674
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933678#comment-15933678
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107020183
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933670#comment-15933670
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107018828
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933687#comment-15933687
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933680#comment-15933680
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933689#comment-15933689
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933665#comment-15933665
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933667#comment-15933667
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933673#comment-15933673
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933672#comment-15933672
]
ASF GitHub Bot commented on FLINK-5654:
---
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/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 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933668#comment-15933668
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933690#comment-15933690
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107020368
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +152,60 @@ cla
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933681#comment-15933681
]
ASF GitHub Bot commented on FLINK-5654:
---
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/3550#discussion_r107022916
--- 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_r107023458
--- 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&focusedCommentId=15933676#comment-15933676
]
ASF GitHub Bot commented on FLINK-5654:
---
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/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 ex
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 @@ cla
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 +1
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15933682#comment-15933682
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in
1 - 100 of 433 matches
Mail list logo
