[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shuyi Chen updated FLINK-8275:
--
Description: The local keytab path in YarnTaskManagerRunner is incorrectly
set to the
[
https://issues.apache.org/jira/browse/FLINK-8270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294631#comment-16294631
]
Tzu-Li (Gordon) Tai commented on FLINK-8270:
It seems like someone has just submitted a fix
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294630#comment-16294630
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5172
Thanks for the PR @suez1224.
There is a duplicate JIRA for this issue:
https://issues.apache.org/jira/browse/FLINK-8270.
Can you take a look at the suggestions explained in that JIRA, and
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294629#comment-16294629
]
Tzu-Li (Gordon) Tai commented on FLINK-8275:
This is a duplicate of FLINK-8270.
[~suez1224]
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5171
@bowenli86 I mean't the actual commit messages, not the PR title /
description.
The actual commit messages should follow our standard commit message
formats.
---
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294680#comment-16294680
]
Timo Walther commented on FLINK-8274:
-
Thanks for working on this. FLINK-8277 might also help in
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5173
[FLINK-8276] [kafka connector] Properly annotate API for kafka connector
## What is the purpose of the change
This PR is mainly for annotate elasticsearch connector API by means of
[
https://issues.apache.org/jira/browse/FLINK-8271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294653#comment-16294653
]
ASF GitHub Bot commented on FLINK-8271:
---
Github user tzulitai commented on the issue:
mingleizhang created FLINK-8276:
---
Summary: Annotation for Kafka connector
Key: FLINK-8276
URL: https://issues.apache.org/jira/browse/FLINK-8276
Project: Flink
Issue Type: Sub-task
Timo Walther created FLINK-8277:
---
Summary: Optimize code generation by using local references
Key: FLINK-8277
URL: https://issues.apache.org/jira/browse/FLINK-8277
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294766#comment-16294766
]
ASF GitHub Bot commented on FLINK-8276:
---
GitHub user zhangminglei opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-8268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-8268:
-
Labels: test-stability (was: )
> Test instability for 'TwoPhaseCommitSinkFunctionTest'
>
GitHub user Xpray opened a pull request:
https://github.com/apache/flink/pull/5174
[FLINK-8274][TableAPI & SQL] Fix Java 64K method compiling limitationâ¦
[FLINK-8274][TableAPI & SQL] Fix Java 64K method compiling limitation for
CommonCalc'
## What is the purpose of
[
https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294790#comment-16294790
]
ASF GitHub Bot commented on FLINK-8274:
---
GitHub user Xpray opened a pull request:
Nico Kruber created FLINK-8279:
--
Summary: Use Mesos/YARN temp directories as fallback for
BlobServer/Cache temp directories
Key: FLINK-8279
URL: https://issues.apache.org/jira/browse/FLINK-8279
Project:
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294656#comment-16294656
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5172
cc @EronWright, gentle ping since you mentioned to include you in the
review :)
---
[
https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294694#comment-16294694
]
Shuyi Chen commented on FLINK-7860:
---
I am proposing adding the following new options:
Fabian Hueske created FLINK-8278:
Summary: Scala examples in Metric documentation do not compile
Key: FLINK-8278
URL: https://issues.apache.org/jira/browse/FLINK-8278
Project: Flink
Issue
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4889#discussion_r157468208
--- Diff:
flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/testutils/category/Flip6.java
---
@@ -0,0 +1,25 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294896#comment-16294896
]
ASF GitHub Bot commented on FLINK-7903:
---
Github user GJL commented on a diff in the pull request:
brucewoo created FLINK-8281:
---
Summary: org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream
cannot be cast to org.apache.flink.core.fs.WrappingProxyCloseable
Key: FLINK-8281
URL:
Nico Kruber created FLINK-8280:
--
Summary: Enable checkstyle for org.apache.flink.runtime.blob
Key: FLINK-8280
URL: https://issues.apache.org/jira/browse/FLINK-8280
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
brucewoo updated FLINK-8281:
state.backend: rocksdb
state.backend: fliesystem
> org.apache.flink.runtime.fs.hdfs.HadoopDataOutputStream
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4889#discussion_r157481924
--- Diff: pom.xml ---
@@ -125,6 +125,9 @@ under the License.
1.6.5
1.3
false
+
--- End diff --
[
https://issues.apache.org/jira/browse/FLINK-7903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294960#comment-16294960
]
ASF GitHub Bot commented on FLINK-7903:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-8278:
--
Assignee: Xingcan Cui
> Scala examples in Metric documentation do not compile
>
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295132#comment-16295132
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user GJL closed the pull request at:
Nico Kruber created FLINK-8283:
--
Summary: FlinkKafkaConsumerBase failing on Travis with no output
in 10min
Key: FLINK-8283
URL: https://issues.apache.org/jira/browse/FLINK-8283
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-8280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294957#comment-16294957
]
ASF GitHub Bot commented on FLINK-8280:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5176
[FLINK-8279][blob] fall back to TaskManager temp directories first
## What is the purpose of the change
Instead of falling back to `java.io.tmpdir` directly, the BLOB server and
cache
Github user PedroMrChaves commented on the issue:
https://github.com/apache/flink/pull/4621
This change needs to also be added to previous versions. I'm using version
1.3.2 and realised that the initializeState(..) function was not being called.
---
Github user GJL closed the pull request at:
https://github.com/apache/flink/pull/5168
---
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294976#comment-16294976
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294970#comment-16294970
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294972#comment-16294972
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294968#comment-16294968
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294971#comment-16294971
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157480732
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/QueueStatus.java
---
@@ -0,0 +1,65 @@
+/*
+ * Licensed to
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157480619
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExecutionResultResponseBody.java
---
@@ -0,0 +1,69 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157479720
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExecutionResultResponseBody.java
---
@@ -0,0 +1,69 @@
+/*
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157482818
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -357,6 +362,28 @@ public void start() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157476788
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -357,6 +362,28 @@ public void start() throws
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157480094
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/json/SerializedValueSerializerTest.java
---
@@ -0,0 +1,81 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294975#comment-16294975
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294974#comment-16294974
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294977#comment-16294977
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294969#comment-16294969
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157476994
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java
---
@@ -0,0 +1,79 @@
+/*
+ * Licensed
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157475492
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/client/SerializedJobExecutionResult.java
---
@@ -55,6 +56,26 @@ public
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5168#discussion_r157477273
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobExecutionResultNotFoundException.java
---
@@ -0,0 +1,45 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-8278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295027#comment-16295027
]
ASF GitHub Bot commented on FLINK-8278:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5177
[FLINK-8278] [doc] Fix the private member init problem for Scala examples
in docs
## What is the purpose of the change
This PR fixes the improper initialization problem for Scala private
[
https://issues.apache.org/jira/browse/FLINK-8283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-8283:
---
Labels: test-stability (was: )
> FlinkKafkaConsumerBase failing on Travis with no output in 10min
>
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294973#comment-16294973
]
ASF GitHub Bot commented on FLINK-8234:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295128#comment-16295128
]
ASF GitHub Bot commented on FLINK-7495:
---
Github user PedroMrChaves commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294992#comment-16294992
]
ASF GitHub Bot commented on FLINK-8279:
---
GitHub user NicoK opened a pull request:
Timo Walther created FLINK-8282:
---
Summary: Transformation with TwoInputStreamOperator fails
Key: FLINK-8282
URL: https://issues.apache.org/jira/browse/FLINK-8282
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther updated FLINK-8282:
Affects Version/s: 1.4.0
> Transformation with TwoInputStreamOperator fails
>
[
https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295193#comment-16295193
]
Xingcan Cui commented on FLINK-8282:
Hi [~twalthr], thanks for this ticket. I just wonder whether we
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5175
[FLINK-8280][checkstyle] fix checkstyle in BlobServer and BlobUtils
## What is the purpose of the change
This commits enables checkstyle in the `org.apache.flink.runtime.blob`
package and
Julio Biason created FLINK-8284:
---
Summary: Custom metrics not being exposed for Prometheus
Key: FLINK-8284
URL: https://issues.apache.org/jira/browse/FLINK-8284
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295011#comment-16295011
]
ASF GitHub Bot commented on FLINK-8234:
---
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/5168#discussion_r157489280
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -357,6 +362,28 @@ public void start() throws Exception {
[
https://issues.apache.org/jira/browse/FLINK-8282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295207#comment-16295207
]
Timo Walther commented on FLINK-8282:
-
I don't know if this is needed. Actually, the {{transform()}}
[
https://issues.apache.org/jira/browse/FLINK-8234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294868#comment-16294868
]
ASF GitHub Bot commented on FLINK-8234:
---
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/5168#discussion_r157462859
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExecutionResult.java
---
@@ -0,0 +1,112 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294864#comment-16294864
]
ASF GitHub Bot commented on FLINK-7452:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/4612
@fhueske I would merge this later today if there are no objections.
---
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/5179
[FLINK-8260/8287] [kafka] Bunch of improvements to Kafka producer Javadocs
/ document
## What is the purpose of the change
This PR collects several improvements to the
[
https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jia liu reopened FLINK-8248:
It happened again, I've read the source code. Found that may be a bug at
[
https://issues.apache.org/jira/browse/FLINK-8248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296123#comment-16296123
]
jia liu edited comment on FLINK-8248 at 12/19/17 3:29 AM:
--
It happened again,
[
https://issues.apache.org/jira/browse/FLINK-8260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296200#comment-16296200
]
ASF GitHub Bot commented on FLINK-8260:
---
GitHub user tzulitai opened a pull request:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5178
+1, thanks for the fix.
Merging this ...
---
[
https://issues.apache.org/jira/browse/FLINK-7951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16296279#comment-16296279
]
ASF GitHub Bot commented on FLINK-7951:
---
Github user djh4230 commented on the issue:
Github user djh4230 commented on the issue:
https://github.com/apache/flink/pull/4926
Does that mean it's not a issue? But the issue still happened in
flink-1.4.How can i fix the issue?
---
[
https://issues.apache.org/jira/browse/FLINK-8279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295290#comment-16295290
]
ASF GitHub Bot commented on FLINK-8279:
---
Github user EronWright commented on a diff in the pull
Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/5172
This PR probably fixes the problem, but it would be good to address the
deeper problem that the code is confusing. At least we could add some
commentary to the code. The specific problems, in
[
https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295518#comment-16295518
]
Tzu-Li (Gordon) Tai commented on FLINK-8285:
Ah, sorry, I somehow was thinking of the
[
https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao updated FLINK-8281:
Description:
{noformat}
org.apache.flink.streaming.runtime.tasks.AsynchronousException:
[
https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295507#comment-16295507
]
Julio Biason commented on FLINK-8285:
-
[~tzulitai] Yeah, it's not relevant, because there is no
[
https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295518#comment-16295518
]
Tzu-Li (Gordon) Tai edited comment on FLINK-8285 at 12/18/17 7:24 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-8275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295515#comment-16295515
]
ASF GitHub Bot commented on FLINK-8275:
---
Github user EronWright commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295518#comment-16295518
]
Tzu-Li (Gordon) Tai edited comment on FLINK-8285 at 12/18/17 7:26 PM:
--
[
https://issues.apache.org/jira/browse/FLINK-8281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295806#comment-16295806
]
Stefan Richter commented on FLINK-8281:
---
Hi,
I had a look at your stacktraces and something seems
[
https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16294694#comment-16294694
]
Shuyi Chen edited comment on FLINK-7860 at 12/18/17 9:01 PM:
-
I am proposing
[
https://issues.apache.org/jira/browse/FLINK-7860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295656#comment-16295656
]
Shuyi Chen edited comment on FLINK-7860 at 12/18/17 9:11 PM:
-
Hi
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r157606329
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -61,9 +61,9 @@
*
[
https://issues.apache.org/jira/browse/FLINK-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295733#comment-16295733
]
ASF GitHub Bot commented on FLINK-3742:
---
Github user rawkintrevo commented on the issue:
Github user rawkintrevo closed the pull request at:
https://github.com/apache/flink/pull/1875
---
Github user rawkintrevo closed the pull request at:
https://github.com/apache/flink/pull/1865
---
[
https://issues.apache.org/jira/browse/FLINK-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295734#comment-16295734
]
ASF GitHub Bot commented on FLINK-3742:
---
Github user rawkintrevo closed the pull request at:
Github user rawkintrevo commented on the issue:
https://github.com/apache/flink/pull/1865
closing this
---
Github user rawkintrevo commented on the issue:
https://github.com/apache/flink/pull/1875
closing this
---
Shuyi Chen created FLINK-8286:
-
Summary: Investigate Flink-Yarn-Kerberos integration for flip-6
Key: FLINK-8286
URL: https://issues.apache.org/jira/browse/FLINK-8286
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295697#comment-16295697
]
ASF GitHub Bot commented on FLINK-8116:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/5121
Thanks @ankitiitb1069 @ggevay for the work and review.
The changes LGTM, minus my comment. I'll address my comments while merging
this ...
---
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16295695#comment-16295695
]
ASF GitHub Bot commented on FLINK-8116:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r157606375
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -61,9 +61,9 @@
*
1 - 100 of 156 matches
Mail list logo
