[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351855966 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351848241 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351854777 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351821224 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351859005 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351842744 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

pnowojski commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351861349 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351860677 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351860451 ## File path:

[GitHub] [flink] flinkbot commented on issue #10350: [FLINK-14957] Remove deprecated -yst option

flinkbot commented on issue #10350: [FLINK-14957] Remove deprecated -yst option URL: https://github.com/apache/flink/pull/10350#issuecomment-559546869 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We

[GitHub] [flink] buptljy opened a new pull request #10350: [FLINK-14957] Remove deprecated -yst option

buptljy opened a new pull request #10350: [FLINK-14957] Remove deprecated -yst option URL: https://github.com/apache/flink/pull/10350 ## What is the purpose of the change As codebase moved, "-yst" option in FlinkYarnSessionCl doesn't work anymore. We can remove it. ## Brief

[jira] [Updated] (FLINK-14957) Remove no power option -yst

[ https://issues.apache.org/jira/browse/FLINK-14957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14957: --- Labels: pull-request-available (was: ) > Remove no power option -yst >

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 : SUCCESS

[jira] [Updated] (FLINK-14987) JDBCTableSource can't support DataTypes.DECIMAL

[ https://issues.apache.org/jira/browse/FLINK-14987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dezhi Cai updated FLINK-14987: -- Description:   sample code 1 fail with ValidationException. After investigation, i find that the

[jira] [Created] (FLINK-14987) JDBCTableSource can't support DataTypes.DECIMAL

Dezhi Cai created FLINK-14987: - Summary: JDBCTableSource can't support DataTypes.DECIMAL Key: FLINK-14987 URL: https://issues.apache.org/jira/browse/FLINK-14987 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

flinkbot edited a comment on issue #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#issuecomment-559115891 ## CI report: * 65f4f8552770a2e1fd05c604a5cc074f32487c74 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

flinkbot edited a comment on issue #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#issuecomment-559531005 ## CI report: * 9579dbfa4c269b979a9127d67ce3de4b95228679 : PENDING

[GitHub] [flink] flinkbot commented on issue #10349: [FLINK-14833] [runtime] Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy

flinkbot commented on issue #10349: [FLINK-14833] [runtime] Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy URL: https://github.com/apache/flink/pull/10349#issuecomment-559541568 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-14833) Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-14833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14833: --- Labels: pull-request-available (was: ) > Remove hierachy of

[GitHub] [flink] buptljy opened a new pull request #10349: [FLINK-14833] [runtime] Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy

buptljy opened a new pull request #10349: [FLINK-14833] [runtime] Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy URL: https://github.com/apache/flink/pull/10349 ## What is the purpose of the change `HeapSnapshotStrategy` doesn't need to implement

[jira] [Updated] (FLINK-14833) Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy

[ https://issues.apache.org/jira/browse/FLINK-14833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-14833: --- Summary: Remove hierachy of SnapshotStrategySynchronicityBehavior in HeapSnapshotStrategy (was:

[jira] [Closed] (FLINK-14909) Let tasks in a batch get scheduled in topological order and subtaskIndex ascending pattern

[ https://issues.apache.org/jira/browse/FLINK-14909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14909. Resolution: Fixed master: 24b77dbdfe072ab6087284b34f95e44b50e2610f

[GitHub] [flink] mchro commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

mchro commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#discussion_r351842076 ## File path:

[GitHub] [flink] mchro commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

mchro commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#discussion_r351842076 ## File path:

[GitHub] [flink] GJL closed pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

GJL closed pull request #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309 This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

flinkbot edited a comment on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-553881527 ## CI report: * e3ac83fe02a7583159184772ff4b4341fa65f827 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559371382 ## CI report: * fbd6e8914b49348a275657130ebdd9413d7d17c6 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

flinkbot edited a comment on issue #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#issuecomment-559103160 ## CI report: * 4f9dc7a1f7ea2cbf6dfc34ed6e5359cf7097eef2 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

flinkbot commented on issue #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#issuecomment-559531005 ## CI report: * 9579dbfa4c269b979a9127d67ce3de4b95228679 : UNKNOWN Bot commands The

[GitHub] [flink] GJL commented on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible

GJL commented on issue #10309: [FLINK-14909][runtime] Let tasks get scheduled in topological order when possible URL: https://github.com/apache/flink/pull/10309#issuecomment-559529738 Merging. This is an automated message

[GitHub] [flink] wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on issue #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#issuecomment-559527458 @walterddr I have add a new fixup to address your comments. Please take a look.

[GitHub] [flink] pnowojski commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351827382 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351826142 ## File path:

[GitHub] [flink] rkhachatryan commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

rkhachatryan commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351821892 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351821265 ## File path:

[jira] [Updated] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-10377: --- Description: The precondition {{checkState(pendingTransactionIterator.hasNext(),

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE

[GitHub] [flink] pnowojski commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

pnowojski commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#discussion_r351817455 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559371382 ## CI report: * fbd6e8914b49348a275657130ebdd9413d7d17c6 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

flinkbot edited a comment on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

flinkbot edited a comment on issue #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#issuecomment-559103160 ## CI report: * 4f9dc7a1f7ea2cbf6dfc34ed6e5359cf7097eef2 : SUCCESS

[GitHub] [flink] azagrebin commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

azagrebin commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#discussion_r351815356 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send()

azagrebin commented on a change in pull request #10339: [FLINK-14976][cassandra] Release semaphore on all Throwable's in send() URL: https://github.com/apache/flink/pull/10339#discussion_r351815356 ## File path:

[GitHub] [flink] StefanRRichter opened a new pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

StefanRRichter opened a new pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723 …yCheckpointComplete ## What is the purpose of the change The precondition

[jira] [Commented] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984469#comment-16984469 ] Piotr Nowojski commented on FLINK-10377: As [reported by a user on the user mailing

[jira] [Closed] (FLINK-14979) TwoPhaseCommitSink fails when checkpoint overtakes a savepoint

[ https://issues.apache.org/jira/browse/FLINK-14979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14979. -- Resolution: Duplicate > TwoPhaseCommitSink fails when checkpoint overtakes a savepoint >

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

flinkbot edited a comment on issue #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#issuecomment-555395817 ## CI report: * 09feda98fa486bb4c3aaf8bba3806cae08b53c23 : SUCCESS

[jira] [Closed] (FLINK-13634) Add Hadoop compression format for use with StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-13634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-13634. Fix Version/s: 1.10.0 Resolution: Implemented Merged on master in

[GitHub] [flink] aljoscha commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

aljoscha commented on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-559517316 Thanks a lot! I merged this  This is

[GitHub] [flink] aljoscha closed pull request #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

aljoscha closed pull request #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434 This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-14813) Expose the new mechanism implemented in FLINK-14472 as a "is back-pressured" metric

[ https://issues.apache.org/jira/browse/FLINK-14813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14813. -- Fix Version/s: 1.10.0 Resolution: Fixed Merged to master as

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351812013 ## File path:

[GitHub] [flink] pnowojski merged pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

pnowojski merged pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247 This is an automated message from the Apache Git Service. To

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351811427 ## File path:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351808583 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1…

pnowojski commented on a change in pull request #10247: [FLINK-14813][runtime]Expose the new mechanism implemented in FLINK-1… URL: https://github.com/apache/flink/pull/10247#discussion_r351808292 ## File path: docs/monitoring/metrics.zh.md ## @@ -1117,7 +1117,7 @@

[jira] [Closed] (FLINK-14709) Allow outputting elements in close method of chained drivers.

[ https://issues.apache.org/jira/browse/FLINK-14709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14709. Fix Version/s: 1.10.0 Assignee: David Moravek Resolution: Fixed Merged on

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351808583 ## File path:

[GitHub] [flink] aljoscha commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

aljoscha commented on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-559514230 Thanks for your work! I merged this. This is

[GitHub] [flink] aljoscha closed pull request #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

aljoscha closed pull request #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153 This is an automated message from the Apache Git Service. To

[GitHub] [flink] pnowojski edited a comment on issue #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski edited a comment on issue #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#issuecomment-559512046 @AHeise @rkhachatryan could you take a look at the updated code and give more comments or +1 the code?

[GitHub] [flink] pnowojski commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351801940 ## File path:

[GitHub] [flink] pnowojski commented on issue #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski commented on issue #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#issuecomment-559512046 @AHeise could you take a look at the updated code and give more comments +1 the code?

[GitHub] [flink] pnowojski edited a comment on issue #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski edited a comment on issue #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#issuecomment-559512046 @AHeise could you take a look at the updated code and give more comments or +1 the code?

[GitHub] [flink] rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions

rkhachatryan commented on a change in pull request #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#discussion_r351804282 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API

flinkbot edited a comment on issue #10017: [FLINK-14019][python] add support for managing environment and dependencies of Python UDF in Flink Python API URL: https://github.com/apache/flink/pull/10017#issuecomment-546947394 ## CI report: *

[GitHub] [flink] pnowojski commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351802556 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r351800192 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r351795561 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r351799371 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r351795786 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r351794477 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli

kl0u commented on a change in pull request #10313: [FLINK-14840] Use Executor interface in SQL cli URL: https://github.com/apache/flink/pull/10313#discussion_r351799855 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE

[GitHub] [flink] pnowojski commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351801940 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10336: [FLINK-14935][task, runtime] Use RunnableWithException in the Mailbox

pnowojski commented on a change in pull request #10336: [FLINK-14935][task,runtime] Use RunnableWithException in the Mailbox URL: https://github.com/apache/flink/pull/10336#discussion_r351800893 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions

flinkbot edited a comment on issue #10345: [FLINK-12484][runtime] synchronize all mailbox actions URL: https://github.com/apache/flink/pull/10345#issuecomment-559421343 ## CI report: * 5206399001512006f4b3d7663e7b5be8ea02a4a2 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

flinkbot edited a comment on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559371382 ## CI report: * fbd6e8914b49348a275657130ebdd9413d7d17c6 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code

flinkbot edited a comment on issue #10347: [FLINK-14516][network] Remove non credit-based flow control code URL: https://github.com/apache/flink/pull/10347#issuecomment-559477264 ## CI report: * 0d3f9f0ad554418153570b7fd9cd9299d1958c5b : SUCCESS

[GitHub] [flink] flinkbot commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

flinkbot commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559509076 ## CI report: * 54ecee627e7036f4d150aad330b9772406a19494 : UNKNOWN Bot commands The

[GitHub] [flink] wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients

wangyang0918 commented on a change in pull request #9965: [FLINK-10935][kubernetes]Implement KubeClient with Faric8 Kubernetes clients URL: https://github.com/apache/flink/pull/9965#discussion_r351797153 ## File path:

[jira] [Created] (FLINK-14986) Support to get detailed Kubernetes cluster description

Yang Wang created FLINK-14986: - Summary: Support to get detailed Kubernetes cluster description Key: FLINK-14986 URL: https://issues.apache.org/jira/browse/FLINK-14986 Project: Flink Issue Type:

[GitHub] [flink] wangyang0918 commented on a change in pull request #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster.

wangyang0918 commented on a change in pull request #9973: [FLINK-9955] Add Kubernetes ClusterDescriptor to support deploying session cluster. URL: https://github.com/apache/flink/pull/9973#discussion_r351792605 ## File path:

[jira] [Commented] (FLINK-14985) FLNIK YARN per job with ehcache Exception

[ https://issues.apache.org/jira/browse/FLINK-14985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984425#comment-16984425 ] Rockey Cui commented on FLINK-14985: Hello,I tested it on another machine and it passed. The

[GitHub] [flink] flinkbot commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

flinkbot commented on issue #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348#issuecomment-559501104 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,…

flinkbot edited a comment on issue #10153: [FLINK-14709] Allow outputting elements in user defined close method,… URL: https://github.com/apache/flink/pull/10153#issuecomment-552508742 ## CI report: * 7692a79b3c58f68ed1296c7a6f192528ef360a0f : CANCELED

[jira] [Commented] (FLINK-14566) Enable ResourceSpec to get/set whether managed memory is used

[ https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984419#comment-16984419 ] Andrey Zagrebin commented on FLINK-14566: - It sounds to me like 2 different ways to set resource

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r351786366 ## File path:

[jira] [Updated] (FLINK-14951) State TTL backend end-to-end test fail when taskManager has multiple slot

[ https://issues.apache.org/jira/browse/FLINK-14951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14951: --- Labels: pull-request-available (was: ) > State TTL backend end-to-end test fail when

[GitHub] [flink] KarmaGYZ opened a new pull request #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests

KarmaGYZ opened a new pull request #10348: [FLINK-14951][tests] Harden the thread safety of State TTL backend tests URL: https://github.com/apache/flink/pull/10348 ## What is the purpose of the change The State TTL RocksDb/file backend tests now contains thread safety issue

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r351785509 ## File path:

[GitHub] [flink] klion26 commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api

klion26 commented on issue #10344: [FLINK-14264][StateBackend][Rest] Expose state backend in checkpoint rest api URL: https://github.com/apache/flink/pull/10344#issuecomment-559499548 @aljoscha thanks for the reply, have generated the rest document.

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r351785337 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE

[GitHub] [flink] wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission

wangyang0918 commented on a change in pull request #10193: [FLINK-13938][yarn] Use pre-uploaded flink binary to accelerate flink submission URL: https://github.com/apache/flink/pull/10193#discussion_r351782380 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

flinkbot edited a comment on issue #10268: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10268#issuecomment-555964030 ## CI report: * 72414aad5f654b834205103f23fbbfc3d5466748 : FAILURE

[jira] [Commented] (FLINK-14985) FLNIK YARN per job with ehcache Exception

[ https://issues.apache.org/jira/browse/FLINK-14985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984412#comment-16984412 ] Gary Yao commented on FLINK-14985: -- How do you package your job? Do you bundle the ehcache dependency

<    1   2   3   4   5   >