[GitHub] [flink] flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

flinkbot edited a comment on issue #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#issuecomment-535013943 ## CI report: * a7a643c54c912e9a42b1dbf887f14eba2ac80f82 : FAILURE

[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_r328460043 ## File path:

[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=16938323#comment-16938323 ] Till Rohrmann commented on FLINK-14164: --- Can't we deprecate the {{fullRestarts}} metric in

[jira] [Closed] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14016. --- Resolution: Resolved > Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and >

[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_r328464527 ## File path:

[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_r328464339 ## File path:

[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_r328464439 ## File path:

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #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#discussion_r328471344 ## File path:

[jira] [Created] (FLINK-14225) Travis is unable to parse of the secure environment variables

Gary Yao created FLINK-14225: Summary: Travis is unable to parse of the secure environment variables Key: FLINK-14225 URL: https://issues.apache.org/jira/browse/FLINK-14225 Project: Flink Issue

[jira] [Updated] (FLINK-14225) Travis is unable to parse one of the secure environment variables

[ https://issues.apache.org/jira/browse/FLINK-14225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-14225: - Summary: Travis is unable to parse one of the secure environment variables (was: Travis is unable to

[GitHub] [flink] TisonKun commented on issue #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending checkpoints for fine grained recovery

TisonKun commented on issue #4844: [FLINK-7844] [ckPt] Fail unacknowledged pending checkpoints for fine grained recovery URL: https://github.com/apache/flink/pull/4844#issuecomment-535382660 > I would suggest to try and test this without as much mocking. Mockito-based tests have proven

[jira] [Commented] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938377#comment-16938377 ] Gary Yao commented on FLINK-14226: -- Could this be related to e7216eebc846a69272c21375af0f4db8009c2e3e?

[GitHub] [flink] lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

lamber-ken commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-535382418 > @zentol could you take a look at the problem with `tools/releasing/collect_license_files.sh build-target`? Hi, @tillrohrmann.

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[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

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #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#discussion_r328514073 ## File path:

[GitHub] [flink] flinkbot commented on issue #9778: [FLINK-14206][runtime] Let fullRestart metric count both full restarts and fine grained restarts

flinkbot commented on issue #9778: [FLINK-14206][runtime] Let fullRestart metric count both full restarts and fine grained restarts URL: https://github.com/apache/flink/pull/9778#issuecomment-535430586 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14206: Affects Version/s: 1.10.0 > Let fullRestart metric count fine grained restarts as well >

[jira] [Updated] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14206: Fix Version/s: 1.10.0 > Let fullRestart metric count fine grained restarts as well >

[GitHub] [flink] hequn8128 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

hequn8128 commented on a change in pull request #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#discussion_r328533791 ## File path:

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

1u0 commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328063741 ## File path:

[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_r328541881 ## File path:

[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_r328422187 ## File path:

[GitHub] [flink] zhijiangW commented on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW commented on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-535443887 @AHeise I have finished the first round review. Almost LGTM only for some tiny comments. In addition, for

[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_r328456850 ## File path:

[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_r328466285 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0

tillrohrmann commented on issue #9751: [FLINK-14177] bump curator from 2.12.0 to 4.2.0 URL: https://github.com/apache/flink/pull/9751#issuecomment-535372743 @zentol could you take a look at the problem with `tools/releasing/collect_license_files.sh build-target`?

[GitHub] [flink] tillrohrmann commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11

tillrohrmann commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11 URL: https://github.com/apache/flink/pull/9775#issuecomment-53534 > One more question. Is

[jira] [Created] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

Gary Yao created FLINK-14226: Summary: Subset of nightly tests fail due to No output has been received in the last 10m0s Key: FLINK-14226 URL: https://issues.apache.org/jira/browse/FLINK-14226 Project:

[GitHub] [flink] TisonKun commented on issue #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method

TisonKun commented on issue #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535380450 Thanks for your information @yanghua ! Due to the ongoing effort I'd like to close this pull

[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_r328474557 ## File path:

[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: *

[jira] [Commented] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

[ https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938369#comment-16938369 ] Gary Yao commented on FLINK-14226: -- I do not think it's related to FLINK-11301 > Subset of nightly

[GitHub] [flink] TisonKun closed pull request #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method

TisonKun closed pull request #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

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

1u0 commented on a change in pull request #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#discussion_r328524715 ## File path:

[GitHub] [flink] zhuzhurk opened a new pull request #9778: [FLINK-14206][runtime] Let fullRestart metric count both full restarts and fine grained restarts

zhuzhurk opened a new pull request #9778: [FLINK-14206][runtime] Let fullRestart metric count both full restarts and fine grained restarts URL: https://github.com/apache/flink/pull/9778 ## What is the purpose of the change With fine grained recovery introduced in 1.9.0, the

[jira] [Updated] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14206: --- Labels: pull-request-available (was: ) > Let fullRestart metric count fine grained

[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

[GitHub] [flink] hequn8128 closed pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution

hequn8128 closed pull request #9748: [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution URL: https://github.com/apache/flink/pull/9748 This is an automated message from

[jira] [Created] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

Till Rohrmann created FLINK-14223: - Summary: Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis Key: FLINK-14223 URL: https://issues.apache.org/jira/browse/FLINK-14223

[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: *

[jira] [Assigned] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-12576: -- Assignee: (was: Aitozi) > inputQueueLength metric does not work for

[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_r328473311 ## File path:

[GitHub] [flink] TisonKun commented on issue #9762: !IGNORE! ZK 3.5.5 shaded migration

TisonKun commented on issue #9762: !IGNORE! ZK 3.5.5 shaded migration URL: https://github.com/apache/flink/pull/9762#issuecomment-535384214 Failure cannot reproduce locally. I notice several issues due to different version of Maven. Locally I use 3.6.1 and will try again with

[GitHub] [flink] flinkbot commented on issue #9777: [FLINK-13143] Remove CheckpointExceptionHandler relevant classes

flinkbot commented on issue #9777: [FLINK-13143] Remove CheckpointExceptionHandler relevant classes URL: https://github.com/apache/flink/pull/9777#issuecomment-53537 ## CI report: * 8408299abf3e5f421ed2867ffa5629171c47af6b : UNKNOWN

[jira] [Commented] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938397#comment-16938397 ] David Anderson commented on FLINK-12576: > Input queue length of both the local and remote

[GitHub] [flink] wsry commented on a change in pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush.

wsry commented on a change in pull request #9706: [FLINK-14118][runtime]Reduce the unnecessary flushing when there is no data available for flush. URL: https://github.com/apache/flink/pull/9706#discussion_r328490790 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328494978 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[GitHub] [flink] Mrart commented on a change in pull request #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi…

Mrart commented on a change in pull request #9773: [FLINK-14210][metrics]support connect timeout and write timeout confi… URL: https://github.com/apache/flink/pull/9773#discussion_r328505056 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9777: [FLINK-13143] Remove CheckpointExceptionHandler relevant classes

flinkbot edited a comment on issue #9777: [FLINK-13143] Remove CheckpointExceptionHandler relevant classes URL: https://github.com/apache/flink/pull/9777#issuecomment-53537 ## CI report: * 8408299abf3e5f421ed2867ffa5629171c47af6b : FAILURE

[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_r328526479 ## File path:

[jira] [Updated] (FLINK-14206) Let fullRestart metric count fine grained restarts as well

[ https://issues.apache.org/jira/browse/FLINK-14206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14206: Description: With fine grained recovery introduced in 1.9.0, the {{fullRestart}} metric only counts how

[jira] [Commented] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes

[ https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938472#comment-16938472 ] Yingjie Cao commented on FLINK-14195: - Thanks [~trohrmann]. My branch is 

[GitHub] [flink] flinkbot edited a comment on issue #9759: [FLINK-14169][history-server] Cleanup expired jobs from history server

flinkbot edited a comment on issue #9759: [FLINK-14169][history-server] Cleanup expired jobs from history server URL: https://github.com/apache/flink/pull/9759#issuecomment-534565511 ## CI report: * 70cf88200f1b09ca6932462f4d51834c339077e3 : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method

flinkbot commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535357550 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Commented] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938324#comment-16938324 ] Hequn Cheng commented on FLINK-14016: - Resolved in 1.10.0 via

[jira] [Created] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

Till Rohrmann created FLINK-14224: - Summary: Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis Key: FLINK-14224 URL:

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938356#comment-16938356 ] Till Rohrmann commented on FLINK-14224: --- cc [~becket_qin] >

[jira] [Commented] (FLINK-14223) Kafka010ProducerITCase>KafkaProducerTestBase.testCustomPartitioning fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938355#comment-16938355 ] Till Rohrmann commented on FLINK-14223: --- [~becket_qin] could you take a look at this problem? >

[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=16938375#comment-16938375 ] lining commented on FLINK-11374: [~trohrmann], could you assign this issue to me? Then i and

[jira] [Updated] (FLINK-13143) Remove CheckpointExceptionHandler relevant classes

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13143: - Summary: Remove CheckpointExceptionHandler relevant classes (was: Refactor CheckpointExceptionHandler

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[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_r328521088 ## File path:

[jira] [Assigned] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-10672: Assignee: Yun Gao > Task stuck while writing output to flink >

[jira] [Commented] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes

[ https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938466#comment-16938466 ] Till Rohrmann commented on FLINK-14195: --- [~kevin.cyj] thanks for looking into the problem. Can you

[jira] [Updated] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes

[ https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14195: -- Priority: Blocker (was: Critical) > Nightly connectors-jdk11 fails because of missing jaxb

[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_r328459063 ## File path:

[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_r328463014 ## File path:

[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_r328462756 ## File path:

[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_r328474162 ## File path:

[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_r328480573 ## File path:

[jira] [Commented] (FLINK-14195) Nightly connectors-jdk11 fails because of missing jaxb classes

[ https://issues.apache.org/jira/browse/FLINK-14195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938383#comment-16938383 ] Yingjie Cao commented on FLINK-14195: - Hi [~trohrmann], I am trying to fix the problem but

[GitHub] [flink] WeiZhong94 commented on a change in pull request #9766: [FLINK-14018][python] Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

WeiZhong94 commented on a change in pull request #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#discussion_r328480727 ## File path: pom.xml ##

[GitHub] [flink] flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy

flinkbot edited a comment on issue #9688: [FLINK-13056][runtime] Introduce FastRestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/9688#issuecomment-531737820 ## CI report: * 23278b65f27154ae066841334f0d0b06885e713a : FAILURE

[GitHub] [flink] lamber-ken commented on issue #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method

lamber-ken commented on issue #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535391017 > OK, the relevant JIRA issue about this parameter is:

[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: *

[jira] [Commented] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938406#comment-16938406 ] Yingjie Cao commented on FLINK-12576: - [~alpinegizmo] Because only one of the two upstream task will

[GitHub] [flink] flinkbot edited a comment on issue #9759: [FLINK-14169][history-server] Cleanup expired jobs from history server

flinkbot edited a comment on issue #9759: [FLINK-14169][history-server] Cleanup expired jobs from history server URL: https://github.com/apache/flink/pull/9759#issuecomment-534565511 ## CI report: * 70cf88200f1b09ca6932462f4d51834c339077e3 : SUCCESS

[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_r328525293 ## File path:

[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_r328525320 ## File path:

[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_r328525357 ## File path:

[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_r328544533 ## File path:

[jira] [Updated] (FLINK-14196) Nightly e2e-sticky-hadoop2.8 fails due to NPE

[ https://issues.apache.org/jira/browse/FLINK-14196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-14196: -- Priority: Blocker (was: Critical) > Nightly e2e-sticky-hadoop2.8 fails due to NPE >

[GitHub] [flink] zhijiangW edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator

zhijiangW edited a comment on issue #9717: [FLINK-14044] [runtime] Reducing synchronization in AsyncWaitOperator URL: https://github.com/apache/flink/pull/9717#issuecomment-535443887 @AHeise I have finished the first round review. Almost LGTM only for some tiny comments. In

[GitHub] [flink] flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot edited a comment on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532984287 ## CI report: * f2b7710f65f478342de389c8e099799287ddf3f9 : FAILURE

[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=16938317#comment-16938317 ] Till Rohrmann commented on FLINK-11374: --- Yes this sounds like a good idea [~lining]. > See more

[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_r328460576 ## File path:

[GitHub] [flink] TisonKun commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method

TisonKun commented on issue #9776: [HOTFIX] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535367265 @flinkbot attention @yanghua please take a look why we don't use this parameter.

[GitHub] [flink] flinkbot commented on issue #9777: [FLINK-13143] Refactor CheckpointExceptionHandler relevant classes

flinkbot commented on issue #9777: [FLINK-13143] Refactor CheckpointExceptionHandler relevant classes URL: https://github.com/apache/flink/pull/9777#issuecomment-535381785 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[GitHub] [flink] yanghua commented on issue #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method

yanghua commented on issue #9776: [HOTFIX][coordination] remove the invalid parameter in handleCheckpointSuccess method URL: https://github.com/apache/flink/pull/9776#issuecomment-535382163 OK, the relevant JIRA issue about this parameter is:

[jira] [Assigned] (FLINK-14215) Add Docs for TM and JM Environment Variable Setting

[ https://issues.apache.org/jira/browse/FLINK-14215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-14215: - Assignee: Zhenqiu Huang > Add Docs for TM and JM Environment Variable Setting >

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938381#comment-16938381 ] Zili Chen commented on FLINK-13417: --- Thanks for your information [~trohrmann]. FYI I open a testing

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328495855 ## File path:

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r328496239 ## File path:

[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_r328471027 ## File path:

[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_r328471027 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11

tillrohrmann commented on issue #9775: [FLINK-14186][e2e] Let JVM ignores unrecoginzed options to avoid end to end test failure in es 2.3.5 with JDK11 URL: https://github.com/apache/flink/pull/9775#issuecomment-535438266 We could use `if [[ ${PROFILE} != *"jdk11"* ]]; then` to filter out

  1   2   3   4   >