[
https://issues.apache.org/jira/browse/FLINK-5752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982390#comment-15982390
]
ASF GitHub Bot commented on FLINK-5752:
---
Github user ramkrish86 commented on the issue:
Github user ramkrish86 commented on the issue:
https://github.com/apache/flink/pull/3760
The failures seems not directly related.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-1526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982354#comment-15982354
]
ASF GitHub Bot commented on FLINK-1526:
---
Github user xccui closed the pull request at:
Github user xccui closed the pull request at:
https://github.com/apache/flink/pull/3284
---
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
Haohui Mai created FLINK-6377:
-
Summary: Support map types in the Table / SQL API
Key: FLINK-6377
URL: https://issues.apache.org/jira/browse/FLINK-6377
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-6368:
--
Assignee: Xingcan Cui
> Grouping keys in stream aggregations have wrong order
>
[
https://issues.apache.org/jira/browse/FLINK-6351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang updated FLINK-6351:
Description: The currently YarnFlinkApplicationMasterRunner inherits from
[
https://issues.apache.org/jira/browse/FLINK-6376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhangrucong1982 reassigned FLINK-6376:
--
Assignee: zhangrucong1982
> when deploy flink cluster on the yarn, it is lack of hdfs
zhangrucong1982 created FLINK-6376:
--
Summary: when deploy flink cluster on the yarn, it is lack of hdfs
delegation token.
Key: FLINK-6376
URL: https://issues.apache.org/jira/browse/FLINK-6376
Greg Hogan created FLINK-6375:
-
Summary: Fix LongValue hashCode
Key: FLINK-6375
URL: https://issues.apache.org/jira/browse/FLINK-6375
Project: Flink
Issue Type: Improvement
Components:
[
https://issues.apache.org/jira/browse/FLINK-6288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982277#comment-15982277
]
ASF GitHub Bot commented on FLINK-6288:
---
GitHub user fanyon opened a pull request:
GitHub user fanyon opened a pull request:
https://github.com/apache/flink/pull/3766
[FLINK-6288] fix FlinkKafkaProducer's custom Partitioner is always invoked
with number of partitions of default topic
1. add extra api addTopicPartitioner, user can use it to add special topic
and
zhangrucong1982 created FLINK-6374:
--
Summary: In yarn cluster model, the -ys parameter is not take
effect.
Key: FLINK-6374
URL: https://issues.apache.org/jira/browse/FLINK-6374
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982255#comment-15982255
]
ASF GitHub Bot commented on FLINK-6295:
---
Github user WangTaoTheTonic commented on the issue:
Github user WangTaoTheTonic commented on the issue:
https://github.com/apache/flink/pull/3709
@StephanEwen Sure. The current fix is like a "pull", while what you suggest
is a "push" way. Both them can fix just make difference in how the EGs being
updated.
---
If your project is set
GitHub user zhangminglei reopened a pull request:
https://github.com/apache/flink/pull/3758
[FLINK-5855][Streaming Connectors] Unprotected access to pendingFilesâ¦
â¦PerCheckpoint in BucketingSink.
Thanks for contributing to Apache Flink. Before you open your pull
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982231#comment-15982231
]
ASF GitHub Bot commented on FLINK-5855:
---
Github user zhangminglei closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982232#comment-15982232
]
ASF GitHub Bot commented on FLINK-5855:
---
GitHub user zhangminglei reopened a pull request:
Github user zhangminglei closed the pull request at:
https://github.com/apache/flink/pull/3758
---
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
[
https://issues.apache.org/jira/browse/FLINK-5855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982229#comment-15982229
]
ASF GitHub Bot commented on FLINK-5855:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/3758
@kl0u Thanks for review , very appreciate it. Yep, BTW, I would like to
work on what you will thorough the code in the following days and keep watching
this class ```synchronized()```. Hopes
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982039#comment-15982039
]
ASF GitHub Bot commented on FLINK-6361:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982038#comment-15982038
]
ASF GitHub Bot commented on FLINK-6361:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982036#comment-15982036
]
ASF GitHub Bot commented on FLINK-6361:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982034#comment-15982034
]
ASF GitHub Bot commented on FLINK-6361:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982037#comment-15982037
]
ASF GitHub Bot commented on FLINK-6361:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982035#comment-15982035
]
ASF GitHub Bot commented on FLINK-6361:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15982040#comment-15982040
]
ASF GitHub Bot commented on FLINK-6361:
---
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/3762#discussion_r113072931
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1259,7 +1301,7 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3762#discussion_r113072758
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1232,12 +1266,20 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3762#discussion_r113072949
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -1281,7 +1323,7 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3762#discussion_r113073730
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/aggregate/BoundedProcessingOverRangeProcessFunctionTest.scala
---
@@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3762#discussion_r113067259
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/AggregateFunction.scala
---
@@ -17,36 +17,93 @@
*/
package
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3762#discussion_r113066365
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/AggregateFunction.scala
---
@@ -17,36 +17,93 @@
*/
package
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3762#discussion_r113065861
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -471,31 +480,36 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-4897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eron Wright reassigned FLINK-4897:
---
Assignee: Eron Wright
Fix Version/s: (was: 1.3.0)
> Implement Dispatcher
>
Github user rbonifacio commented on a diff in the pull request:
https://github.com/apache/flink/pull/3757#discussion_r113068939
--- Diff:
flink-connectors/flink-avro/src/main/java/org/apache/flink/api/java/io/AvroOutputFormat.java
---
@@ -125,9 +125,7 @@ public void open(int
[
https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981948#comment-15981948
]
ASF GitHub Bot commented on FLINK-6373:
---
Github user haohui commented on the issue:
Github user haohui commented on the issue:
https://github.com/apache/flink/pull/3765
Note that this PR contains minimal amount of tests. Would love the
feedbacks on what kinds of tests are required here.
---
If your project is set up for it, you can reply to this email and have your
GitHub user haohui opened a pull request:
https://github.com/apache/flink/pull/3765
[FLINK-6373] Add runtime support for distinct aggregation over grouped
windows
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/haohui/flink
[
https://issues.apache.org/jira/browse/FLINK-6373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981934#comment-15981934
]
ASF GitHub Bot commented on FLINK-6373:
---
GitHub user haohui opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981878#comment-15981878
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113043582
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -255,17 +256,23 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981891#comment-15981891
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981873#comment-15981873
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113048361
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -118,7 +130,7 @@ object
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981887#comment-15981887
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113044998
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/BatchScan.scala
---
@@ -38,7 +39,9 @@ trait BatchScan
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113048128
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -102,13 +110,17 @@ object
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981880#comment-15981880
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113045326
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala
---
@@ -45,7 +45,7 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113050568
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRowsOver.scala
---
@@ -48,15 +49,15 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113047487
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -46,12 +47,12 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981885#comment-15981885
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113048214
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -102,13 +110,17 @@ object
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981872#comment-15981872
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981893#comment-15981893
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r112901336
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -723,11 +738,11 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981884#comment-15981884
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r112902344
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/types/CRowTypeInfo.scala
---
@@ -0,0 +1,86 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981877#comment-15981877
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981895#comment-15981895
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113050330
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -69,10 +70,10 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981870#comment-15981870
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981889#comment-15981889
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981883#comment-15981883
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981886#comment-15981886
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981881#comment-15981881
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981894#comment-15981894
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981874#comment-15981874
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981892#comment-15981892
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981879#comment-15981879
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981882#comment-15981882
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r112901608
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -723,11 +738,11 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981890#comment-15981890
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981888#comment-15981888
]
ASF GitHub Bot commented on FLINK-6091:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981869#comment-15981869
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113049726
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -47,12 +48,12 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113049930
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -69,10 +70,10 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981867#comment-15981867
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113049237
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GeneratedAggregations.scala
---
@@ -31,35 +32,35 @@ abstract
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981871#comment-15981871
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113043191
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenUtils.scala
---
@@ -233,6 +234,9 @@ object CodeGenUtils {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113051216
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/TimeWindowPropertyCollector.scala
---
@@ -19,34 +19,44 @@
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113049009
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggReduceGroupFunction.scala
---
@@ -66,7
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113046533
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala
---
@@ -92,11 +92,13 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113046948
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamRel.scala
---
@@ -22,17 +22,16 @@ import
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113050816
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -82,9 +83,9 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981875#comment-15981875
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r112901968
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/calcite/FlinkTypeFactory.scala
---
@@ -175,14 +176,19 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113048689
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -179,7 +198,9 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113043078
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -627,24 +640,27 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981876#comment-15981876
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113051486
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/types/CRow.scala
---
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113050047
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeBoundedRangeOver.scala
---
@@ -93,7 +94,7 @@ class
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113048507
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -159,18 +174,22 @@ object
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981868#comment-15981868
]
ASF GitHub Bot commented on FLINK-6091:
---
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/3733#discussion_r113047960
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -61,23 +62,28 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3733#discussion_r113044668
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonCalc.scala
---
@@ -23,26 +23,28 @@ import
[
https://issues.apache.org/jira/browse/FLINK-5781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15981856#comment-15981856
]
ASF GitHub Bot commented on FLINK-5781:
---
Github user zentol commented on the issue:
1 - 100 of 204 matches
Mail list logo
