[GitHub] [flink] flinkbot edited a comment on pull request #14434: [DOC]fix to update file_sink & streamfile_sink doc for error code

flinkbot edited a comment on pull request #14434: URL: https://github.com/apache/flink/pull/14434#issuecomment-748424188 ## CI report: * c842f89ec6dc499aae7892af964db77f595d547f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14434: [DOC]fix to update file_sink & streamfile_sink doc for error code

flinkbot edited a comment on pull request #14434: URL: https://github.com/apache/flink/pull/14434#issuecomment-748424188 ## CI report: * c842f89ec6dc499aae7892af964db77f595d547f Azure:

[GitHub] [flink] flinkbot commented on pull request #14434: [DOC]fix to update file_sink & streamfile_sink doc for error code

flinkbot commented on pull request #14434: URL: https://github.com/apache/flink/pull/14434#issuecomment-748424188 ## CI report: * c842f89ec6dc499aae7892af964db77f595d547f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14433: [typo] fix kubernetes ha typo

flinkbot edited a comment on pull request #14433: URL: https://github.com/apache/flink/pull/14433#issuecomment-748371062 ## CI report: * 7511cbed092a30ac95caf96f2205bc5f299fb3b7 Azure:

[GitHub] [flink] flinkbot commented on pull request #14434: [DOC]fix to update file_sink & streamfile_sink doc for error code

flinkbot commented on pull request #14434: URL: https://github.com/apache/flink/pull/14434#issuecomment-748423025 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 will use this comment to track the

[GitHub] [flink] hehuiyuan opened a new pull request #14434: [DOC]fix to update file_sink & streamfile_sink doc for error code

hehuiyuan opened a new pull request #14434: URL: https://github.com/apache/flink/pull/14434 ## What is the purpose of the change There are some documents error. 

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252096#comment-17252096 ] Huang Xingbo commented on FLINK-20662: --

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252095#comment-17252095 ] Yun Gao commented on FLINK-20476: - It also seems there is always one TaskManager keep iterating on the

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252094#comment-17252094 ] Huang Xingbo commented on FLINK-20329: --

[jira] [Created] (FLINK-20679) JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering test failed

Huang Xingbo created FLINK-20679: Summary: JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering test failed Key: FLINK-20679 URL: https://issues.apache.org/jira/browse/FLINK-20679 Project: Flink

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252093#comment-17252093 ] Yun Gao commented on FLINK-20476: - Hi [~hxbks2ks], very thanks for reporting the issues! But the new

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252090#comment-17252090 ] Huang Xingbo commented on FLINK-20662: --

[jira] [Closed] (FLINK-20666) Fix the deserialized Row losing the field_name information in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-20666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-20666. --- Fix Version/s: 1.12.1 1.11.4 1.13.0 Resolution: Fixed Fixed in

[GitHub] [flink] dianfu closed pull request #14422: [FLINK-20666][python] Fix the deserialized Row losing the field_name information in PyFlink

dianfu closed pull request #14422: URL: https://github.com/apache/flink/pull/14422 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Assigned] (FLINK-20666) Fix the deserialized Row losing the field_name information in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-20666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-20666: --- Assignee: Huang Xingbo > Fix the deserialized Row losing the field_name information in PyFlink >

[GitHub] [flink] dianfu merged pull request #14426: [FLINK-20666][python] Fix the deserialized Row losing the field_name information in PyFlink

dianfu merged pull request #14426: URL: https://github.com/apache/flink/pull/14426 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-20476) New File Sink end-to-end test Failed

