[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157961376 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobExecutionResultNotFoundException.java --- @@ -0,0 +1,45 @@ +/* + * Licensed

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157961174 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobExecutionResultNotFoundException.java --- @@ -0,0 +1,45 @@ +/* + * Licensed

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157960760 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/client/SerializedJobExecutionResult.java --- @@ -55,6 +56,26 @@ public

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157960722 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -357,6 +362,28 @@ public void start() throws Exception {

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157960666 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL closed the pull request at: https://github.com/apache/flink/pull/5168 ---

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157489280 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -357,6 +362,28 @@ public void start() throws Exception {

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157476788 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -357,6 +362,28 @@ public void start() throws

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157480732 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/queue/QueueStatus.java --- @@ -0,0 +1,65 @@ +/* + * Licensed to

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157480619 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExecutionResultResponseBody.java --- @@ -0,0 +1,69 @@ +/*

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157479720 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExecutionResultResponseBody.java --- @@ -0,0 +1,69 @@ +/*

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157480094 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/rest/messages/json/SerializedValueSerializerTest.java --- @@ -0,0 +1,81 @@ +/*

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157482818 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java --- @@ -357,6 +362,28 @@ public void start() throws

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157475492 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/client/SerializedJobExecutionResult.java --- @@ -55,6 +56,26 @@ public

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157477273 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobExecutionResultNotFoundException.java --- @@ -0,0 +1,45 @@ +/* + *

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157476994 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157462859 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobExecutionResult.java --- @@ -0,0 +1,112 @@ +/* + * Licensed to the

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027881 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027633 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/messages/JobExecutionResultNotFoundException.java --- @@ -0,0 +1,45 @@ +/* + * Licensed

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027510 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157027178 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java --- @@ -33,10 +40,23 @@ objectMapper.enable(

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157026590 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/JobExecutionResultHandler.java --- @@ -0,0 +1,107 @@ +/* + * Licensed

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157026313 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/util/RestMapperUtils.java --- @@ -33,10 +40,23 @@ objectMapper.enable(

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5168#discussion_r157025791 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobExecutionResultCache.java --- @@ -0,0 +1,79 @@ +/* + * Licensed to the

[GitHub] flink pull request #5168: [FLINK-8234][flip6] WIP

GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5168 [FLINK-8234][flip6] WIP WIP @tillrohrmann You can merge this pull request into a Git repository by running: $ git pull https://github.com/GJL/flink FLINK-8234 Alternatively you can