[
https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538720#comment-16538720
]
Chesnay Schepler edited comment on FLINK-9792 at 7/10/18 2:59 PM:
--
The
GitHub user linjun007 opened a pull request:
https://github.com/apache/flink/pull/6296
解å³flink-dist*.jarå¤æ¬¡ä¸ä¼
*Thank you very much for contributing to Apache Flink - we are happy that
you want to help us improve Flink. To help the community review your
contribution in
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linzhongjun updated FLINK-9793:
---
Summary: When flink on yarn is submitted with yarn-cluster, flink-dist*.
Jar is repeatedly uploaded
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linzhongjun updated FLINK-9793:
---
Description:
Our company is using flink1.4.2，When the flink program is submitted to run on
yarn,To
[
https://issues.apache.org/jira/browse/FLINK-9787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Florian Schmidt reassigned FLINK-9787:
--
Assignee: (was: Florian Schmidt)
> Change ExecutionConfig#getGlobalJobParameters
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linzhongjun updated FLINK-9793:
---
Attachment: 20180710231518.png
> When flink on yarn is submitted with yarn-cluster, flink-dist*. Jar
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538765#comment-16538765
]
ASF GitHub Bot commented on FLINK-9777:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6297
[FLINK-9777] YARN: JM and TM Memory must be specified with Units
## What is the purpose of the change
*This pull request specify unit for JM and TM memory on YARN mode*
##
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9777:
--
Labels: pull-request-available (was: )
> YARN: JM and TM Memory must be specified with Units
[
https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538766#comment-16538766
]
Dawid Wysakowicz commented on FLINK-9792:
-
I see your point. Nevertheless I think it would be
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6296
Please update the JIRA and this PR with an english title and description of
the problem.
---
GitHub user nekrassov opened a pull request:
https://github.com/apache/flink/pull/6298
[FLINK-9784] Fix inconsistent use of 'static' in AsyncIOExample.java
## What is the purpose of the change
This patch fixes inconsistent use of `static` in AsyncIOExample.java that
can
[
https://issues.apache.org/jira/browse/FLINK-9784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538773#comment-16538773
]
ASF GitHub Bot commented on FLINK-9784:
---
GitHub user nekrassov opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9784:
--
Labels: pull-request-available (was: )
> Inconsistent use of 'static' in AsyncIOExample.java
[
https://issues.apache.org/jira/browse/FLINK-9791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9791:
---
Assignee: vinoyang
> Outdated savepoint compatibility table
>
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9793:
---
Assignee: vinoyang
> When flink on yarn is submitted with yarn-cluster, flink-dist*. Jar is
>
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201400623
--- Diff:
flink-core/src/test/java/org/apache/flink/core/fs/AbstractResumableWriterTest.java
---
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201369555
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
---
@@ -253,4
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201374783
--- Diff:
flink-core/src/test/java/org/apache/flink/core/fs/local/LocalFileSystemResumableWriterTest.java
---
@@ -0,0 +1,45 @@
+/*
+ * Licensed
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201374633
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
---
@@ -253,4
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201375290
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java
---
@@ -130,7 +130,7 @@ public static boolean
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201401033
--- Diff:
flink-core/src/test/java/org/apache/flink/core/fs/AbstractResumableWriterTest.java
---
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6281#discussion_r201375170
--- Diff:
flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java
---
@@ -41,6 +44,8
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538909#comment-16538909
]
Leonid Ishimnikov commented on FLINK-9649:
--
The Mesos documentation page seems to be generally
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539059#comment-16539059
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user medcv commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538816#comment-16538816
]
ASF GitHub Bot commented on FLINK-9013:
---
Github user dawidwys commented on a diff in the pull
Chesnay Schepler created FLINK-9796:
---
Summary: Add failure handling to release guide
Key: FLINK-9796
URL: https://issues.apache.org/jira/browse/FLINK-9796
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539020#comment-16539020
]
ASF GitHub Bot commented on FLINK-9483:
---
Github user bowenli86 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler resolved FLINK-9789.
-
Resolution: Fixed
1.5: a0a810720d251fb9ab6a4cf9d995828d99a3f2c8
> Watermark metrics for
GitHub user glaksh100 opened a pull request:
https://github.com/apache/flink/pull/6300
[FLINK-9692] Adaptive reads from Kinesis
## What is the purpose of the change
The purpose of this change is to provide an option to the Kinesis connector
to optimize the amount of data
[
https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9692:
--
Labels: performance pull-request-available (was: performance)
> Adapt maxRecords parameter in
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9793:
---
Assignee: (was: vinoyang)
> When flink on yarn is submitted with yarn-cluster, flink-dist*. Jar
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538793#comment-16538793
]
vinoyang commented on FLINK-9793:
-
[~till.rohrmann] please give [~linjun] contribute permission to assign
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6294#discussion_r201399926
--- Diff: docs/ops/deployment/yarn_setup.md ---
@@ -132,7 +132,7 @@ Stop the YARN session by stopping the unix process
(using CTRL+C) or by entering
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonid Ishimnikov closed FLINK-9649.
Resolution: Not A Bug
Created a ticket for a documentation update:
[
https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539037#comment-16539037
]
ASF GitHub Bot commented on FLINK-9754:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539036#comment-16539036
]
ASF GitHub Bot commented on FLINK-9768:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6285
merging.
---
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6286
merging.
---
Github user medcv commented on the issue:
https://github.com/apache/flink/pull/6259
@dawidwys Thanks a lot for the review.
I will start look into both problems that you've pointed out.
Second point would be easy to fix but for the first one I need do some
research and see the
[
https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538832#comment-16538832
]
Chesnay Schepler edited comment on FLINK-9792 at 7/10/18 3:54 PM:
--
I
[
https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538879#comment-16538879
]
ASF GitHub Bot commented on FLINK-9768:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538880#comment-16538880
]
ASF GitHub Bot commented on FLINK-9754:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6286
+1
---
[
https://issues.apache.org/jira/browse/FLINK-9762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9762:
-
Fix Version/s: 1.6.0
1.5.2
> CoreOptions.TMP_DIRS wrongly managed on Yarn
>
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6275
All right, thanks, merging!
---
Github user jgrier commented on the issue:
https://github.com/apache/flink/pull/6290
ð
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6294#discussion_r201398701
--- Diff: docs/ops/deployment/yarn_setup.md ---
@@ -132,7 +132,7 @@ Stop the YARN session by stopping the unix process
(using CTRL+C) or by entering
[
https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538832#comment-16538832
]
Chesnay Schepler commented on FLINK-9792:
-
I like that idea more than adding html directly, and
[
https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538835#comment-16538835
]
ASF GitHub Bot commented on FLINK-9013:
---
Github user zentol commented on a diff in the pull
wangsan created FLINK-9794:
--
Summary: JDBCOutputFormat does not consider idle connection and
multithreads synchronization
Key: FLINK-9794
URL: https://issues.apache.org/jira/browse/FLINK-9794
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538919#comment-16538919
]
ASF GitHub Bot commented on FLINK-9776:
---
Github user StephanEwen commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538988#comment-16538988
]
Chesnay Schepler commented on FLINK-9792:
-
For starters I would probably go with a simple DSL:
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538859#comment-16538859
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538857#comment-16538857
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538855#comment-16538855
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538858#comment-16538858
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538856#comment-16538856
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538860#comment-16538860
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538854#comment-16538854
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9713:
--
Labels: pull-request-available (was: )
> Support versioned joins in planning phase
>
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538904#comment-16538904
]
ASF GitHub Bot commented on FLINK-9713:
---
GitHub user pnowojski opened a pull request:
Leonid Ishimnikov created FLINK-9795:
Summary: Update Mesos documentation for flip6
Key: FLINK-9795
URL: https://issues.apache.org/jira/browse/FLINK-9795
Project: Flink
Issue Type:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/6109
cc @zentol
---
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9483:
--
Labels: pull-request-available (was: )
> "Building Flink" doc doesn't highlight quick build
[
https://issues.apache.org/jira/browse/FLINK-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538840#comment-16538840
]
ASF GitHub Bot commented on FLINK-9013:
---
Github user dawidwys commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingcan Cui reassigned FLINK-9790:
--
Assignee: Xingcan Cui
> Add documentation for UDF in SQL Client
>
Github user dawidwys commented on a diff in the pull request:
https://github.com/apache/flink/pull/6294#discussion_r201394304
--- Diff: docs/ops/deployment/yarn_setup.md ---
@@ -132,7 +132,10 @@ Stop the YARN session by stopping the unix process
(using CTRL+C) or by entering
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6290
Thanks, merging this...
---
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/6299
[FLINK-9713][table][sql] Support versioned join in planning phase
## What is the purpose of the change
This PR introduces provides a way to define Table Version Functions in
Table API
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6296
@linjun007 thanks for your contribution, please rename the PR's title based
on this description :
```
Name the pull request in the form "[FLINK-] [component] Title of the
pull
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6296#discussion_r201396143
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -1189,9 +1189,9 @@ private static Path
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reassigned FLINK-9793:
---
Assignee: linzhongjun
> When flink on yarn is submitted with yarn-cluster,
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16538863#comment-16538863
]
Florian Schmidt commented on FLINK-8985:
Hey,
I was playing around with the CLI a little bit as
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6285
+1
---
[
https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539095#comment-16539095
]
ASF GitHub Bot commented on FLINK-9692:
---
GitHub user glaksh100 opened a pull request:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6275
---
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6290
---
[
https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539105#comment-16539105
]
ASF GitHub Bot commented on FLINK-9776:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539348#comment-16539348
]
ASF GitHub Bot commented on FLINK-9785:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/6291
@yanghua sure, why not ... although there's no performance problem in
string concatenation for exceptions - we'll abort anyway
---
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539256#comment-16539256
]
Rong Rong commented on FLINK-8985:
--
Thanks [~florianschmidt] for the exhausted listing for all CLI.
[
https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539196#comment-16539196
]
ASF GitHub Bot commented on FLINK-9692:
---
Github user glaksh100 commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539385#comment-16539385
]
ASF GitHub Bot commented on FLINK-9777:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6297
@GJL please review~
---
[
https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Rao reassigned FLINK-9692:
--
Assignee: Lakshmi Rao
> Adapt maxRecords parameter in the getRecords call to optimize bytes
Github user glaksh100 commented on the issue:
https://github.com/apache/flink/pull/6300
@fhueske @tzulitai @tweise Can you please take a look when you have a
chance?
---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/6115
alright - tried that change which also has the advantage of not using up
memory for the `templateKey` - these are the results from the same Benchmark
(same hardware, new software though, so I also
[
https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9435:
--
Labels: pull-request-available (was: )
> Remove per-key selection Tuple instantiation via
[
https://issues.apache.org/jira/browse/FLINK-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539274#comment-16539274
]
ASF GitHub Bot commented on FLINK-9435:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9794:
---
Assignee: vinoyang
> JDBCOutputFormat does not consider idle connection and multithreads
>
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16539465#comment-16539465
]
ASF GitHub Bot commented on FLINK-9794:
---
GitHub user jrthe42 opened a pull request:
Github user linjun007 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6296#discussion_r201543969
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -1189,9 +1189,9 @@ private static Path
GitHub user jrthe42 opened a pull request:
https://github.com/apache/flink/pull/6301
[FLINK-9794] [jdbc] JDBCOutputFormat does not consider idle connection and
multithreads synchronization
## What is the purpose of the change
This pull request fix bugs in original
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9794:
--
Labels: pull-request-available (was: )
> JDBCOutputFormat does not consider idle connection
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linzhongjun updated FLINK-9793:
---
Description:
We are using flink1.4.2 in our company. When the flink job is submitted to run
on yarn
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/6296#discussion_r201570938
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -1189,7 +1189,7 @@ private static Path
[
https://issues.apache.org/jira/browse/FLINK-9793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linzhongjun updated FLINK-9793:
---
Priority: Minor (was: Major)
> When flink on yarn is submitted with yarn-cluster, flink-dist*. Jar
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9794:
---
Assignee: (was: vinoyang)
> JDBCOutputFormat does not consider idle connection and multithreads
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r201552317
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -41,6 +43,8 @@
public class
201 - 300 of 328 matches
Mail list logo
