[
https://issues.apache.org/jira/browse/FLINK-5125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535993#comment-16535993
]
Congxian Qiu commented on FLINK-5125:
-
I run into the same problem also while run the test in my
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535987#comment-16535987
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user hequn8128 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-9642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535986#comment-16535986
]
ASF GitHub Bot commented on FLINK-9642:
---
Github user zhangminglei commented on the issue:
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=16535973#comment-16535973
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on the issue:
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=16535969#comment-16535969
]
ASF GitHub Bot commented on FLINK-9563:
---
Github user deepaks4077 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-9750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535780#comment-16535780
]
ASF GitHub Bot commented on FLINK-9776:
---
Github user StephanEwen commented on a diff in the pull
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=16535776#comment-16535776
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user StephanEwen commented on the issue:
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
[
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=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
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535749#comment-16535749
]
ASF GitHub Bot commented on FLINK-9682:
---
Github user hequn8128 commented on the issue:
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=16535745#comment-16535745
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user hequn8128 commented on the issue:
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
[
https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16535697#comment-16535697
]
ASF GitHub Bot commented on FLINK-9352:
---
Github user asfgit closed the pull request at:
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
[
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)
>
[
https://issues.apache.org/jira/browse/FLINK-9706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535694#comment-16535694
]
ASF GitHub Bot commented on FLINK-9706:
---
GitHub user tillrohrmann opened a pull request:
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
[
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=16535682#comment-16535682
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
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=16535680#comment-16535680
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
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
[
https://issues.apache.org/jira/browse/FLINK-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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=16535678#comment-16535678
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
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
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
[
https://issues.apache.org/jira/browse/FLINK-8866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535676#comment-16535676
]
ASF GitHub Bot commented on FLINK-8866:
---
Github user suez1224 commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16535655#comment-16535655
]
ASF GitHub Bot commented on FLINK-9407:
---
Github user zhangminglei commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/6075
Patch have been updated.
---
47 matches
Mail list logo
