Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167896900
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/AbstractCollectingResultPartitionWriter.java
---
@@ -0,0 +1,100
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167556014
--- Diff: flink-core/src/main/java/org/apache/flink/util/FutureUtil.java ---
@@ -45,4 +52,36 @@ private FutureUtil() {
return
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167556221
--- Diff: flink-core/src/main/java/org/apache/flink/util/FutureUtil.java ---
@@ -45,4 +52,36 @@ private FutureUtil() {
return
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167520277
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumer.java
---
@@ -0,0 +1,153 @@
+/*
+ * Licensed
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167604523
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -55,69 +51,56 @@
/**
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167879211
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
---
@@ -220,6 +273,19 @@ private void
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167860402
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -209,22 +171,38 @@ public void
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167527566
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/RecordSerializer.java
---
@@ -87,41 +86,12 @@ public
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167588455
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -111,93 +117,49 @@ public void
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167859598
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -111,93 +117,49 @@ public void
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167818220
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java
---
@@ -169,18 +170,60 @@ public
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167621132
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/Buffer.java
---
@@ -60,12 +60,20 @@
void tagAsEvent();
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167898515
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/api/writer/AbstractCollectingResultPartitionWriter.java
---
@@ -0,0 +1,100
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167596726
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -131,9 +114,9 @@ public void
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5423#discussion_r167883063
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java
---
@@ -151,64 +213,55 @@ private void
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/5478
[FLINK-8647] [flip6] Introduce JobMasterConfiguration
## What is the purpose of the change
This commit introduces a JobMasterConfiguration which contains JobMaster
specific
[
https://issues.apache.org/jira/browse/FLINK-8647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362459#comment-16362459
]
ASF GitHub Bot commented on FLINK-8647:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362595#comment-16362595
]
Shashank Agarwal commented on FLINK-7756:
-
[~aljoscha] I am building using SBT please find
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362610#comment-16362610
]
Shashank Agarwal commented on FLINK-7756:
-
That was the bug in version 1.3.2 during the build so I
[
https://issues.apache.org/jira/browse/FLINK-8645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362630#comment-16362630
]
Aljoscha Krettek commented on FLINK-8645:
-
+1 That makes a lot of sense.
> Support convenient
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362657#comment-16362657
]
Shashank Agarwal commented on FLINK-7756:
-
But this happens only when I choose rocksdb otherwise
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/5427
@StephanEwen do you mean that we could avoid adding an initialization
method to the hook interface? We need to somehow call into the hook to reset
its state, even when there's no checkpoint data
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362843#comment-16362843
]
Bowen Li commented on FLINK-8411:
-
[~aljoscha]
For the 1st functionality, isn't [the PR of this
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5477
Thanks @aljoscha ! Merged.
---
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362602#comment-16362602
]
Aljoscha Krettek commented on FLINK-7756:
-
Why is that last bit about netty versions needed?
>
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362625#comment-16362625
]
Aljoscha Krettek commented on FLINK-7756:
-
Could you try leaving that part out? The exception in
[
https://issues.apache.org/jira/browse/FLINK-8648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362624#comment-16362624
]
Thomas Weise commented on FLINK-8648:
-
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5477
---
[
https://issues.apache.org/jira/browse/FLINK-8642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362601#comment-16362601
]
ASF GitHub Bot commented on FLINK-8642:
---
Github user kl0u commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362609#comment-16362609
]
ASF GitHub Bot commented on FLINK-8642:
---
Github user asfgit closed the pull request at:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930454
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadResponseBody.java
---
@@ -0,0 +1,58 @@
+/*
+ *
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930421
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362645#comment-16362645
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362642#comment-16362642
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930349
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java
---
@@ -100,6 +107,16 @@ public DispatcherRestEndpoint(
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362653#comment-16362653
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362649#comment-16362649
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362652#comment-16362652
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362650#comment-16362650
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362648#comment-16362648
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362646#comment-16362646
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362651#comment-16362651
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362654#comment-16362654
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362681#comment-16362681
]
Aljoscha Krettek commented on FLINK-7756:
-
Thanks, trying without Cassandra but with RocksDB could
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 @@
+/*
+ *
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 @@
+/*
+ *
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 @@
+/*
+ *
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;
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;
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 @@
+/*
+ *
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 @@
+/*
+ *
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 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;
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_r167872946
--- Diff: flink-libraries/flink-sql-client/pom.xml ---
@@ -0,0 +1,149 @@
+
+
+http://maven.apache.org/POM/4.0.0;
[
https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362848#comment-16362848
]
ASF GitHub Bot commented on FLINK-8411:
---
Github user bowenli86 commented on the issue:
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-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362632#comment-16362632
]
Shashank Agarwal commented on FLINK-7756:
-
Sure, I will check that.
On Tue, 13 Feb 2018 at 10:21
[
https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8628:
Priority: Blocker (was: Critical)
> BucketingSink does not work with S3
>
[
https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362680#comment-16362680
]
Aljoscha Krettek commented on FLINK-8628:
-
I think the issues mentioned in those mail threads have
[
https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8628:
Fix Version/s: 1.5.0
> BucketingSink does not work with S3
>
[
https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362771#comment-16362771
]
ASF GitHub Bot commented on FLINK-8649:
---
GitHub user ggevay opened a pull request:
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-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362644#comment-16362644
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362641#comment-16362641
]
Aljoscha Krettek commented on FLINK-7756:
-
This might not be the problem, though, and there might
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930373
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ * Licensed
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930279
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930470
--- Diff:
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/ng/JarUploadHandler.java
---
@@ -0,0 +1,103 @@
+/*
+ * Licensed
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930317
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930401
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362643#comment-16362643
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-7713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362640#comment-16362640
]
ASF GitHub Bot commented on FLINK-7713:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930174
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r167930099
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java
---
@@ -207,6 +215,53 @@ public static WebMonitor
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5282
Initial question: why is the timestamp not used for newly discovered
partitions?
---
Gabor Gevay created FLINK-8649:
--
Summary: Scala StreamExecutionEnvironment.createInput should pass
on the TypeInfo
Key: FLINK-8649
URL: https://issues.apache.org/jira/browse/FLINK-8649
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362816#comment-16362816
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362809#comment-16362809
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362805#comment-16362805
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362796#comment-16362796
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167912662
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362811#comment-16362811
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362792#comment-16362792
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362802#comment-16362802
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167939768
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362807#comment-16362807
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362785#comment-16362785
]
ASF GitHub Bot commented on FLINK-8607:
---
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/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=16362810#comment-16362810
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362782#comment-16362782
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362793#comment-16362793
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167914210
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -0,0 +1,121 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362787#comment-16362787
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362799#comment-16362799
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362784#comment-16362784
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362790#comment-16362790
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362789#comment-16362789
]
ASF GitHub Bot commented on FLINK-8607:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16362780#comment-16362780
]
ASF GitHub Bot commented on FLINK-8607:
---
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/5441#discussion_r167917093
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/LocalExecutor.java
---
@@ -0,0 +1,445 @@
+/*
+ *
201 - 300 of 371 matches
Mail list logo
