[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16536004#comment-16536004
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on a di
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830833
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535997#comment-16535997
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user xndai commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535999#comment-16535999
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user xndai commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535998#comment-16535998
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user xndai commented on a diff in t
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535996#comment-16535996
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user xndai commented on a diff in t
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830078
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830111
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830013
--- Diff:
flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcFileWriter.java
---
@@ -0,0 +1,269 @@
+/**
+ * Licensed to the Apache Softw
Github user xndai commented on a diff in the pull request:
https://github.com/apache/flink/pull/6075#discussion_r200830153
--- Diff:
flink-connectors/flink-orc/src/test/java/org/apache/flink/orc/OrcFileWriterTest.java
---
@@ -0,0 +1,40 @@
+/**
+ * Licensed to the Apache So
[
https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535993#comment-16535993
]
Congxian Qiu commented on FLINK-5125:
-
I run into the same problem also while run the
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535987#comment-16535987
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user hequn8128 commented on the iss
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6075
Hi @zhangminglei , The main reason to implement the `CheckpointedFuntion `
is you have kept a buffer in you Writer class. The buffer is a memory buffer
which will suffer data loss during job failov
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535986#comment-16535986
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user zhangminglei commented on the
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6205
Hi, @Aitozi I think it has conflicts now.
---
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535973#comment-16535973
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on the
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6075
Thanks @hequn8128. You are very correct! It is more reasonable to put the
ORC related classes into there ~, like @StephanEwen said, at the very least.
make them optional. As refers to implement
[
https://issues.apache.org/jira/browse/FLINK-9563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535969#comment-16535969
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the i
Github user deepaks4077 commented on the issue:
https://github.com/apache/flink/pull/6170
@zentol, thanks for reviewing. I've updated the PR, can you please take a
look?
---
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9750:
--
Labels: pull-request-available (was: )
> Create new StreamingFileSink that works on Flink's Fi
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535932#comment-16535932
]
ASF GitHub Bot commented on FLINK-9750:
---
GitHub user kl0u opened a pull request:
GitHub user kl0u opened a pull request:
https://github.com/apache/flink/pull/6281
[FLINK-9750] Add new StreamingFileSink with ResumableWriter.
## What is the purpose of the change
This PR is the first step towards introducing a new Streaming Filesystem
sink that works on to
[
https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535780#comment-16535780
]
ASF GitHub Bot commented on FLINK-9776:
---
Github user StephanEwen commented on a dif
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/6275#discussion_r200814568
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ---
@@ -1563,7 +1573,7 @@ public void run() {
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535776#comment-16535776
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user StephanEwen commented on the i
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6075
The dependencies of the `flink-connector-filesystem` are not well set up
already, having an Avro dependency and a Hadoop dependency. I agree that it
would be good to not introduce yet more depend
[
https://issues.apache.org/jira/browse/FLINK-9733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9733:
--
Labels: pull-request-available (was: )
> Make location for job graph files configurable
>
[
https://issues.apache.org/jira/browse/FLINK-9733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535755#comment-16535755
]
ASF GitHub Bot commented on FLINK-9733:
---
GitHub user yanghua opened a pull request:
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6280
[FLINK-9733] Make location for job graph files configurable
## What is the purpose of the change
*This pull request make location for job graph files configurable*
## Brief cha
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535753#comment-16535753
]
ASF GitHub Bot commented on FLINK-9682:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6266
@hequn8128 thanks for your suggestion. Yes, cutting off the description is
a choice. But currently, for the web UI, if the description does not show in a
new line, there is only little zone can be us
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535749#comment-16535749
]
ASF GitHub Bot commented on FLINK-9682:
---
Github user hequn8128 commented on the iss
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6266
Hi @yanghua , I think if the description is too long, we can simply cut off
the description. It is safe and easy.
---
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535745#comment-16535745
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user hequn8128 commented on the iss
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/6075
Hi @zhangminglei , thanks very much for your PR.
As for dependencies, I think it is better to move ORC related classes into
the module of `flink-orc`, so we don't need to add orc dependenc
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535715#comment-16535715
]
ASF GitHub Bot commented on FLINK-9682:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6266
hi @tillrohrmann what's your idea about the way of showing the description
of the job, or split the issue into backend API and frontend presentation?
---
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535697#comment-16535697
]
ASF GitHub Bot commented on FLINK-9352:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6092
---
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-9352.
--
Resolution: Fixed
Fix Version/s: 1.6.0
Fixed via 9f736d1927c62d220a82931c4f5ffa4955910f2
[
https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9706:
--
Labels: pull-request-available test-stability (was: test-stability)
> DispatcherTest#testSubmi
[
https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535694#comment-16535694
]
ASF GitHub Bot commented on FLINK-9706:
---
GitHub user tillrohrmann opened a pull req
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/6279
[FLINK-9706] Properly wait for termination of JobManagerRunner before
restarting jobs
## What is the purpose of the change
In order to avoid race conditions between resource clean up,
[
https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-9706:
-
Fix Version/s: 1.6.0
1.5.2
> DispatcherTest#testSubmittedJobGraphListener fail
[
https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann reassigned FLINK-9706:
Assignee: Till Rohrmann
> DispatcherTest#testSubmittedJobGraphListener fails on Travis
> -
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535682#comment-16535682
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff i
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200806113
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/PhysicalTableSourceScan.scala
---
@@ -39,9 +39,12 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535680#comment-16535680
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff i
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200806045
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/descriptors/FileSystem.scala
---
@@ -27,6 +28,8 @@ class FileSystem extends Con
[
https://issues.apache.org/jira/browse/FLINK-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535679#comment-16535679
]
ASF GitHub Bot commented on FLINK-9772:
---
Github user yanghua commented on the issue
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6278
cc @zentol @tillrohrmann can this PR be merged into 1.5.1?
---
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535678#comment-16535678
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff i
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200805902
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -56,23 +58,44 @@ public Environment()
Github user suez1224 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6201#discussion_r200805881
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java
---
@@ -56,23 +58,44 @@ public Environment()
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535676#comment-16535676
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16535655#comment-16535655
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on the
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6075
Patch have been updated.
---
57 matches
Mail list logo
