[
https://issues.apache.org/jira/browse/FLINK-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961705#comment-15961705
]
ASF GitHub Bot commented on FLINK-6282:
---
GitHub user lingjinjiang opened a pull requ
GitHub user lingjinjiang opened a pull request:
https://github.com/apache/flink/pull/3702
[FLINK-6282] Fix some spelling mistake
Find some words are spelled wrong.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lingjinjiang/flink
[
https://issues.apache.org/jira/browse/FLINK-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinjiang Ling updated FLINK-6282:
-
Description: I find some words are spelled wrong. (was: I find some words
were spelled wrong.)
>
[
https://issues.apache.org/jira/browse/FLINK-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinjiang Ling updated FLINK-6282:
-
Description: I find some words were spelled wrong. (was: I find some words
was spelled wrong.)
>
[
https://issues.apache.org/jira/browse/FLINK-6282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jinjiang Ling updated FLINK-6282:
-
Attachment: FLINK-6282-0.patch
> Some words was spelled wrong
>
>
>
Jinjiang Ling created FLINK-6282:
Summary: Some words was spelled wrong
Key: FLINK-6282
URL: https://issues.apache.org/jira/browse/FLINK-6282
Project: Flink
Issue Type: Bug
Report
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6162:
--
Affects Version/s: 1.3.0
> Fix bug in ByteArrayOutputStreamWithPos#setPosition
> ---
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6162.
-
Resolution: Fixed
Fixed in af34e5bd0bc8bf93c78b8bf37033ee660e7913be
> Fix bug in ByteArrayOutputStreamWit
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6162:
--
Fix Version/s: 1.3.0
> Fix bug in ByteArrayOutputStreamWithPos#setPosition
> ---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3595
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961580#comment-15961580
]
ASF GitHub Bot commented on FLINK-6162:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961495#comment-15961495
]
Fabian Hueske commented on FLINK-6233:
--
I think we only need to update previously emi
Haohui Mai created FLINK-6281:
-
Summary: Create TableSink for JDBC
Key: FLINK-6281
URL: https://issues.apache.org/jira/browse/FLINK-6281
Project: Flink
Issue Type: Improvement
Reporte
[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961480#comment-15961480
]
ASF GitHub Bot commented on FLINK-5256:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3673
Thanks for working on this @DmytroShkvyra. I'll be on vacation next week
but will review your PR when I am back.
Thanks, Fabian
---
If your project is set up for it, you can reply to this e
[
https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai closed FLINK-5622.
-
Resolution: Duplicate
> Support tumbling window on batch tables in the SQL API
> -
[
https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961476#comment-15961476
]
Haohui Mai commented on FLINK-5622:
---
I think so. Thanks for the reminder. I'll close thi
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961472#comment-15961472
]
Fabian Hueske commented on FLINK-5859:
--
Hi [~godfreyhe], FilterableTableSource has be
[
https://issues.apache.org/jira/browse/FLINK-5622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961469#comment-15961469
]
Fabian Hueske commented on FLINK-5622:
--
Hi [~wheat9], I think this is a duplicate of
[
https://issues.apache.org/jira/browse/FLINK-3851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-3851.
Resolution: Duplicate
Duplicate of FLINK-5570
> Add interface to register external catalogs in the
[
https://issues.apache.org/jira/browse/FLINK-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6204:
-
Issue Type: Improvement (was: Bug)
> Update all OVER window ProcessFunction implementations to u
[
https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haohui Mai reassigned FLINK-6225:
-
Assignee: Haohui Mai
> Support Row Stream for CassandraSink
> ---
[
https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6279.
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed with 697cc96106846547ff856aa5e478fee037ffde1a
>
[
https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961452#comment-15961452
]
ASF GitHub Bot commented on FLINK-6279:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3699
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110481685
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -0,0 +1,167 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110476516
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala
---
@@ -0,0 +1,367 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110483259
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SortAggFunction.scala
---
@@ -0,0 +1,166 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110479361
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -0,0 +1,167 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110480378
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala
---
@@ -0,0 +1,139
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110477811
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -0,0 +1,167 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110478103
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -0,0 +1,167 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110476920
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/aggfunctions/SortAggFunction.scala
---
@@ -0,0 +1,166 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110482967
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala
---
@@ -0,0 +1,139
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110477127
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamSortRule.scala
---
@@ -0,0 +1,67 @@
+/*
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110480674
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala
---
@@ -0,0 +1,139
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110479650
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/SortUtil.scala
---
@@ -0,0 +1,367 @@
+/*
+ * Licensed
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110481364
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/ProcTimeUnboundedSortProcessFunction.scala
---
@@ -0,0 +1,139
[
https://issues.apache.org/jira/browse/FLINK-6162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961379#comment-15961379
]
ASF GitHub Bot commented on FLINK-6162:
---
Github user greghogan commented on the issu
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3595
@wenlong88 thanks for the contribution (and the ping)! Merging ...
---
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 do
[
https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961333#comment-15961333
]
ASF GitHub Bot commented on FLINK-6279:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3699
Hi @godfreyhe, thanks for the fix!
Will merge this PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not hav
[
https://issues.apache.org/jira/browse/FLINK-6280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961174#comment-15961174
]
ASF GitHub Bot commented on FLINK-6280:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/3701
[FLINK-6280] [scripts] Allow logging with Java flags
Evaluate user-defined Java options immediately before starting services and
rotate all log files.
You can merge this pull request into a Git r
Greg Hogan created FLINK-6280:
-
Summary: Allow logging with Java flags
Key: FLINK-6280
URL: https://issues.apache.org/jira/browse/FLINK-6280
Project: Flink
Issue Type: Improvement
Compo
[
https://issues.apache.org/jira/browse/FLINK-6104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6104:
--
Description:
{code}
final WriteOptions write_options = new WriteOptions()
.setSync(false)
.s
[
https://issues.apache.org/jira/browse/FLINK-4540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961070#comment-15961070
]
ASF GitHub Bot commented on FLINK-4540:
---
Github user MayerRoman closed the pull requ
Github user MayerRoman closed the pull request at:
https://github.com/apache/flink/pull/3287
---
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-6210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15961024#comment-15961024
]
Ted Yu commented on FLINK-6210:
---
I agree all resources should be closed.
> RocksDB instance
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-6091:
---
Description:
Implement functions for generating and consuming retract messages for different
aggregat
[
https://issues.apache.org/jira/browse/FLINK-6091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-6091:
---
Summary: Implement and turn on the retraction for aggregates (was:
Implement and turn on the retracti
[
https://issues.apache.org/jira/browse/FLINK-6112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6112:
-
Summary: Support Calcite 1.12's new numerical functions (was: Support new
numerical functions whe
[
https://issues.apache.org/jira/browse/FLINK-5829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5829.
Resolution: Done
Fix Version/s: 1.3.0
> Bump Calcite version to 1.12 once available
> ---
[
https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5545.
Resolution: Fixed
Fix Version/s: 1.3.0
Fixed with 0038da41553908a427dd20be75838cccb48c6bcf
>
[
https://issues.apache.org/jira/browse/FLINK-6112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-6112:
-
Issue Type: New Feature (was: Sub-task)
Parent: (was: FLINK-5829)
> Support new numer
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3695
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960888#comment-15960888
]
ASF GitHub Bot commented on FLINK-6012:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6012.
Resolution: Implemented
Fix Version/s: 1.3.0
Implemented with fa7907ab0e90d182b6386802c97f9b4
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3693
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
[
https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960889#comment-15960889
]
ASF GitHub Bot commented on FLINK-5545:
---
Github user asfgit closed the pull request
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3700
I just realized that the commit does not have the proper name/number
---
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
Github user rtudoran commented on a diff in the pull request:
https://github.com/apache/flink/pull/3700#discussion_r110396436
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamSort.scala
---
@@ -0,0 +1,167 @@
+/*
+
Github user rtudoran commented on the issue:
https://github.com/apache/flink/pull/3700
@fhueske @shijinkui @hongyuhong @stefanobortoli @sunjincheng121 @twalthr
I have created a first implementation for supporting logical sort. As per
the discussion on the JIRA issue the inten
GitHub user rtudoran opened a pull request:
https://github.com/apache/flink/pull/3700
Backbone implementation for supporting sort. Implementation includes
util functions, sort aggregations (without retraction), rule and sort
cases identification
Thanks for contributing t
[
https://issues.apache.org/jira/browse/FLINK-6279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960809#comment-15960809
]
ASF GitHub Bot commented on FLINK-6279:
---
GitHub user godfreyhe opened a pull request
GitHub user godfreyhe opened a pull request:
https://github.com/apache/flink/pull/3699
[FLINK-6279] [table] fix bug: the digest of VolcanoRuleMatch matched â¦
toString of TableSourceScan should contain table name and result of
explainSource to distinguish the difference of table so
godfrey he created FLINK-6279:
-
Summary: the digest of VolcanoRuleMatch matched different table
sources with same field names may be same
Key: FLINK-6279
URL: https://issues.apache.org/jira/browse/FLINK-6279
[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960760#comment-15960760
]
ASF GitHub Bot commented on FLINK-2184:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960759#comment-15960759
]
ASF GitHub Bot commented on FLINK-6208:
---
GitHub user dawidwys opened a pull request:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3110
Thanks @gallenvara, the changes look good to me but we would also need a
few tests.
@aljoscha, what do you think about this change? Should we add it to be
consistent with the Java API or do
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/3698
[FLINK-6208] Implement skip till next match strategy
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3623#discussion_r110379778
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -382,7 +381,10 @@ object U
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960724#comment-15960724
]
ASF GitHub Bot commented on FLINK-6196:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960728#comment-15960728
]
ASF GitHub Bot commented on FLINK-6196:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960723#comment-15960723
]
ASF GitHub Bot commented on FLINK-6196:
---
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/3623#discussion_r110381407
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/DeferredTypeFlinkTableFunction.scala
---
@@ -40,6 +43,10 @@ class De
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960722#comment-15960722
]
ASF GitHub Bot commented on FLINK-6196:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960725#comment-15960725
]
ASF GitHub Bot commented on FLINK-6196:
---
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/3623#discussion_r110379996
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/schema/DeferredTypeFlinkTableFunction.scala
---
@@ -40,6 +43,10 @@ class De
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3623#discussion_r110381497
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedTableFunctions.scala
---
@@ -232,7 +244,8 @@ class DynamicSchem
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960726#comment-15960726
]
ASF GitHub Bot commented on FLINK-6196:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960727#comment-15960727
]
ASF GitHub Bot commented on FLINK-6196:
---
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/3623#discussion_r110378068
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala
---
@@ -382,7 +381,10 @@ object U
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3623#discussion_r110379666
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala
---
@@ -135,8 +135,11 @@ abstract class TableFunct
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3623#discussion_r110377050
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/TableFunction.scala
---
@@ -135,8 +135,11 @@ abstract class TableFunct
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3632
Updated for YARN @StephanEwen @EronWright
---
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-6176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960705#comment-15960705
]
ASF GitHub Bot commented on FLINK-6176:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960670#comment-15960670
]
ASF GitHub Bot commented on FLINK-5545:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3695
merging
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960634#comment-15960634
]
ASF GitHub Bot commented on FLINK-6012:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960632#comment-15960632
]
ASF GitHub Bot commented on FLINK-6012:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960633#comment-15960633
]
ASF GitHub Bot commented on FLINK-6012:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960636#comment-15960636
]
ASF GitHub Bot commented on FLINK-6012:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960637#comment-15960637
]
ASF GitHub Bot commented on FLINK-6012:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960635#comment-15960635
]
ASF GitHub Bot commented on FLINK-6012:
---
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/3693#discussion_r110361333
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala
---
@@ -0,0 +1,117 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3693#discussion_r110362433
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala
---
@@ -0,0 +1,117 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3693#discussion_r110362631
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala
---
@@ -0,0 +1,117 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3693#discussion_r110361425
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala
---
@@ -0,0 +1,117 @@
+/*
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3693#discussion_r110360562
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/common/WindowExpressionRule.scala
---
@@ -0,0 +1,117 @@
+/*
+
1 - 100 of 165 matches
Mail list logo
