zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics
to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#issuecomment-486947869
Thanks for further review @azagrebin .
I have pushed one fixup commit for addressing ab
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486945344
@tillrohrmann, I have a new idea to fix the bug. The most essential reason
[
https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826702#comment-16826702
]
Fokko Driesprong commented on FLINK-12330:
--
My personal preference is using Doc
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486945344
@tillrohrmann, I have a new idea to fix the bug. The most essential reason
is when
[
https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-12333:
Assignee: Yun Tang
> Add documentation around save point with cancel lifecycle through REST
> --
[
https://issues.apache.org/jira/browse/FLINK-10929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826677#comment-16826677
]
Liya Fan commented on FLINK-10929:
--
Hi [Stephan
Ewen|https://issues.apache.org/jira/se
[
https://issues.apache.org/jira/browse/FLINK-12330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng reassigned FLINK-12330:
---
Assignee: sunjincheng
> Add integrated Tox for ensuring compatibility with the python2/3 ve
[
https://issues.apache.org/jira/browse/FLINK-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12328:
---
Labels: pull-request-available (was: )
> Invalid Express
> ---
>
>
happyer closed pull request #8270: [FLINK-12328][test] remove invalid expression
URL: https://github.com/apache/flink/pull/8270
This is an automated message from the Apache Git Service.
To respond to the message, please log o
sunjincheng121 commented on issue #8225: FLINK-10984]Remove flink-shaded-hadoop
from flink
URL: https://github.com/apache/flink/pull/8225#issuecomment-486937897
Thanks for your Review @zentol!
I have had updated the PR accordingly. And about download the `uber` JRA,
I think your r
sunjincheng121 commented on a change in pull request #8225: FLINK-10984]Remove
flink-shaded-hadoop from flink
URL: https://github.com/apache/flink/pull/8225#discussion_r278817480
##
File path: flink-dist/pom.xml
##
@@ -428,9 +411,6 @@ under the License.
KurtYoung commented on a change in pull request #8275: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8275#discussion_r278815850
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFuncti
KurtYoung commented on a change in pull request #8275: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8275#discussion_r278816704
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ReadableWrita
KurtYoung commented on a change in pull request #8275: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8275#discussion_r278815825
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogFuncti
KurtYoung commented on a change in pull request #8275: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8275#discussion_r278816869
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMe
KurtYoung commented on a change in pull request #8275: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8275#discussion_r278816442
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ReadableWrita
zhijiangW commented on issue #7822: [FLINK-11726][network] Refactor the
creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#issuecomment-486936180
I have pushed new fixup commit for addressing above comments.
For the refactor
zhijiangW edited a comment on issue #7822: [FLINK-11726][network] Refactor the
creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#issuecomment-486936180
Thanks for further review @azagrebin .
I have pushed a new fixup commit f
[
https://issues.apache.org/jira/browse/FLINK-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
chauncy closed FLINK-12328.
---
Resolution: Invalid
> Invalid Express
> ---
>
> Key: FLINK-12328
>
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278806215
##
File path:
flink-runtime/src/main/java/org/apache/fli
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278804998
##
File path:
flink-runtime/src/test/java/org/apache/fli
xuefuz commented on issue #8275: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8275#issuecomment-486919103
This is to replace PR https://github.com/apache/flink/pull/8212. cc:
@JingsongLi @KurtYoung
--
[
https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826621#comment-16826621
]
Kurt Young commented on FLINK-11974:
Regarding #2: I'm wondering why we want to git
zhijiangW commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278800356
##
File path:
flink-runtime/src/test/java/org/apache/fli
xuefuz commented on issue #8212: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8212#issuecomment-486913258
I had to rebase my fork to resolve the conflicts. Doing so, however, I had
to do a forced push, which avoided this PR. I created a n
flinkbot commented on issue #8275: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8275#issuecomment-486912987
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull req
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r278782559
##
File path: docs/dev/table/tableApi.md
##
xuefuz opened a new pull request #8275: [FLINK-11519][table] Add function
related catalog APIs
URL: https://github.com/apache/flink/pull/8275
## What is the purpose of the change
As a followup for FLINK-11474 and its PR#8007, this PR adds additional
catalog APIs for function
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r278796916
##
File path:
flink-python/flink-python-tab
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r278795877
##
File path: flink-python/flink-python-tabl
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r278782653
##
File path: flink-python/flink-python-tabl
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r278793531
##
File path: flink-python/flink-python-tabl
sunjincheng121 commented on a change in pull request #8267:
[FLINK-12311][table][python] Add base python framework and Add Scan,
Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#discussion_r278793705
##
File path: flink-python/flink-python-tabl
[
https://issues.apache.org/jira/browse/FLINK-12319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826610#comment-16826610
]
Liya Fan commented on FLINK-12319:
--
Hi [~mpf], thanks again for the additional informat
Kejian-Li opened a new pull request #8274: [FLIKN-12306][Runtime] Change the
name of variable log into LOG
URL: https://github.com/apache/flink/pull/8274
## What is the purpose of the change
A trivial improvement that changes the name of variable "log" into "LOG" to
corr
flinkbot commented on issue #8274: [FLIKN-12306][Runtime] Change the name of
variable log into LOG
URL: https://github.com/apache/flink/pull/8274#issuecomment-486910585
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826608#comment-16826608
]
vinoyang commented on FLINK-11935:
--
Yes, what do you think?
> Remove DateTimeUtils pul
[
https://issues.apache.org/jira/browse/FLINK-12334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826606#comment-16826606
]
Liya Fan commented on FLINK-12334:
--
Hi [~cre...@gmail.com], thanks for opening this iss
[
https://issues.apache.org/jira/browse/FLINK-11611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826605#comment-16826605
]
Xin Ma commented on FLINK-11611:
Hi [~jark]
I have completed the first translation.
>
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826601#comment-16826601
]
Rong Rong edited comment on FLINK-11935 at 4/26/19 2:57 AM:
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826601#comment-16826601
]
Rong Rong commented on FLINK-11935:
---
hmm. I might've misunderstood some details.
Are
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826599#comment-16826599
]
vinoyang commented on FLINK-11935:
--
Hi [~walterddr] Actually, my idea is to keep it as
shixiaogang commented on issue #8269: [FLINK-12285][test] Harden savepoint
relevant test cases by explicitly canceling test job
URL: https://github.com/apache/flink/pull/8269#issuecomment-486906606
> most of these should have no positive effect since the
`MiniClusterResource` is shut down
[
https://issues.apache.org/jira/browse/FLINK-11611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11611:
---
Labels: pull-request-available (was: )
> Translate the "Batch Examples" page into Chinese
>
flinkbot commented on issue #8273: [FLINK-11611] [docs] Translate the "Batch
Examples" page into Chinese
URL: https://github.com/apache/flink/pull/8273#issuecomment-486905909
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to revie
luvex opened a new pull request #8273: [FLINK-11611] [docs] Translate the
"Batch Examples" page into Chinese
URL: https://github.com/apache/flink/pull/8273
## What is the purpose of the change
This pull request translates the batch example page into Chinese.
## Bri
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826516#comment-16826516
]
Rong Rong edited comment on FLINK-11935 at 4/26/19 2:19 AM:
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826516#comment-16826516
]
Rong Rong edited comment on FLINK-11935 at 4/26/19 2:18 AM:
xuefuz closed pull request #8212: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8212
This is an automated message from the Apache Git Service.
To respond to the message, ple
KurtYoung commented on a change in pull request #8179: [FLINK-12200]
[Table-planner] Support UNNEST for MAP types
URL: https://github.com/apache/flink/pull/8179#discussion_r278783132
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/util/Explo
KurtYoung commented on a change in pull request #8179: [FLINK-12200]
[Table-planner] Support UNNEST for MAP types
URL: https://github.com/apache/flink/pull/8179#discussion_r278782753
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logi
Myasuka commented on a change in pull request #8272: [FLINK-12274] Fix
documentation to enable Queryable State
URL: https://github.com/apache/flink/pull/8272#discussion_r278782171
##
File path: docs/dev/stream/state/queryable_state.md
##
@@ -69,10 +69,12 @@ response back t
Myasuka commented on a change in pull request #8272: [FLINK-12274] Fix
documentation to enable Queryable State
URL: https://github.com/apache/flink/pull/8272#discussion_r278782171
##
File path: docs/dev/stream/state/queryable_state.md
##
@@ -69,10 +69,12 @@ response back t
Myasuka commented on a change in pull request #8272: [FLINK-12274] Fix
documentation to enable Queryable State
URL: https://github.com/apache/flink/pull/8272#discussion_r278782170
##
File path: docs/dev/stream/state/queryable_state.md
##
@@ -69,10 +69,12 @@ response back t
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278782161
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericCat
JingsongLi commented on a change in pull request #8212: [FLINK-11519][table]
Add function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278782143
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericCat
tianchen92 commented on issue #8219: [FLINK-10441]Don't log warning when
creating upload directory
URL: https://github.com/apache/flink/pull/8219#issuecomment-486890525
Thanks for your reply @zentol, I have resolved the comments, please have a
look.
--
flinkbot edited a comment on issue #8212: [FLINK-11519][table] Add function
related catalog APIs
URL: https://github.com/apache/flink/pull/8212#issuecomment-484544644
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your p
JingsongLi commented on issue #8212: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8212#issuecomment-486890255
@xuefuz please resolve the conflicts
This is an automated messa
JingsongLi commented on issue #8212: [FLINK-11519][table] Add function related
catalog APIs
URL: https://github.com/apache/flink/pull/8212#issuecomment-486890214
@flinkbot attention @KurtYoung
This is an automated message f
flinkbot edited a comment on issue #8267: [FLINK-12311][table][python] Add base
python framework and Add Scan, Projection, and Filter operator support
URL: https://github.com/apache/flink/pull/8267#issuecomment-486582161
Thanks a lot for your contribution to the Apache Flink project. I'm th
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826516#comment-16826516
]
Rong Rong commented on FLINK-11935:
---
Hi [~yanghua], I understand what you said. I thin
flinkbot commented on issue #8272: [FLINK-12274] Fix documentation to enable
Queryable State
URL: https://github.com/apache/flink/pull/8272#issuecomment-486846727
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
[
https://issues.apache.org/jira/browse/FLINK-12274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12274:
---
Labels: pull-request-available (was: )
> Fix documentation to enable Queryable State
>
PierreZ opened a new pull request #8272: [FLINK-12274] Fix documentation to
enable Queryable State
URL: https://github.com/apache/flink/pull/8272
## What is the purpose of the change
Queryable state, since 1.8, now need to be enable through configuration.
This add the right
Cliff Resnick created FLINK-12334:
-
Summary: change to MockStreamTask breaks
OneInputStreamOperatorTestHarness
Key: FLINK-12334
URL: https://issues.apache.org/jira/browse/FLINK-12334
Project: Flink
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278722515
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278722430
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278722342
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278722293
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278722212
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278721994
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278721918
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
xuefuz commented on a change in pull request #8212: [FLINK-11519][table] Add
function related catalog APIs
URL: https://github.com/apache/flink/pull/8212#discussion_r278720766
##
File path:
flink-table/flink-table-api-java/src/test/java/org/apache/flink/table/catalog/GenericInMemor
bowenli86 commented on issue #8205: [FLINK-12238] [hive] Support database
related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#issuecomment-486795425
Thanks @zentol for the feedbacks! I've addressed them by b
lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime]
Fix can't get max_attempts_history_size value when create ExecutionVertex
URL: https://github.com/apache/flink/pull/8268#discussion_r278663085
##
File path:
flink-runtime/src/main/java/org/apache/flink/r
lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime]
Fix can't get max_attempts_history_size value when create ExecutionVertex
URL: https://github.com/apache/flink/pull/8268#discussion_r278663085
##
File path:
flink-runtime/src/main/java/org/apache/flink/r
lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime]
Fix can't get max_attempts_history_size value when create ExecutionVertex
URL: https://github.com/apache/flink/pull/8268#discussion_r278663085
##
File path:
flink-runtime/src/main/java/org/apache/flink/r
lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime]
Fix can't get max_attempts_history_size value when create ExecutionVertex
URL: https://github.com/apache/flink/pull/8268#discussion_r278663085
##
File path:
flink-runtime/src/main/java/org/apache/flink/r
lamber-ken commented on a change in pull request #8268: [FLINK-12246][runtime]
Fix can't get max_attempts_history_size value when create ExecutionVertex
URL: https://github.com/apache/flink/pull/8268#discussion_r278663085
##
File path:
flink-runtime/src/main/java/org/apache/flink/r
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r278654915
##
File path: flink-connectors/f
bowenli86 commented on a change in pull request #8205: [FLINK-12238] [hive]
Support database related operations in GenericHiveMetastoreCatalog and setup
flink-connector-hive module
URL: https://github.com/apache/flink/pull/8205#discussion_r278654915
##
File path: flink-connectors/f
azagrebin commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278627976
##
File path:
flink-runtime/src/main/java/org/apache/fli
azagrebin commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278618535
##
File path:
flink-runtime/src/test/java/org/apache/fli
azagrebin commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278620145
##
File path:
flink-runtime/src/test/java/org/apache/fli
azagrebin commented on a change in pull request #7822: [FLINK-11726][network]
Refactor the creation of ResultPartition and InputGate into NetworkEnvironment
URL: https://github.com/apache/flink/pull/7822#discussion_r278636171
##
File path:
flink-runtime/src/main/java/org/apache/fli
art4ul commented on a change in pull request #8179: [FLINK-12200]
[Table-planner] Support UNNEST for MAP types
URL: https://github.com/apache/flink/pull/8179#discussion_r278625671
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486731333
@tillrohrmann, BTW, if you want to get the NPE stacktrace, you need to use
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486731333
@tillrohrmann, BTW, if you want to get the NPE stacktrace, you need to use
log4j a
azagrebin commented on a change in pull request #8181: [FLINK-12199][network]
Refactor IOMetrics to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#discussion_r278615592
##
File path:
flink-runtime/src/test/java/org/apache/flink/runt
zhijiangW commented on a change in pull request #8181: [FLINK-12199][network]
Refactor IOMetrics to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#discussion_r278614937
##
File path:
flink-runtime/src/test/java/org/apache/flink/runt
lamber-ken removed a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486716231
@tillrohrmann, here is original NPE stacktrace.
```
java.lang.NullPoi
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486714974
hi, @tillrohrmann
**First**, the original exception is NPE which as
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486714974
hi, @tillrohrmann
**First**, the original exception is NPE which as
zhijiangW commented on a change in pull request #8181: [FLINK-12199][network]
Refactor IOMetrics to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#discussion_r278611563
##
File path:
flink-runtime/src/main/java/org/apache/flink/runt
lamber-ken edited a comment on issue #8254: [FLINK-12219][runtime] Yarn
application can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486723700
> The `HistoryServerArchivist` is not supposed to throw any exceptions. If
zhijiangW commented on a change in pull request #8181: [FLINK-12199][network]
Refactor IOMetrics to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#discussion_r278610658
##
File path:
flink-runtime/src/test/java/org/apache/flink/runt
zhijiangW commented on a change in pull request #8181: [FLINK-12199][network]
Refactor IOMetrics to not distinguish between local/remote in/out bytes
URL: https://github.com/apache/flink/pull/8181#discussion_r278610383
##
File path:
flink-runtime/src/test/java/org/apache/flink/runt
lamber-ken commented on issue #8254: [FLINK-12219][runtime] Yarn application
can't stop when flink job failed in per-job yarn cluste mode
URL: https://github.com/apache/flink/pull/8254#issuecomment-486723700
> The `HistoryServerArchivist` is not supposed to throw any exceptions. If
it does
TisonKun commented on issue #8264: [hotfix][yarn] userJarFiles can be a local
variable
URL: https://github.com/apache/flink/pull/8264#issuecomment-486719685
@tillrohrmann thanks for your review!
I accidentally added a force push on this pr. Sorry and please check if
conflict :(
---
1 - 100 of 240 matches
Mail list logo
