Timo Walther created FLINK-8650:
---
Summary: Add tests and documentation for WINDOW clause
Key: FLINK-8650
URL: https://issues.apache.org/jira/browse/FLINK-8650
Project: Flink
Issue Type: Improve
[
https://issues.apache.org/jira/browse/FLINK-6352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363556#comment-16363556
]
ASF GitHub Bot commented on FLINK-6352:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5282
@aljoscha this is the currently the case for any startup mode. Any
partition discovered after the initial batch fetch is considered a new
partition due to Kafka scale outs, and is therefore read fro
[
https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363537#comment-16363537
]
ASF GitHub Bot commented on FLINK-8560:
---
GitHub user bowenli86 opened a pull request
GitHub user bowenli86 opened a pull request:
https://github.com/apache/flink/pull/5481
[FLINK-8560] Access to the current key in ProcessFunction after keyBy()
## What is the purpose of the change
Currently, it is required to store the key of a keyBy() in the
processElement
[
https://issues.apache.org/jira/browse/FLINK-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363521#comment-16363521
]
ASF GitHub Bot commented on FLINK-8553:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5418
cc @zentol
---
[
https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363295#comment-16363295
]
ASF GitHub Bot commented on FLINK-8648:
---
Github user tweise commented on the issue:
Github user tweise commented on the issue:
https://github.com/apache/flink/pull/5480
R: @tzulitai
---
[
https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363289#comment-16363289
]
ASF GitHub Bot commented on FLINK-8648:
---
GitHub user tweise opened a pull request:
GitHub user tweise opened a pull request:
https://github.com/apache/flink/pull/5480
[FLINK-8648] [kinesis] Allow for customization of emitRecordAndUpdateState
in Kinesis connector.
## What is the purpose of the change
Allow customization of record emission in the Kinesis co
[
https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reopened FLINK-7343:
--
It happened again :(
https://api.travis-ci.org/v3/job/340947835/log.txt
> Kafka010ProducerITCase i
[
https://issues.apache.org/jira/browse/FLINK-8401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363087#comment-16363087
]
ASF GitHub Bot commented on FLINK-8401:
---
Github user suez1224 commented on the issue
Github user suez1224 commented on the issue:
https://github.com/apache/flink/pull/5274
@tillrohrmann , can you help take another look?
---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5419
Can we also add timestamps to the surefire messages using
`systemPropertyVariables`?
https://gualtierotesta.wordpress.com/2015/11/01/tutorial-logging-during-tests/
http://maven.apache
[
https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363057#comment-16363057
]
ASF GitHub Bot commented on FLINK-8574:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362887#comment-16362887
]
ASF GitHub Bot commented on FLINK-8411:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5300
NVM, I double checked that this PR is in 1.5.0.
---
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362848#comment-16362848
]
ASF GitHub Bot commented on FLINK-8411:
---
Github user bowenli86 commented on the issu
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5300
@aljoscha @StefanRRichter isn't this PR merged into 1.5.0?
---
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362843#comment-16362843
]
Bowen Li commented on FLINK-8411:
-
[~aljoscha]
For the 1st functionality, isn't [the PR o
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167903512
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java
---
@@ -0,0 +1,69 @@
+/*
+ * License
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167953460
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362788#comment-16362788
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167871796
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362816#comment-16362816
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362809#comment-16362809
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362811#comment-16362811
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362792#comment-16362792
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362807#comment-16362807
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362785#comment-16362785
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167889717
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliChangelogResultView.java
---
@@ -0,0 +1,284 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362810#comment-16362810
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362782#comment-16362782
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362799#comment-16362799
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362784#comment-16362784
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362790#comment-16362790
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362780#comment-16362780
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167917093
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362814#comment-16362814
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362804#comment-16362804
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167916900
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362786#comment-16362786
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r16794
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167951055
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362791#comment-16362791
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362802#comment-16362802
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167939768
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362789#comment-16362789
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362815#comment-16362815
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167944240
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ResultStore.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licens
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167921047
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362800#comment-16362800
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362794#comment-16362794
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362803#comment-16362803
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167871058
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167953650
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362805#comment-16362805
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362796#comment-16362796
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362793#comment-16362793
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167914210
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -0,0 +1,121 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362787#comment-16362787
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167922399
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ResultStore.java
---
@@ -0,0 +1,124 @@
+/*
+ * Licens
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362801#comment-16362801
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167896355
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/CollectTableSink.java
---
@@ -0,0 +1,116 @@
+/*
+ * L
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167949288
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362812#comment-16362812
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362797#comment-16362797
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167921296
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167912319
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362781#comment-16362781
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362779#comment-16362779
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362783#comment-16362783
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167952297
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167898913
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362808#comment-16362808
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167912662
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167936060
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -0,0 +1,121 @@
+/*
+ * License
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362795#comment-16362795
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362798#comment-16362798
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362813#comment-16362813
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362806#comment-16362806
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167881723
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167921412
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/PropertyStrings.java
---
@@ -0,0 +1,63 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167947410
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/DynamicResult.java
---
@@ -0,0 +1,253 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167938697
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167902843
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/TypedResult.java
---
@@ -0,0 +1,69 @@
+/*
+ * License
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167880842
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167880856
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167869733
--- Diff: flink-libraries/flink-sql-client/bin/sql-client.sh ---
@@ -0,0 +1,83 @@
+#!/usr/bin/env bash
+#
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167892881
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/CollectTableSink.java
---
@@ -0,0 +1,116 @@
+/*
+ * L
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167882975
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/SqlClient.java
---
@@ -0,0 +1,181 @@
+/*
+ * Licensed to the
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167909635
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ * Lice
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167872946
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167870419
--- Diff: flink-libraries/flink-sql-client/conf/sql-client-defaults.yaml ---
@@ -0,0 +1,47 @@
+##
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167871291
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/20
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5441#discussion_r167869958
--- Diff: flink-libraries/flink-sql-client/conf/sql-client-defaults.yaml ---
@@ -0,0 +1,47 @@
+##
GitHub user ggevay opened a pull request:
https://github.com/apache/flink/pull/5479
[FLINK-8649] [scala api] Pass on TypeInfo in
StreamExecutionEnvironment.createInput
## What is the purpose of the change
In the Scala API, modify `StreamExecutionEnvironment.createInput` to
[
https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362771#comment-16362771
]
ASF GitHub Bot commented on FLINK-8649:
---
GitHub user ggevay opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16362722#comment-16362722
]
ASF GitHub Bot commented on FLINK-8533:
---
Github user EronWright commented on the iss
1 - 100 of 372 matches
Mail list logo
