[GitHub] [flink] TisonKun commented on issue #9700: [FLINK-14050][yarn] Refactor YarnClusterDescriptor inheritance

TisonKun commented on issue #9700: [FLINK-14050][yarn] Refactor YarnClusterDescriptor inheritance URL: https://github.com/apache/flink/pull/9700#issuecomment-534884522 CC @aljoscha could you take a look at this pull request?

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327961954 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327962020 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327962005 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327964157 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[jira] [Updated] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10837: -- Priority: Critical (was: Major) > Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked

[jira] [Commented] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937475#comment-16937475 ] Till Rohrmann commented on FLINK-10837: --- Another instance: https://api.travis-ci.o

[jira] [Updated] (FLINK-10837) Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked on deleteTestTopic?

[ https://issues.apache.org/jira/browse/FLINK-10837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10837: -- Labels: test-stability (was: ) > Kafka 2.0 test KafkaITCase.testOneToOneSources dead locked o

[jira] [Created] (FLINK-14202) Optimize the execution plan for Python Calc when there is a condition

Dian Fu created FLINK-14202: --- Summary: Optimize the execution plan for Python Calc when there is a condition Key: FLINK-14202 URL: https://issues.apache.org/jira/browse/FLINK-14202 Project: Flink

[GitHub] [flink] dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function e

dianfu commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534891281 @sunjincheng121 As I discuss

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

flinkbot edited a comment on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#issuecomment-534621946 ## CI report: * 008c7253d29aa86554782d0adfea06ce1d2eafb8 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] sunjincheng121 commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python fu

sunjincheng121 commented on issue #9748: [FLINK-14016][python][flink-table-planner] Introduce FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec for Python function execution URL: https://github.com/apache/flink/pull/9748#issuecomment-534891962 Thanks Dian, we can

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/bui

[jira] [Updated] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

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

[GitHub] [flink] a-siuniaev opened a new pull request #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown

a-siuniaev opened a new pull request #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown URL: https://github.com/apache/flink/pull/9767 ## What is the purpose of the change The subtle asynchronous bug appearing in test is fixed. ## Brief change log *(for exa

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327970135 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[jira] [Updated] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

[ https://issues.apache.org/jira/browse/FLINK-14018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14018: Description: We need to add a few Python building blocks such as ScalarFunctionOperation, BigIntCoder, et

[GitHub] [flink] wangxiyuan opened a new pull request #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

wangxiyuan opened a new pull request #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768 ## What is the purpose of the change There is no way to distinguish operating system architecture in Flink. So that Flink alwa

[jira] [Updated] (FLINK-14086) PrometheusReporterEndToEndITCase doesn't support ARM arch

[ https://issues.apache.org/jira/browse/FLINK-14086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14086: --- Labels: pull-request-available (was: ) > PrometheusReporterEndToEndITCase doesn't support A

[jira] [Updated] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

[ https://issues.apache.org/jira/browse/FLINK-14018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14018: Description: We need to add a few Python building blocks such as ScalarFunctionOperation, RowCoder, etc f

[GitHub] [flink] flinkbot commented on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown

flinkbot commented on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown URL: https://github.com/apache/flink/pull/9767#issuecomment-534893435 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] [flink] b923 commented on a change in pull request #9759: [FLINK-14169][history-server] Cleanup expired jobs from history server

b923 commented on a change in pull request #9759: [FLINK-14169][history-server] Cleanup expired jobs from history server URL: https://github.com/apache/flink/pull/9759#discussion_r327971808 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/history/Hi

[GitHub] [flink] flinkbot commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

flinkbot commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534893979 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull r

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327973260 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327973356 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327973730 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327974182 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327974424 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327975397 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327975499 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327976364 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] pnowojski merged pull request #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

pnowojski merged pull request #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483 This is an automated message from the Apache Git Service

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327976364 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327976571 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327976682 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[jira] [Closed] (FLINK-13767) Refactor StreamInputProcessor#processInput based on InputStatus

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

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/bui

[GitHub] [flink] flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

flinkbot edited a comment on issue #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work URL: https://github.com/apache/flink/pull/9766#issuecomment-534879961 ## CI report: * 8fffbbc4bc605ccedad7412ac2292

[GitHub] [flink] flinkbot commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

flinkbot commented on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 : UNKNOWN --

[GitHub] [flink] flinkbot edited a comment on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

flinkbot edited a comment on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#issuecomment-534621946 ## CI report: * 008c7253d29aa86554782d0adfea06ce1d2eafb8 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot commented on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown

flinkbot commented on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown URL: https://github.com/apache/flink/pull/9767#issuecomment-534898951 ## CI report: * d0732c1e898be8e2bf6881687c546a669caf4808 : UNKNOWN ---

[GitHub] [flink] zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r327964157 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operator

[jira] [Commented] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937493#comment-16937493 ] Kostas Kloudas commented on FLINK-9749: --- That is correct [~dangdangdang]! > Rework

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327972417 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/Ne

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327972417 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/Ne

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327982708 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DeploymentHandle.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327979650 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Commented] (FLINK-14180) Enable config of maximum capacity of FileArchivedExecutionGraphStore.

[ https://issues.apache.org/jira/browse/FLINK-14180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937501#comment-16937501 ] Till Rohrmann commented on FLINK-14180: --- Please wait with opening the PR until you

[jira] [Assigned] (FLINK-14180) Enable config of maximum capacity of FileArchivedExecutionGraphStore.

[ https://issues.apache.org/jira/browse/FLINK-14180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14180: - Assignee: Yingjie Cao > Enable config of maximum capacity of FileArchivedExecutionGraph

[GitHub] [flink] flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

flinkbot edited a comment on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-534387866 ## CI report: * 5b73b3d6319447fd2d81b48183d9f22012133a6b : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/

[GitHub] [flink] flinkbot edited a comment on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown

flinkbot edited a comment on issue #9767: [FLINK-14120][API/Datastream] Fix testImmediateShutdown URL: https://github.com/apache/flink/pull/9767#issuecomment-534898951 ## CI report: * d0732c1e898be8e2bf6881687c546a669caf4808 : PENDING [Build](https://travis-ci.com/flink-ci/flink

[GitHub] [flink] flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum

flinkbot edited a comment on issue #9768: [FLINK-14086][test][core] Add OperatingArchitecture Enum URL: https://github.com/apache/flink/pull/9768#issuecomment-534899022 ## CI report: * 51ae12da735fd7fd1bdadd282839c9bfe7b80146 : PENDING [Build](https://travis-ci.com/flink-ci/flin

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937503#comment-16937503 ] Till Rohrmann commented on FLINK-14164: --- So what is the concrete proposal? 1. Kee

[jira] [Comment Edited] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16936671#comment-16936671 ] Zhu Zhu edited comment on FLINK-14164 at 9/25/19 8:11 AM: -- >> S

[jira] [Updated] (FLINK-14139) Fix potential memory leak of rest server when using session/standalone cluster

[ https://issues.apache.org/jira/browse/FLINK-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14139: -- Issue Type: Bug (was: Improvement) > Fix potential memory leak of rest server when using sess

[jira] [Updated] (FLINK-14139) Fix potential memory leak of rest server when using session/standalone cluster

[ https://issues.apache.org/jira/browse/FLINK-14139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14139: -- Fix Version/s: 1.9.1 > Fix potential memory leak of rest server when using session/standalone

[jira] [Commented] (FLINK-14197) Increasing trend for state size of keyed stream using ProcessWindowFunction with ProcessingTimeSessionWindows

[ https://issues.apache.org/jira/browse/FLINK-14197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937507#comment-16937507 ] Oliver Kostera commented on FLINK-14197: Thanks for quick response. Unfortunate

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r327989026 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r327990096 ## File path: flink-state-backends/flink-statebackend-heap-spillable/src

[GitHub] [flink] tillrohrmann closed pull request #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

tillrohrmann closed pull request #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745 This is an automated message from the Apache Git Service

[jira] [Resolved] (FLINK-14070) Use TimeUtils to parse duration configs

[ https://issues.apache.org/jira/browse/FLINK-14070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14070. --- Resolution: Done Done via 9d9d9e88a84ea45e205d3101991e13cca49f5bc6 949776bb8a8c326368bf777

[jira] [Updated] (FLINK-11405) rest api can more exceptions by query parameter

[ https://issues.apache.org/jira/browse/FLINK-11405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-11405: --- Summary: rest api can more exceptions by query parameter (was: rest api can see task and task attempt excep

[jira] [Updated] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-11374: --- Description: Now failover just show limit size task failover latest time(ps: ). (was: Now failover just sho

[GitHub] [flink] flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server.

flinkbot edited a comment on issue #9750: [FLINK-14139][rest]Fix potential memory leak problem of rest server. URL: https://github.com/apache/flink/pull/9750#issuecomment-534370339 ## CI report: * 9ea7a2157e67850fe26c893969108694d2525284 : SUCCESS [Build](https://travis-ci.com/f

[GitHub] [flink] flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime

flinkbot edited a comment on issue #9757: [FLINK-14183][runtime] Remove unnecessary scala Duration usages in flink-runtime URL: https://github.com/apache/flink/pull/9757#issuecomment-534477715 ## CI report: * 665c10facbe808e8437f4ca4534e00173e5a1240 : FAILURE [Build](https://tra

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r327970691 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorReso

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r327965610 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorReso

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r327918736 ## File path: flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java ## @

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r327982652 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/clusterframework/TaskExecutorReso

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics

KarmaGYZ commented on a change in pull request #9760: [FLINK-13982][runtime] Implement memory calculation logics URL: https://github.com/apache/flink/pull/9760#discussion_r327922713 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/TaskExecutorReso

[GitHub] [flink] flinkbot edited a comment on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and …

flinkbot edited a comment on issue #9761: [FLINK-14031][examples][table]Added the blink planner dependency and … URL: https://github.com/apache/flink/pull/9761#issuecomment-534621946 ## CI report: * 008c7253d29aa86554782d0adfea06ce1d2eafb8 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] tillrohrmann commented on issue #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services

tillrohrmann commented on issue #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services URL: https://github.com/apache/flink/pull/9743#issuecomment-534915250 Merging now. This i

[jira] [Updated] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-11374: --- Description: Now failover just show limit size task failover latest time(ps:According to the current flink 

[GitHub] [flink] tillrohrmann commented on issue #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services

tillrohrmann commented on issue #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services URL: https://github.com/apache/flink/pull/9743#issuecomment-534916409 Merged via 8b85715cfb9d9927c7d2fb82593be0bcaf084502

[GitHub] [flink] tillrohrmann closed pull request #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services

tillrohrmann closed pull request #9743: [hotfix][coordination] Fix MiniCluster#closeAsync to correctly close all components and services URL: https://github.com/apache/flink/pull/9743 This is an automated message from the Ap

[jira] [Commented] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937521#comment-16937521 ] lining commented on FLINK-11374: [~trohrmann], if [~vthinkxie] 's suggest is ok, we coul

[GitHub] [flink] flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

flinkbot edited a comment on issue #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#issuecomment-513425405 ## CI report: * bd7ade5e0b57dc8577d7f864afcbbb24c2513e56 : FAILURE [Build](https://travis-ci.com/flink-ci/fli

[jira] [Created] (FLINK-14203) add an abstract class for mappers with rich model.

Xu Yang created FLINK-14203: --- Summary: add an abstract class for mappers with rich model. Key: FLINK-14203 URL: https://issues.apache.org/jira/browse/FLINK-14203 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-14203) add an abstract class for mappers with rich model.

[ https://issues.apache.org/jira/browse/FLINK-14203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xu Yang updated FLINK-14203: Description: _The RichModel is used to the classification, the regression or the clustering._ __  _The o

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE [Build](https://travis-ci.com/flink-ci/flink/builds/12833415

[jira] [Created] (FLINK-14204) Add the model mapper for Gaussian Mixture model.

Xu Yang created FLINK-14204: --- Summary: Add the model mapper for Gaussian Mixture model. Key: FLINK-14204 URL: https://issues.apache.org/jira/browse/FLINK-14204 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-12531) flink sql-client throw NoMatchingTableFactoryException

[ https://issues.apache.org/jira/browse/FLINK-12531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16937529#comment-16937529 ] Pritam Sadhukhan commented on FLINK-12531: -- I am facing the same issue with ver

[GitHub] [flink] xuyang1706 opened a new pull request #9769: [FLINK-14203][ml] add an abstract class for mappers with rich model.

xuyang1706 opened a new pull request #9769: [FLINK-14203][ml] add an abstract class for mappers with rich model. URL: https://github.com/apache/flink/pull/9769 ## What is the purpose of the change The RichModel is used to the classification, the regression or the clustering.

[jira] [Updated] (FLINK-14203) add an abstract class for mappers with rich model.

[ https://issues.apache.org/jira/browse/FLINK-14203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14203: --- Labels: pull-request-available (was: ) > add an abstract class for mappers with rich model.

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r328001905 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.jav

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327927379 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/memory/KeyedBudgetTest.j

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327957575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.jav

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327962042 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.jav

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327922460 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/KeyedBudget.java

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327912570 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.ja

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327915668 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.jav

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327922550 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/KeyedBudget.java

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r328001404 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.jav

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327920212 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/KeyedBudget.java

[GitHub] [flink] xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools

xintongsong commented on a change in pull request #9693: [FLINK-13984] Separate on-heap and off-heap managed memory pools URL: https://github.com/apache/flink/pull/9693#discussion_r327940329 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/memory/KeyedBudgetTest.j

  1   2   3   4   5   6   >