[
https://issues.apache.org/jira/browse/FLINK-5754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929948#comment-15929948
]
Greg Hogan commented on FLINK-5754:
---
[~shijinkui] it looks like the objective is to tag the release.
[
https://issues.apache.org/jira/browse/FLINK-5650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929946#comment-15929946
]
shijinkui commented on FLINK-5650:
--
Good job, Thanks.
> Flink-python tests executing cost too long time
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3543
Looks good.
+1 for 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
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929932#comment-15929932
]
ASF GitHub Bot commented on FLINK-5985:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3127#discussion_r106644720
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/Types.scala
---
@@ -17,29 +17,51 @@
*/
package
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3127
Found one more small concern (inline comment)
---
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-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929928#comment-15929928
]
ASF GitHub Bot commented on FLINK-5481:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929927#comment-15929927
]
ASF GitHub Bot commented on FLINK-5481:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929925#comment-15929925
]
ASF GitHub Bot commented on FLINK-5481:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3127
Looks good to me, +1
@twalthr @fhueske Any concerns about 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.
[
https://issues.apache.org/jira/browse/FLINK-5668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929916#comment-15929916
]
Stephan Ewen commented on FLINK-5668:
-
There are other config files and config objects that are passes
[
https://issues.apache.org/jira/browse/FLINK-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929909#comment-15929909
]
Jakub Nowacki commented on FLINK-6098:
--
Well, it doesn't. :) As you can see from the above logs,
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106545012
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +154,64 @@
[
https://issues.apache.org/jira/browse/FLINK-6098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929893#comment-15929893
]
Chesnay Schepler commented on FLINK-6098:
-
It is very odd that the job does not fail/restarts.
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-6101:
---
Description:
currently the TableAPI do not support selecting GroupBy fields with expression
either
[
https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln.lee updated FLINK-6101:
---
Description:
currently the TableAPI do not support selecting GroupBy fields with expression
either
Github user tonycox closed the pull request at:
https://github.com/apache/flink/pull/3166
---
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/3392
+1
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
enabled and
[
https://issues.apache.org/jira/browse/FLINK-3849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929815#comment-15929815
]
ASF GitHub Bot commented on FLINK-3849:
---
Github user tonycox closed the pull request at:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106548270
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/DataStreamProcTimeBoundAggIntegrationTest.scala
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106630745
--- 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_r106546899
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -191,3 +287,31 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106545668
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +154,64 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106544854
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -106,6 +137,10 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106630792
--- 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_r106546112
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +154,64 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106630541
--- 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_r106629913
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -119,6 +154,66 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106546529
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -191,3 +287,31 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106547382
--- 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_r106631183
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -17,23 +17,54 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3550#discussion_r106547467
--- 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_r106630898
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/DataStreamProcTimeBoundAggIntegrationITCase.scala
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929811#comment-15929811
]
ASF GitHub Bot commented on FLINK-5883:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929795#comment-15929795
]
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=15929800#comment-15929800
]
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=15929806#comment-15929806
]
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=15929804#comment-15929804
]
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=15929791#comment-15929791
]
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=15929803#comment-15929803
]
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=15929799#comment-15929799
]
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=15929801#comment-15929801
]
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=15929792#comment-15929792
]
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=15929802#comment-15929802
]
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=15929794#comment-15929794
]
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=15929805#comment-15929805
]
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=15929793#comment-15929793
]
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=15929797#comment-15929797
]
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=15929796#comment-15929796
]
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=15929798#comment-15929798
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929776#comment-15929776
]
ASF GitHub Bot commented on FLINK-5995:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3503
Looks good, 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
enabled and
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929775#comment-15929775
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-5981.
-
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed via e0614f6551a232706b74963563694486fe2461b1
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen closed FLINK-5981.
---
> SSL version and ciper suites cannot be constrained as configured
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3486
---
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
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929768#comment-15929768
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3508
@StefanRRichter I think I was faster ... ð
---
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
Su Ralph created FLINK-6102:
---
Summary: Update protobuf to latest version
Key: FLINK-6102
URL: https://issues.apache.org/jira/browse/FLINK-6102
Project: Flink
Issue Type: Task
Components:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3508
I wonder if there could also exist a case for broadcasting operator state
(non-keyed), where only one operator instance is selected as sender and all
others receive on restore. Furthermore,
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929756#comment-15929756
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929753#comment-15929753
]
ASF GitHub Bot commented on FLINK-5653:
---
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/3547#discussion_r106627390
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -17,34 +17,41 @@
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929751#comment-15929751
]
ASF GitHub Bot commented on FLINK-5653:
---
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/3547#discussion_r106627282
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -106,9 +113,14 @@
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929740#comment-15929740
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929742#comment-15929742
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929738#comment-15929738
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929741#comment-15929741
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929745#comment-15929745
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929746#comment-15929746
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929733#comment-15929733
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929743#comment-15929743
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929739#comment-15929739
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929736#comment-15929736
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929744#comment-15929744
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929734#comment-15929734
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929735#comment-15929735
]
ASF GitHub Bot commented on FLINK-5658:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5658?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929737#comment-15929737
]
ASF GitHub Bot commented on FLINK-5658:
---
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/3386#discussion_r106620612
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -159,6 +167,46 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106625858
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -317,4 +320,119 @@ class SqlITCase
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106623827
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106622821
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106621564
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -91,6 +91,35 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106623601
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106623012
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106617971
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamOverAggregate.scala
---
@@ -112,7 +113,14 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106624514
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106626434
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -317,4 +320,119 @@ class SqlITCase
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106624582
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106625475
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/SqlITCase.scala
---
@@ -317,4 +320,119 @@ class SqlITCase
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106622479
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/UnboundedEventTimeOverProcessFunction.scala
---
@@ -0,0
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3386#discussion_r106623704
--- 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-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929731#comment-15929731
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3508
+1 on not exposing the Java Serialisation shortcut, btw. I was very unhappy
that we even have it for the normal operator state. ð
---
If your project is set up for it, you can reply to this
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/3508
I would like us to take some time and think about the name. We are about to
introduce a thing called "broadcast state" somewhat soon in the effort to make
streaming joins possible. This broadcast
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929730#comment-15929730
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user aljoscha commented on the issue:
lincoln.lee created FLINK-6101:
--
Summary: GroupBy fields with expression can not be selected either
using original name or expression
Key: FLINK-6101
URL: https://issues.apache.org/jira/browse/FLINK-6101
[
https://issues.apache.org/jira/browse/FLINK-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15929719#comment-15929719
]
ASF GitHub Bot commented on FLINK-6058:
---
GitHub user fanyon opened a pull request:
GitHub user fanyon opened a pull request:
https://github.com/apache/flink/pull/3561
[FLINK-6058] fix read DEFAULT_PARALLELISM from ContextEnvironment
fix read DEFAULT_PARALLELISM from ContextEnvironment
You can merge this pull request into a Git repository by running:
$ git
201 - 300 of 444 matches
Mail list logo