[ https://issues.apache.org/jira/browse/FLINK-20476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252083#comment-17252083 ] Huang Xingbo commented on FLINK-20476: --

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252082#comment-17252082 ] Huang Xingbo commented on FLINK-20662: --

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252081#comment-17252081 ] Huang Xingbo commented on FLINK-20662: -- Hi [~AHeise] It seems that this issue occurs quite

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252080#comment-17252080 ] Huang Xingbo commented on FLINK-20662: --

[jira] [Commented] (FLINK-20662) UnalignedCheckpointITCase.execute failed with IndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/FLINK-20662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252078#comment-17252078 ] Huang Xingbo commented on FLINK-20662: --

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252076#comment-17252076 ] Huang Xingbo commented on FLINK-20254: --

[jira] [Commented] (FLINK-20389) UnalignedCheckpointITCase failure caused by NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17252075#comment-17252075 ] Huang Xingbo commented on FLINK-20389: --

[GitHub] [flink] flinkbot edited a comment on pull request #14433: [typo] fix kubernetes ha typo

flinkbot edited a comment on pull request #14433: URL: https://github.com/apache/flink/pull/14433#issuecomment-748371062 ## CI report: * 7511cbed092a30ac95caf96f2205bc5f299fb3b7 Azure:

[GitHub] [flink] flinkbot commented on pull request #14433: [typo] fix kubernetes ha typo

flinkbot commented on pull request #14433: URL: https://github.com/apache/flink/pull/14433#issuecomment-748371062 ## CI report: * 7511cbed092a30ac95caf96f2205bc5f299fb3b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14433: [typo] fix kubernetes ha typo

flinkbot commented on pull request #14433: URL: https://github.com/apache/flink/pull/14433#issuecomment-748368610 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 will use this comment to track the

[GitHub] [flink] casidiablo opened a new pull request #14433: [typo] fix kubernetes ha typo

casidiablo opened a new pull request #14433: URL: https://github.com/apache/flink/pull/14433 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[GitHub] [flink-docker] tianon commented on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

tianon commented on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748346905 `docker run flink run bash` just to get a shell that has useful environment variables is a bit convoluted/awkward -- are these variables harmful for normal commands? Given

[GitHub] [flink] flinkbot edited a comment on pull request #14432: [FLINK-20678] Let JobManagerRunnerImpl fail if the JobMasterService fails unexpectedly

flinkbot edited a comment on pull request #14432: URL: https://github.com/apache/flink/pull/14432#issuecomment-748196526 ## CI report: * d2192e5c0d882ef4d475b2f55b0623673026fb7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14431: [FLINK-11719] Do not reuse JobMaster instances across leader sessions

flinkbot edited a comment on pull request #14431: URL: https://github.com/apache/flink/pull/14431#issuecomment-748196435 ## CI report: * aec1ac97effc6607d3fb4f94fe323c86c20759a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

flinkbot edited a comment on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277 ## CI report: * ba3f9a13b98b5ddaee1dcf142ee3cf00322fe5c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14430: [FLINK-20677] Introduce proper JobManagerRunnerResult

flinkbot edited a comment on pull request #14430: URL: https://github.com/apache/flink/pull/14430#issuecomment-748196338 ## CI report: * 2996e3ffa70a4caa7437c9699e1cbc93ebfe488a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14423: [FLINK-20673][table-planner-blink] ExecNode#getOutputType method should return LogicalType instead of RowType

flinkbot edited a comment on pull request #14423: URL: https://github.com/apache/flink/pull/14423#issuecomment-748013167 ## CI report: * feca8bda1976f237787ea3219b567bff442e4568 Azure:

[jira] [Commented] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251965#comment-17251965 ] Arvid Heise commented on FLINK-20433: - Stabilized test in master as

[GitHub] [flink] AHeise merged pull request #14421: [FLINK-20433][tests] Stabilizing UnalignedCheckpointITCase. [1.12]

AHeise merged pull request #14421: URL: https://github.com/apache/flink/pull/14421 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #14429: [FLINK-20623][table-planner-blink] Introduce StreamPhysicalWatermarkAssigner, and make StreamExecWatermarkAssigner only extended from

flinkbot edited a comment on pull request #14429: URL: https://github.com/apache/flink/pull/14429#issuecomment-748082234 ## CI report: * 2480c4158f646cef362efb050fe60356c80bcd0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 091ba28c2182acfbb79b8cf0c0d6b0b2d40784ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14427: [FLINK-20608][table-planner-blink] Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourceScan

flinkbot edited a comment on pull request #14427: URL: https://github.com/apache/flink/pull/14427#issuecomment-748081998 ## CI report: * ac114d186758867e905eb1cd891a9a52279ed375 Azure:

[jira] [Commented] (FLINK-20672) CheckpointAborted RPC failure can fail JM

[ https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251928#comment-17251928 ] Roman Khachatryan commented on FLINK-20672: --- Thanks for the confirmation [~yunta]. >

[jira] [Updated] (FLINK-20672) CheckpointAborted RPC failure can fail JM

[ https://issues.apache.org/jira/browse/FLINK-20672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-20672: -- Fix Version/s: 1.13.0 > CheckpointAborted RPC failure can fail JM >

[GitHub] [flink] flinkbot edited a comment on pull request #14402: [FLINK-20622][table-planner-blink] Introduce StreamPhysicalChangelogNormalize, and make StreamExecChangelogNormalize only extended fr

flinkbot edited a comment on pull request #14402: URL: https://github.com/apache/flink/pull/14402#issuecomment-74600 ## CI report: * 64e05a309f50760e1f821402892b36b3c8e58133 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14400: [FLINK-20610][table-planner-blink] Separate the implementation of BatchExecCalc and StreamExecCalc

flinkbot edited a comment on pull request #14400: URL: https://github.com/apache/flink/pull/14400#issuecomment-745936223 ## CI report: * d37a896391cd2b590044d3ec1074798cb01bdbed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14426: [FLINK-20666][python] Fix the deserialized Row losing the field_name information in PyFlink

flinkbot edited a comment on pull request #14426: URL: https://github.com/apache/flink/pull/14426#issuecomment-748081897 ## CI report: * acccd3653ec2ae872671b5289ca4082e2ab9107b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14398: [FLINK-20516][table-planner-blink] Separate the implementation of BatchExecTableSourceScan and StreamExecTableSourceScan

flinkbot edited a comment on pull request #14398: URL: https://github.com/apache/flink/pull/14398#issuecomment-745762402 ## CI report: * ebca7dda6bb09c98710b8f34a4e5b3cd2b156f0a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 4333cc2789d8eccf1ddc58a3c79ab0880169fab6 Azure:

[jira] [Commented] (FLINK-20552) JdbcDynamicTableSink doesn't sink buffered data on checkpoint

[ https://issues.apache.org/jira/browse/FLINK-20552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251912#comment-17251912 ] mei jie commented on FLINK-20552: - Hi, [~jark] Too busy these days, I will fix this at this weekend.

[GitHub] [flink] flinkbot edited a comment on pull request #14425: [FLINK-19773][runtime] Implement ExponentialDelayStrategy

flinkbot edited a comment on pull request #14425: URL: https://github.com/apache/flink/pull/14425#issuecomment-748063383 ## CI report: * 0b24ca071bed9d436d66a2362c5a93efdb049e11 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 3556926bfe3d10e73d4700f295c7343e7b42509e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

flinkbot edited a comment on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277 ## CI report: * ffcb3c699eb099caccb20aa38f372557e8a59306 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14423: [FLINK-20673][table-planner-blink] ExecNode#getOutputType method should return LogicalType instead of RowType

flinkbot edited a comment on pull request #14423: URL: https://github.com/apache/flink/pull/14423#issuecomment-748013167 ## CI report: * c1507f5fd4747da2a8d3434b2cdbc883a1d332f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14432: [FLINK-20678] Let JobManagerRunnerImpl fail if the JobMasterService fails unexpectedly

flinkbot edited a comment on pull request #14432: URL: https://github.com/apache/flink/pull/14432#issuecomment-748196526 ## CI report: * d2192e5c0d882ef4d475b2f55b0623673026fb7d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14431: [FLINK-11719] Do not reuse JobMaster instances across leader sessions

flinkbot edited a comment on pull request #14431: URL: https://github.com/apache/flink/pull/14431#issuecomment-748196435 ## CI report: * aec1ac97effc6607d3fb4f94fe323c86c20759a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14430: [FLINK-20677] Introduce proper JobManagerRunnerResult

flinkbot edited a comment on pull request #14430: URL: https://github.com/apache/flink/pull/14430#issuecomment-748196338 ## CI report: * 2996e3ffa70a4caa7437c9699e1cbc93ebfe488a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14422: [FLINK-20666][python] Fix the deserialized Row losing the field_name information in PyFlink

flinkbot edited a comment on pull request #14422: URL: https://github.com/apache/flink/pull/14422#issuecomment-747979046 ## CI report: * 6496e62d787b56d01e9053fa4f59e2ec5ac9077e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14377: [FLINK-19905][Connector][jdbc] The Jdbc-connector's 'lookup.max-retries' option initial value is 1 in JdbcLookupFunction

flinkbot edited a comment on pull request #14377: URL: https://github.com/apache/flink/pull/14377#issuecomment-744303277 ## CI report: * ffcb3c699eb099caccb20aa38f372557e8a59306 Azure:

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251864#comment-17251864 ] Arvid Heise commented on FLINK-20654: - For my investigation, I added a bunch of info statements to

[jira] [Commented] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251863#comment-17251863 ] Boris Lublinsky commented on FLINK-20664: - I think so. This gives me the flexibility. I can

[jira] [Updated] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20654: Description: Fix of FLINK-20433 shows potential corruption after recovery for all variations of

[GitHub] [flink] flinkbot commented on pull request #14432: [FLINK-20678] Let JobManagerRunnerImpl fail if the JobMasterService fails unexpectedly

flinkbot commented on pull request #14432: URL: https://github.com/apache/flink/pull/14432#issuecomment-748196526 ## CI report: * d2192e5c0d882ef4d475b2f55b0623673026fb7d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14431: [FLINK-11719] Do not reuse JobMaster instances across leader sessions

flinkbot commented on pull request #14431: URL: https://github.com/apache/flink/pull/14431#issuecomment-748196435 ## CI report: * aec1ac97effc6607d3fb4f94fe323c86c20759a8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #14430: [FLINK-20677] Introduce proper JobManagerRunnerResult

flinkbot commented on pull request #14430: URL: https://github.com/apache/flink/pull/14430#issuecomment-748196338 ## CI report: * 2996e3ffa70a4caa7437c9699e1cbc93ebfe488a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Issue Comment Deleted] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20648: -- Comment: was deleted (was: Hmm. Maybe we could build the rpc endpoint id for JobMaster outside and

[GitHub] [flink] kl0u commented on a change in pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

kl0u commented on a change in pull request #14312: URL: https://github.com/apache/flink/pull/14312#discussion_r545953329 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java ## @@ -143,7 +150,20 @@

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 3556926bfe3d10e73d4700f295c7343e7b42509e Azure:

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251850#comment-17251850 ] Yang Wang commented on FLINK-20648: --- Yes. We are justing using the {{leaderContenderDescription}}(aka

[GitHub] [flink] flinkbot commented on pull request #14432: [FLINK-20678] Let JobManagerRunnerImpl fail if the JobMasterService fails unexpectedly

flinkbot commented on pull request #14432: URL: https://github.com/apache/flink/pull/14432#issuecomment-748187284 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 will use this comment to track the

[jira] [Assigned] (FLINK-19369) BlobClientTest.testGetFailsDuringStreamingForJobPermanentBlob hangs

[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-19369: - Assignee: Till Rohrmann >

[jira] [Updated] (FLINK-20678) JobManagerRunnerImpl does not notice unexpected JobMasterService termination

[ https://issues.apache.org/jira/browse/FLINK-20678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20678: --- Labels: pull-request-available (was: ) > JobManagerRunnerImpl does not notice unexpected

[jira] [Commented] (FLINK-20664) Support setting service account for TaskManager pod

[ https://issues.apache.org/jira/browse/FLINK-20664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251848#comment-17251848 ] Yang Wang commented on FLINK-20664: --- [~lublinsky] Do you think adding a new config option

[GitHub] [flink] tillrohrmann opened a new pull request #14432: [FLINK-20678] Let JobManagerRunnerImpl fail if the JobMasterService fails unexpectedly

tillrohrmann opened a new pull request #14432: URL: https://github.com/apache/flink/pull/14432 ## What is the purpose of the change This is a safety net which ensures that the JobManagerRunnerImpl will fail if the JobMasterService fails unexpectedly. ## Verifying this

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * d1afe2b80aee567e824eee4c8654798e7163a01b Azure:

[GitHub] [flink] flinkbot commented on pull request #14431: [FLINK-11719] Do not reuse JobMaster instances across leader sessions

flinkbot commented on pull request #14431: URL: https://github.com/apache/flink/pull/14431#issuecomment-748184472 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 will use this comment to track the

[jira] [Created] (FLINK-20678) JobManagerRunnerImpl does not notice unexpected JobMasterService termination

Till Rohrmann created FLINK-20678: - Summary: JobManagerRunnerImpl does not notice unexpected JobMasterService termination Key: FLINK-20678 URL: https://issues.apache.org/jira/browse/FLINK-20678

[jira] [Updated] (FLINK-11719) Remove JobMaster#start(JobMasterId) and #suspend

[ https://issues.apache.org/jira/browse/FLINK-11719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11719: --- Labels: pull-request-available (was: ) > Remove JobMaster#start(JobMasterId) and #suspend

[GitHub] [flink] tillrohrmann opened a new pull request #14431: [FLINK-11719] Do not reuse JobMaster instances across leader sessions

tillrohrmann opened a new pull request #14431: URL: https://github.com/apache/flink/pull/14431 ## What is the purpose of the change This PR changes how the `JobMaster` is used by the `JobManagerRunnerImpl`. Instead of reusing the `JobMaster` across different leader sessions, the

[GitHub] [flink] flinkbot commented on pull request #14430: [FLINK-20677] Introduce proper JobManagerRunnerResult

flinkbot commented on pull request #14430: URL: https://github.com/apache/flink/pull/14430#issuecomment-748182634 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 will use this comment to track the

[jira] [Updated] (FLINK-20677) Let JobManagerRunner return JobManagerRunnerResult to better distinguish result cases

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

[GitHub] [flink] tillrohrmann opened a new pull request #14430: [FLINK-20677] Introduce proper JobManagerRunnerResult

tillrohrmann opened a new pull request #14430: URL: https://github.com/apache/flink/pull/14430 ## What is the purpose of the change The JobManagerRunnerResult allows to express different termination conditions for the JobManagerRunner: 1) Job finished successfully 2) Job

[jira] [Created] (FLINK-20677) Let JobManagerRunner return JobManagerRunnerResult to better distinguish result cases

Till Rohrmann created FLINK-20677: - Summary: Let JobManagerRunner return JobManagerRunnerResult to better distinguish result cases Key: FLINK-20677 URL: https://issues.apache.org/jira/browse/FLINK-20677

[GitHub] [flink-docker] wangyang0918 edited a comment on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

wangyang0918 edited a comment on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748171203 @tillrohrmann I have updated this PR. Once this PR is merged, we could ping the docker guys for merging the docker publishing PR for 1.12.0. I also created a

[jira] [Created] (FLINK-20676) Remove deprecated command "native-k8s" in docker-entrypoint.sh

Yang Wang created FLINK-20676: - Summary: Remove deprecated command "native-k8s" in docker-entrypoint.sh Key: FLINK-20676 URL: https://issues.apache.org/jira/browse/FLINK-20676 Project: Flink

[jira] [Updated] (FLINK-20650) Add new general command "run" and mark "native-k8s" as deprecated in docker-entrypoint.sh

[ https://issues.apache.org/jira/browse/FLINK-20650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20650: -- Summary: Add new general command "run" and mark "native-k8s" as deprecated in docker-entrypoint.sh

[jira] [Updated] (FLINK-20650) [FLINK-20650] Add new general command "run" and mark "native-k8s" as deprecated in docker-entrypoint.sh

[ https://issues.apache.org/jira/browse/FLINK-20650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-20650: -- Summary: [FLINK-20650] Add new general command "run" and mark "native-k8s" as deprecated in

[GitHub] [flink] flinkbot edited a comment on pull request #14424: [FLINK-19369][tests] Disable BlobClientSslTest.testGetFailsDuringStreaming*

flinkbot edited a comment on pull request #14424: URL: https://github.com/apache/flink/pull/14424#issuecomment-748039662 ## CI report: * a281ac1645846dce585e8b377c4f48a7e03e8cf6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 47dcb9670fdea6129692d27b33dc13b620248600 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14361: [FLINK-19435][connectors/jdbc] Fix deadlock when loading different driver classes concurrently using Class.forName

flinkbot edited a comment on pull request #14361: URL: https://github.com/apache/flink/pull/14361#issuecomment-742899629 ## CI report: * 0aa90c60d5e038daeb11b9ed90ef1226a4410613 Azure:

[jira] [Commented] (FLINK-17598) Implement FileSystemHAServices for native K8s setups

[ https://issues.apache.org/jira/browse/FLINK-17598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251835#comment-17251835 ] Yang Wang commented on FLINK-17598: --- cc [~boris.lublin...@cna.com], do you think we still need to

[GitHub] [flink-docker] wangyang0918 commented on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

wangyang0918 commented on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748171203 @tillrohrmann I have updated this PR. Once this PR is merged, we could ping the docker guys for merging the docker publishing PR for 1.12.0.

[jira] [Updated] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-20675: - Description: After FLINK-12364, no mater how many times of asynchronous part of checkpoint on task

[jira] [Commented] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

[ https://issues.apache.org/jira/browse/FLINK-20675?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251834#comment-17251834 ] Yun Tang commented on FLINK-20675: -- cc [~pnowojski] > Asynchronous checkpoint failure would not fail

[jira] [Created] (FLINK-20675) Asynchronous checkpoint failure would not fail the job anymore

Yun Tang created FLINK-20675: Summary: Asynchronous checkpoint failure would not fail the job anymore Key: FLINK-20675 URL: https://issues.apache.org/jira/browse/FLINK-20675 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * 1e4d45934795e74502b7871d1cbad7380727ad22 Azure:

[jira] [Commented] (FLINK-20674) Wrong send/received stats with UNION ALL

[ https://issues.apache.org/jira/browse/FLINK-20674?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251825#comment-17251825 ] Piotr Nowojski commented on FLINK-20674: Ideally we would have both bytes/records produced and

[GitHub] [flink] flinkbot edited a comment on pull request #14428: [FLINK-20609][table-planner-blink] Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan

flinkbot edited a comment on pull request #14428: URL: https://github.com/apache/flink/pull/14428#issuecomment-748082099 ## CI report: * c8d5bac964a6dd973db3e643118f4af50c82f7a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

flinkbot edited a comment on pull request #14387: URL: https://github.com/apache/flink/pull/14387#issuecomment-745165624 ## CI report: * 47dcb9670fdea6129692d27b33dc13b620248600 Azure:

[GitHub] [flink-docker] tillrohrmann commented on pull request #49: [FLINK-20650] Rename "native-k8s" command to a more general name in docker-entrypoint.sh

tillrohrmann commented on pull request #49: URL: https://github.com/apache/flink-docker/pull/49#issuecomment-748153256 Yes, this would be my suggestion in order to not break things within the `1.12.x` release line. This is

[jira] [Commented] (FLINK-20648) Unable to restore job from savepoint when using Kubernetes based HA services

[ https://issues.apache.org/jira/browse/FLINK-20648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251821#comment-17251821 ] Till Rohrmann commented on FLINK-20648: --- The address of the contender does not need to be known

[GitHub] [flink] xiaoHoly commented on a change in pull request #14387: [FLINK-19691][Connector][jdbc] Expose `CONNECTION_CHECK_TIMEOUT_SECONDS` as a configurable option in Jdbc connector

xiaoHoly commented on a change in pull request #14387: URL: https://github.com/apache/flink/pull/14387#discussion_r545900554 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcOptions.java ## @@ -150,7 +168,7

[jira] [Closed] (FLINK-19880) Fix ignore-parse-errors not work for the legacy JSON format

[ https://issues.apache.org/jira/browse/FLINK-19880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19880. --- Resolution: Fixed Fixed in - master: fc660274a5c7b4cdea00335cac87bdf5d421db92 - release-1.12:

[GitHub] [flink] flinkbot edited a comment on pull request #14423: [FLINK-20673][table-planner-blink] ExecNode#getOutputType method should return LogicalType instead of RowType

flinkbot edited a comment on pull request #14423: URL: https://github.com/apache/flink/pull/14423#issuecomment-748013167 ## CI report: * 0cd0435254c0858f52ad5bd5f7d998ce2b9797e1 Azure:

  1   2   3   4   >