sunjincheng created FLINK-6959:
--
Summary: Add documentation for SQL OVER windows
Key: FLINK-6959
URL: https://issues.apache.org/jira/browse/FLINK-6959
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057103#comment-16057103
]
Fabian Hueske commented on FLINK-6959:
--
I don't think we need to add a specific section to the
Github user zjureel commented on a diff in the pull request:
https://github.com/apache/flink/pull/4075#discussion_r123180174
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
---
@@ -52,7 +52,74 @@
sunjincheng created FLINK-6960:
--
Summary: Add E(2.7182818284590452354),PI(3.14159265358979323846)
supported in SQL
Key: FLINK-6960
URL: https://issues.apache.org/jira/browse/FLINK-6960
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6847:
---
Labels: starter (was: )
> Add TIMESTAMPDIFF supported in TableAPI
>
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4152
[FLINK-6960][table] Add E supported in SQL.
In this PR. I have add Math.E supported in SQL.
- [x] General
- The pull request references the related JIRA issue
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057097#comment-16057097
]
Chesnay Schepler commented on FLINK-6655:
-
The stack trace is sufficient. The basic problem is
[
https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057147#comment-16057147
]
ASF GitHub Bot commented on FLINK-6494:
---
Github user zjureel commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057177#comment-16057177
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6926:
--
Assignee: Shaoxuan Wang (was: sunjincheng)
> Add MD5/SHA1/SHA2 supported in SQL
>
[
https://issues.apache.org/jira/browse/FLINK-6847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6847:
--
Assignee: (was: sunjincheng)
> Add TIMESTAMPDIFF supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057173#comment-16057173
]
ASF GitHub Bot commented on FLINK-6960:
---
GitHub user sunjincheng121 opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/4153
[FLINK-6927] [cep] Support pattern group in CEP
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your
[
https://issues.apache.org/jira/browse/FLINK-6927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057193#comment-16057193
]
ASF GitHub Bot commented on FLINK-6927:
---
GitHub user dianfu opened a pull request:
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123184832
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -1131,6 +1152,7 @@ private void serializeStates(Set
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057176#comment-16057176
]
Stefan Richter commented on FLINK-6633:
---
[~cre...@gmail.com], I think this log was already enough to
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123186831
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -1131,6 +1152,7 @@ private void serializeStates(Set
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057188#comment-16057188
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu updated FLINK-6960:
---
Labels: starter (was: )
> Add E(2.7182818284590452354),PI(3.14159265358979323846) supported in SQL
>
[
https://issues.apache.org/jira/browse/FLINK-6942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6942:
---
Labels: starter (was: )
> Add a document for the FLINK-6810 related scalar functions
>
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-6846:
--
Assignee: (was: sunjincheng)
> Add TIMESTAMPADD supported in TableAPI
>
[
https://issues.apache.org/jira/browse/FLINK-6846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng updated FLINK-6846:
---
Labels: starter (was: )
> Add TIMESTAMPADD supported in TableAPI
>
Github user tedyu commented on the issue:
https://github.com/apache/flink/pull/4151
lgtm
---
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-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viliam Durina closed FLINK-6953.
Resolution: Won't Fix
Not an issue in flink but rather in zookeeper.
> Ignore space after comman
[
https://issues.apache.org/jira/browse/FLINK-6953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057210#comment-16057210
]
Viliam Durina commented on FLINK-6953:
--
https://issues.apache.org/jira/browse/ZOOKEEPER-2814
>
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123204588
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -126,6 +129,7 @@ public
Github user dianfu commented on the issue:
https://github.com/apache/flink/pull/4145
Nice work. Just one comment: the states in NFA is metadata, maybe we should
get rid of serializing them at all?
---
If your project is set up for it, you can reply to this email and have your
reply
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057361#comment-16057361
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dianfu commented on the issue:
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/4145#discussion_r123192355
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
---
@@ -126,6 +129,7 @@ public
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057218#comment-16057218
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057216#comment-16057216
]
Aegeaner commented on FLINK-6958:
-
Maybe you could set a CountDownLatch, and call countdown in case of
Shaoxuan Wang created FLINK-6962:
Summary: SQL DDL for input and output tables
Key: FLINK-6962
URL: https://issues.apache.org/jira/browse/FLINK-6962
Project: Flink
Issue Type: New Feature
Shaoxuan Wang created FLINK-6963:
Summary: User Defined Operator
Key: FLINK-6963
URL: https://issues.apache.org/jira/browse/FLINK-6963
Project: Flink
Issue Type: New Feature
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4154
[Flink 6649][table]Improve Non-window group aggregate with update intâ¦
In this PR. I have improve Non-window group aggregate with update interval.
- [x] General
- The pull
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6655:
---
Assignee: mingleizhang
> Misleading error message when HistoryServer path is empty
>
[
https://issues.apache.org/jira/browse/FLINK-6938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057274#comment-16057274
]
ASF GitHub Bot commented on FLINK-6938:
---
Github user wuchong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-6897:
---
Assignee: Dawid Wysakowicz
> Re-add support for Java 8 lambdas in CEP library
>
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057203#comment-16057203
]
ASF GitHub Bot commented on FLINK-6960:
---
Github user wuchong commented on a diff in the pull
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4152#discussion_r123188958
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/functions/scalarSqlFunctions/MathSqlFunctions.scala
---
@@ -0,0 +1,35 @@
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4152#discussion_r123189112
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala
---
@@ -1116,6 +1116,13 @@ class
[
https://issues.apache.org/jira/browse/FLINK-6960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057204#comment-16057204
]
ASF GitHub Bot commented on FLINK-6960:
---
Github user wuchong commented on a diff in the pull
Github user sunjincheng121 closed the pull request at:
https://github.com/apache/flink/pull/4154
---
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
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057337#comment-16057337
]
mingleizhang commented on FLINK-6655:
-
Exactly. That is why I said it is not suitable fix in
[
https://issues.apache.org/jira/browse/FLINK-6389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057200#comment-16057200
]
ASF GitHub Bot commented on FLINK-6389:
---
Github user tedyu commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057209#comment-16057209
]
ASF GitHub Bot commented on FLINK-6498:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4123
@zentol Thank you for your suggestions. I have fixed them, thanks :)
---
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
[
https://issues.apache.org/jira/browse/FLINK-6494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057237#comment-16057237
]
ASF GitHub Bot commented on FLINK-6494:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4075#discussion_r123197240
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java
---
@@ -52,7 +52,74 @@
Shaoxuan Wang created FLINK-6961:
Summary: Enable configurable early-firing rate
Key: FLINK-6961
URL: https://issues.apache.org/jira/browse/FLINK-6961
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-6633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057249#comment-16057249
]
Stefan Richter commented on FLINK-6633:
---
I created https://issues.apache.org/jira/browse/FLINK-6964
Stefan Richter created FLINK-6964:
-
Summary: Fix recovery for incremental checkpoints in
StandaloneCompletedCheckpointStore
Key: FLINK-6964
URL: https://issues.apache.org/jira/browse/FLINK-6964
[
https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057374#comment-16057374
]
ASF GitHub Bot commented on FLINK-6940:
---
Github user zentol commented on a diff in the pull request:
Github user zhangminglei closed the pull request at:
https://github.com/apache/flink/pull/4155
---
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-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057414#comment-16057414
]
ASF GitHub Bot commented on FLINK-6655:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057466#comment-16057466
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123031759
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123016738
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057460#comment-16057460
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057479#comment-16057479
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057458#comment-16057458
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123009399
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123228354
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123233427
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/JoinTest.scala
---
@@ -0,0 +1,149 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057469#comment-16057469
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123035300
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123228716
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123030850
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057476#comment-16057476
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123226695
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057477#comment-16057477
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123236585
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/harness/JoinHarnessTest.scala
---
@@ -0,0 +1,200 @@
+/*
+ *
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/4157
[Flink 6649][table]Improve Non-window group aggregate with update intâ¦
In this PR. I have add supports updating the calculated data according to
the specified time interval on non-window
[
https://issues.apache.org/jira/browse/FLINK-6949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mikhail Pryakhin updated FLINK-6949:
Description:
*The problem:*
When deploying a flink job on YARN it is not possible to
[
https://issues.apache.org/jira/browse/FLINK-6907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-6907:
Summary: Adjust TupleGenerator javadocs in flink-java (was: Remove
TupleGenerator in
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4155
Flink 6655 misleading error message historyserver
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r122842288
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonJoin.scala
---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123003230
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123028155
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/JoinUtil.scala
---
@@ -0,0 +1,385 @@
+/*
+ * Licensed to
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r122841979
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonJoin.scala
---
@@ -0,0 +1,51 @@
+/*
+ * Licensed to
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4136#discussion_r123228173
--- Diff: docs/ops/state_backends.md ---
@@ -124,7 +124,7 @@ RocksDBStateBackend is currently the only backend that
offers incremental checkp
##
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4156
[FLINK-6655] Add validateAndNormalizeUri method to MemoryArchivist
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into
[
https://issues.apache.org/jira/browse/FLINK-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057411#comment-16057411
]
ASF GitHub Bot commented on FLINK-6655:
---
GitHub user zhangminglei opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057441#comment-16057441
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057462#comment-16057462
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057452#comment-16057452
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057443#comment-16057443
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057468#comment-16057468
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057457#comment-16057457
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123209008
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123231612
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/JoinITCase.scala
---
@@ -0,0 +1,204 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123231931
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/JoinITCase.scala
---
@@ -0,0 +1,204 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123189670
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/JoinITCase.scala
---
@@ -0,0 +1,204 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123225232
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057454#comment-16057454
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123232793
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/JoinTest.scala
---
@@ -0,0 +1,149 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057475#comment-16057475
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057483#comment-16057483
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16057481#comment-16057481
]
ASF GitHub Bot commented on FLINK-6232:
---
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/3715#discussion_r123229245
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r123227488
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/join/ProcTimeInnerJoin.scala
---
@@ -0,0 +1,316 @@
+/*
+ *
1 - 100 of 270 matches
Mail list logo
