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 setupSingleLocalResour
[
https://issues.apache.org/jira/browse/FLINK-9687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539580#comment-16539580
]
ASF GitHub Bot commented on FLINK-9687:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6224
Aha, I meat to improve the performance of windowOperator, In the scenario
mentioned in the issue, this PR can avoid that bug, lucky hit ;-)
---
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r201558827
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -41,6 +43,8 @@
public class JDBCOutp
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539528#comment-16539528
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user yanghua commented on a diff in
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6296
@linjun007 please rename the PR title
---
GitHub user indrc opened a pull request:
https://github.com/apache/flink/pull/6302
[FLINK-9061][checkpointing] add entropy to s3 path for better scalability
## What is the purpose of the change
*This pull request adds entropy to the checkpoint path based upon a user
define
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9061:
--
Labels: pull-request-available (was: )
> add entropy to s3 path for better scalability
> -
[
https://issues.apache.org/jira/browse/FLINK-9061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539526#comment-16539526
]
ASF GitHub Bot commented on FLINK-9061:
---
GitHub user indrc opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539508#comment-16539508
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user jrthe42 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539510#comment-16539510
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user jrthe42 commented on a diff in
Github user jrthe42 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r201555608
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -41,6 +43,8 @@
public class JDBCOutp
Github user jrthe42 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r20190
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java
---
@@ -115,6 +119,16 @@ public JDBCAp
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539507#comment-16539507
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user jrthe42 commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539511#comment-16539511
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user jrthe42 commented on a diff in
Github user jrthe42 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r20198
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -54,6 +58,10 @@
private Connectio
Github user jrthe42 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r20175
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java
---
@@ -115,6 +119,16 @@ public JDBCAp
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539498#comment-16539498
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user Aitozi commented on the issue:
Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6205
Resolved the conflicts, please help review when you free @dawidwys .
---
Github user linjun007 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6296#discussion_r201553199
--- Diff:
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
---
@@ -1189,9 +1189,9 @@ private static Path setupSingleLocal
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539488#comment-16539488
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user yanghua commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539486#comment-16539486
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user yanghua commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539487#comment-16539487
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user yanghua commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539489#comment-16539489
]
ASF GitHub Bot commented on FLINK-9794:
---
Github user yanghua commented on a diff in
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 JDBCOutp
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r201551945
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCOutputFormat.java
---
@@ -54,6 +58,10 @@
private Connectio
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r201551369
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java
---
@@ -115,6 +119,16 @@ public JDBCAp
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6301#discussion_r201551339
--- Diff:
flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSinkBuilder.java
---
@@ -115,6 +119,16 @@ public JDBCAp
[
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
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539467#comment-16539467
]
vinoyang commented on FLINK-9794:
-
[~till.rohrmann] please give [~wangsan] contribute per
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539468#comment-16539468
]
wangsan commented on FLINK-9794:
Hi [~yanghua], I've opened a pull request for this issue
[
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
[
https://issues.apache.org/jira/browse/FLINK-9794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539465#comment-16539465
]
ASF GitHub Bot commented on FLINK-9794:
---
GitHub user jrthe42 opened a pull request:
[
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 an
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 implement
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 setupSingleLocal
[
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 i
[
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
> synchron
[
https://issues.apache.org/jira/browse/FLINK-9777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-9785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-9435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539274#comment-16539274
]
ASF GitHub Bot commented on FLINK-9435:
---
Github user NicoK commented on the issue:
[
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 refl
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 re-d
[
https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539256#comment-16539256
]
Rong Rong commented on FLINK-8985:
--
Thanks [~florianschmidt] for the exhausted listing f
[
https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539196#comment-16539196
]
ASF GitHub Bot commented on FLINK-9692:
---
Github user glaksh100 commented on the iss
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?
---
[
https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539105#comment-16539105
]
ASF GitHub Bot commented on FLINK-9776:
---
Github user asfgit closed the 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-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 re
[
https://issues.apache.org/jira/browse/FLINK-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539095#comment-16539095
]
ASF GitHub Bot commented on FLINK-9692:
---
GitHub user glaksh100 opened a pull reques
[
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
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 (i
[
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
[
https://issues.apache.org/jira/browse/FLINK-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539059#comment-16539059
]
ASF GitHub Bot commented on FLINK-9679:
---
Github user medcv commented on the issue:
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 f
[
https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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.
---
[
https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539037#comment-16539037
]
ASF GitHub Bot commented on FLINK-9754:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/6286
merging.
---
Github user jgrier commented on the issue:
https://github.com/apache/flink/pull/6290
ð
---
[
https://issues.apache.org/jira/browse/FLINK-9483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16539020#comment-16539020
]
ASF GitHub Bot commented on FLINK-9483:
---
Github user bowenli86 commented on the iss
[
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 co
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/6109
cc @zentol
---
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: Improve
[
https://issues.apache.org/jira/browse/FLINK-9792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538988#comment-16538988
]
Chesnay Schepler commented on FLINK-9792:
-
For starters I would probably go with
[
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.o
[
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
>
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: Improv
[
https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538919#comment-16538919
]
ASF GitHub Bot commented on FLINK-9776:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6275
All right, thanks, merging!
---
[
https://issues.apache.org/jira/browse/FLINK-9649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538909#comment-16538909
]
Leonid Ishimnikov commented on FLINK-9649:
--
The Mesos documentation page seems t
[
https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538904#comment-16538904
]
ASF GitHub Bot commented on FLINK-9713:
---
GitHub user pnowojski opened a pull reques
[
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
> -
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 and
[
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
> --
[
https://issues.apache.org/jira/browse/FLINK-9754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538880#comment-16538880
]
ASF GitHub Bot commented on FLINK-9754:
---
Github user StephanEwen commented on the i
[
https://issues.apache.org/jira/browse/FLINK-9768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538879#comment-16538879
]
ASF GitHub Bot commented on FLINK-9768:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6286
+1
---
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6285
+1
---
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-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538863#comment-16538863
]
Florian Schmidt commented on FLINK-8985:
Hey,
I was playing around with the CLI
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538859#comment-16538859
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538857#comment-16538857
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538858#comment-16538858
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538855#comment-16538855
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538860#comment-16538860
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538854#comment-16538854
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538856#comment-16538856
]
ASF GitHub Bot commented on FLINK-9750:
---
Github user StephanEwen commented on a dif
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_r201400623
--- Diff:
flink-core/src/test/java/org/apache/flink/core/fs/AbstractResumableWriterTest.java
---
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apach
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 +265,3
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 +265,3
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 h
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 Apach
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-9013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16538840#comment-16538840
]
ASF GitHub Bot commented on FLINK-9013:
---
Github user dawidwys commented on a diff i
1 - 100 of 324 matches
Mail list logo
