[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: * a006bfe64ef6b5ba5e9d553a9da2c5015ca6cf2d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-17328) Expose network metric for job vertex in rest api

[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252668#comment-17252668 ] Piotr Nowojski commented on FLINK-17328: I'm currently taking over and investiga

[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: * c14c4c87691bfa10a61424323e35fcbd74b1098d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14442: [FLINK-20213][fs-connector] Partition commit is delayed when records keep coming

flinkbot edited a comment on pull request #14442: URL: https://github.com/apache/flink/pull/14442#issuecomment-748818625 ## CI report: * 99b3b8824b9991e9906cd6ab4e38a6766e34f0cf Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-20694) Declarative resource management can get stuck in a loop

Chesnay Schepler created FLINK-20694: Summary: Declarative resource management can get stuck in a loop Key: FLINK-20694 URL: https://issues.apache.org/jira/browse/FLINK-20694 Project: Flink

[jira] [Updated] (FLINK-20694) Declarative resource management can get stuck in a loop

[ https://issues.apache.org/jira/browse/FLINK-20694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20694: - Priority: Blocker (was: Major) > Declarative resource management can get stuck in a loo

[jira] [Closed] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration"

[ https://issues.apache.org/jira/browse/FLINK-20688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20688. Fix Version/s: (was: 1.13.0) Resolution: Duplicate Tracking this in FLINK-20694

[jira] [Commented] (FLINK-20458) Translate page 'SQL-gettingStarted' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-20458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252676#comment-17252676 ] Subao commented on FLINK-20458: --- Hi,Seth! I offen use Flink SQL in my work after I graduat

[jira] [Commented] (FLINK-20688) New File Sink end-to-end test failed repeating "Received resource declaration"

[ https://issues.apache.org/jira/browse/FLINK-20688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252677#comment-17252677 ] Chesnay Schepler commented on FLINK-20688: -- Scratch that, we were only logging

[GitHub] [flink] flinkbot edited a comment on pull request #13907: [FLINK-19942][Connectors / JDBC]Support sink parallelism configuration to JDBC connector

flinkbot edited a comment on pull request #13907: URL: https://github.com/apache/flink/pull/13907#issuecomment-721230727 ## CI report: * f4f1cf14d4d413c4c87881516215c7d5be64 UNKNOWN * 9341091a00aaf73556b7e6c5f9bc319a9512dd5a Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] xintongsong commented on pull request #14413: [FLINK-20646] Update memory requirements for ReduceTransformation

xintongsong commented on pull request #14413: URL: https://github.com/apache/flink/pull/14413#issuecomment-748840367 AFAIK, there's no concern that prevents this PR from getting merged. Since @aljoscha is on vacation, I'm merging this PR now.

[jira] [Commented] (FLINK-20618) Some of the source operator subtasks will stuck when flink job in critical backpressure

[ https://issues.apache.org/jira/browse/FLINK-20618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252685#comment-17252685 ] zlzhang0122 commented on FLINK-20618: - Ok, the network engineer is checking the netw

[GitHub] [flink] xintongsong closed pull request #14413: [FLINK-20646] Update memory requirements for ReduceTransformation

xintongsong closed pull request #14413: URL: https://github.com/apache/flink/pull/14413 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

[jira] [Updated] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20646: - Fix Version/s: 1.13.0 > ReduceTransformation does not work with RocksDBStateBackend > --

[jira] [Closed] (FLINK-20646) ReduceTransformation does not work with RocksDBStateBackend

[ https://issues.apache.org/jira/browse/FLINK-20646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-20646. Release Note: Fixed via: * master (1.13): cf71008984dd68b25db3612a9ca39f197b7e09c8 * release-1.12:

[GitHub] [flink] jrthe42 commented on a change in pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

jrthe42 commented on a change in pull request #14404: URL: https://github.com/apache/flink/pull/14404#discussion_r546571928 ## File path: flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamExecJoinRuleBase.scala ###

[jira] [Closed] (FLINK-20691) flink-1.12.0 job shutdown but metrics group not delete

[ https://issues.apache.org/jira/browse/FLINK-20691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20691. Resolution: Duplicate > flink-1.12.0 job shutdown but metrics group not delete > -

[jira] [Created] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

lidesheng created FLINK-20695: - Summary: Zookeeper node under leader and leaderlatch is not deleted after job finished Key: FLINK-20695 URL: https://issues.apache.org/jira/browse/FLINK-20695 Project: Flin

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252691#comment-17252691 ] Jingsong Lee commented on FLINK-20671: -- [~ZhuShang] Thanks for the reporting. I go

[GitHub] [flink] flinkbot edited a comment on pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

flinkbot edited a comment on pull request #14404: URL: https://github.com/apache/flink/pull/14404#issuecomment-746157858 ## CI report: * dd0716385b6e0c59ae8d9b33cd56d191bd65342a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 18b85ad3b3f803a13ad8239a039b57101a002d7f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] wenlong88 commented on a change in pull request #14402: [FLINK-20622][table-planner-blink] Introduce StreamPhysicalChangelogNormalize, and make StreamExecChangelogNormalize only exten

wenlong88 commented on a change in pull request #14402: URL: https://github.com/apache/flink/pull/14402#discussion_r546574624 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java #

[jira] [Commented] (FLINK-20685) Flink connect incorrect address of yarn's resouceManager scheduler

[ https://issues.apache.org/jira/browse/FLINK-20685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252692#comment-17252692 ] Spongebob commented on FLINK-20685: --- It works now, thanks for your kindly explain. >

[jira] [Commented] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252696#comment-17252696 ] zhuxiaoshang commented on FLINK-20671: -- Thanks for your [~lzljs3620320] patient exp

[jira] [Closed] (FLINK-20671) Partition doesn't commit until the end of partition

[ https://issues.apache.org/jira/browse/FLINK-20671?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhuxiaoshang closed FLINK-20671. Resolution: Not A Problem > Partition doesn't commit until the end of partition >

[jira] [Created] (FLINK-20696) Yarn Session Blob Directory is not deleted.

Mulan Wong created FLINK-20696: -- Summary: Yarn Session Blob Directory is not deleted. Key: FLINK-20696 URL: https://issues.apache.org/jira/browse/FLINK-20696 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mulan Wong updated FLINK-20696: --- Description: This Job is finished, but blob directory is not deleted. There is a small probability

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mulan Wong updated FLINK-20696: --- Attachment: (was: image-2020-12-21-16-43-32-220.png) > Yarn Session Blob Directory is not delete

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mulan Wong updated FLINK-20696: --- Description: This Job is finished, but blob directory is not deleted. There is a small probability

[jira] [Updated] (FLINK-20696) Yarn Session Blob Directory is not deleted.

[ https://issues.apache.org/jira/browse/FLINK-20696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mulan Wong updated FLINK-20696: --- Attachment: image-2020-12-21-16-47-37-278.png > Yarn Session Blob Directory is not deleted. > --

[GitHub] [flink] godfreyhe opened a new pull request #14443: [FLINK-20690][table-planner-blink] Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

godfreyhe opened a new pull request #14443: URL: https://github.com/apache/flink/pull/14443 ## What is the purpose of the change *Separate the implementation of BatchExecCorrelate and StreamExecCorrelate* ## Brief change log - *Introduce StreamPhysicalCorrelate & S

[jira] [Updated] (FLINK-20690) Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

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

[GitHub] [flink] flinkbot commented on pull request #14443: [FLINK-20690][table-planner-blink] Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

flinkbot commented on pull request #14443: URL: https://github.com/apache/flink/pull/14443#issuecomment-748855410 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #14404: [FLINK-20624][table-planner]Refactor StreamExecJoinRule, StreamExecIntervalJoinRule and StreamExecTemporalJoinRule

flinkbot edited a comment on pull request #14404: URL: https://github.com/apache/flink/pull/14404#issuecomment-746157858 ## CI report: * dd0716385b6e0c59ae8d9b33cd56d191bd65342a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

flinkbot edited a comment on pull request #14401: URL: https://github.com/apache/flink/pull/14401#issuecomment-745968134 ## CI report: * 8f14cd73606d83ac976b9e17934c645d13a32947 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-20614) Registered sql drivers not deregistered after task finished in session cluster

[ https://issues.apache.org/jira/browse/FLINK-20614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252707#comment-17252707 ] Flavio Pompermaier commented on FLINK-20614: Thank you [~kezhuw] for all you

[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&focusedCommentId=17252708#comment-17252708 ] Huang Xingbo commented on FLINK-20654: -- https://dev.azure.com/apache-flink/apache-f

[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&focusedCommentId=17252709#comment-17252709 ] Huang Xingbo commented on FLINK-20389: -- https://dev.azure.com/apache-flink/apache-f

[jira] [Comment Edited] (FLINK-18983) Job doesn't changed to failed if close function has blocked

[ https://issues.apache.org/jira/browse/FLINK-18983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252653#comment-17252653 ] Piotr Nowojski edited comment on FLINK-18983 at 12/21/20, 9:10 AM: ---

[GitHub] [flink] wenlong88 commented on a change in pull request #14427: [FLINK-20608][table-planner-blink] Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourc

wenlong88 commented on a change in pull request #14427: URL: https://github.com/apache/flink/pull/14427#discussion_r546575921 ## File path: flink-table/flink-table-planner-blink/src/test/resources/explain/testStreamTableEnvironmentExecutionExplain.out ## @@ -32,9 +32,9 @@ Leg

[GitHub] [flink] flinkbot edited a comment on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

flinkbot edited a comment on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-726354432 ## CI report: * a74097650256dde7e570ea1cd98bbaa31142799a UNKNOWN * f984efa3d7eedacd36d5f2c12f1256a10cfbc87d Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #14401: [FLINK-20621][python] Refactor the TypeInformation implementation in Python DataStream API.

flinkbot edited a comment on pull request #14401: URL: https://github.com/apache/flink/pull/14401#issuecomment-745968134 ## CI report: * 8f14cd73606d83ac976b9e17934c645d13a32947 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14443: [FLINK-20690][table-planner-blink] Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

flinkbot commented on pull request #14443: URL: https://github.com/apache/flink/pull/14443#issuecomment-748866082 ## CI report: * 42b36c4ab4cce97accc793cd93f147a372f5741e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] pnowojski commented on pull request #14057: [FLINK-19681][checkpointing] Timeout aligned checkpoints

pnowojski commented on pull request #14057: URL: https://github.com/apache/flink/pull/14057#issuecomment-748864186 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] godfreyhe commented on a change in pull request #14400: [FLINK-20610][table-planner-blink] Separate the implementation of BatchExecCalc and StreamExecCalc

godfreyhe commented on a change in pull request #14400: URL: https://github.com/apache/flink/pull/14400#discussion_r546594922 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecCalc.java ## @@ -0,0

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

[ https://issues.apache.org/jira/browse/FLINK-20679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20679: -- Priority: Critical (was: Major) > JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering test

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

[ https://issues.apache.org/jira/browse/FLINK-20679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20679: -- Fix Version/s: 1.13.0 > JobMasterTest.testSlotRequestTimeoutWhenNoSlotOffering test failed > -

[jira] [Updated] (FLINK-20682) Add configuration options related to hadoop

[ https://issues.apache.org/jira/browse/FLINK-20682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20682: -- Description: Current, we submit flink job to yarn with run-application target and need to spe

[GitHub] [flink] godfreyhe commented on a change in pull request #14400: [FLINK-20610][table-planner-blink] Separate the implementation of BatchExecCalc and StreamExecCalc

godfreyhe commented on a change in pull request #14400: URL: https://github.com/apache/flink/pull/14400#discussion_r546597347 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.java ## @@ -20,6 +20,7 @@

[GitHub] [flink] godfreyhe commented on a change in pull request #14400: [FLINK-20610][table-planner-blink] Separate the implementation of BatchExecCalc and StreamExecCalc

godfreyhe commented on a change in pull request #14400: URL: https://github.com/apache/flink/pull/14400#discussion_r546597347 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/ExecNodeBase.java ## @@ -20,6 +20,7 @@

[jira] [Commented] (FLINK-20682) Add configuration options related to hadoop

[ https://issues.apache.org/jira/browse/FLINK-20682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252719#comment-17252719 ] Till Rohrmann commented on FLINK-20682: --- Thanks for creating this issue [~jiang7ch

[GitHub] [flink] wenlong88 commented on a change in pull request #14428: [FLINK-20609][table-planner-blink] Separate the implementation of BatchExecDataStreamScan and StreamExecDataStreamScan

wenlong88 commented on a change in pull request #14428: URL: https://github.com/apache/flink/pull/14428#discussion_r546598135 ## File path: flink-table/flink-table-planner-blink/src/test/resources/explain/testStatementSetExecutionExplain.out ## @@ -32,9 +32,9 @@ LegacySink(na

[jira] [Commented] (FLINK-20681) Support specifying the hdfs path when ship archives or files

[ https://issues.apache.org/jira/browse/FLINK-20681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252722#comment-17252722 ] Till Rohrmann commented on FLINK-20681: --- Thanks for creating this issue [~jiang7ch

[jira] [Updated] (FLINK-20683) TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotTimeout test failed with "The slot timeout should have been deactivated."

[ https://issues.apache.org/jira/browse/FLINK-20683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20683: -- Priority: Critical (was: Major) > TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotT

[jira] [Updated] (FLINK-20683) TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotTimeout test failed with "The slot timeout should have been deactivated."

[ https://issues.apache.org/jira/browse/FLINK-20683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20683: -- Fix Version/s: 1.12.1 1.13.0 > TaskSlotTableImplTest.testTryMarkSlotActiveD

[jira] [Commented] (FLINK-18828) Terminate jobmanager process with zero exit code to avoid unexpected restarting by K8s

[ https://issues.apache.org/jira/browse/FLINK-18828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252724#comment-17252724 ] Till Rohrmann commented on FLINK-18828: --- This could be a solution. However, I woul

[GitHub] [flink] godfreyhe commented on a change in pull request #14402: [FLINK-20622][table-planner-blink] Introduce StreamPhysicalChangelogNormalize, and make StreamExecChangelogNormalize only exten

godfreyhe commented on a change in pull request #14402: URL: https://github.com/apache/flink/pull/14402#discussion_r546601105 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecChangelogNormalize.java #

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14443: [FLINK-20690][table-planner-blink] Separate the implementation of BatchExecCorrelate and StreamExecCorrelate

flinkbot edited a comment on pull request #14443: URL: https://github.com/apache/flink/pull/14443#issuecomment-748866082 ## CI report: * 42b36c4ab4cce97accc793cd93f147a372f5741e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] godfreyhe commented on a change in pull request #14427: [FLINK-20608][table-planner-blink] Separate the implementation of BatchExecLegacyTableSourceScan and StreamExecLegacyTableSourc

godfreyhe commented on a change in pull request #14427: URL: https://github.com/apache/flink/pull/14427#discussion_r546602345 ## File path: flink-table/flink-table-planner-blink/src/test/resources/explain/testStreamTableEnvironmentExecutionExplain.out ## @@ -32,9 +32,9 @@ Leg

[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 ] Till Rohrmann updated FLINK-20654: -- Priority: Critical (was: Major) > Unaligned checkpoint recovery may lead to corrupted data st

[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&focusedCommentId=17252738#comment-17252738 ] Till Rohrmann commented on FLINK-20654: --- Another instance: https://dev.azure.com/

[GitHub] [flink] tillrohrmann commented on pull request #14424: [FLINK-19369][tests] Disable BlobClientSslTest.testGetFailsDuringStreaming*

tillrohrmann commented on pull request #14424: URL: https://github.com/apache/flink/pull/14424#issuecomment-748883634 Thanks for the review @NicoK. The failing test case is unrelated. Merging this PR now. This is an automate

[GitHub] [flink] tillrohrmann closed pull request #14424: [FLINK-19369][tests] Disable BlobClientSslTest.testGetFailsDuringStreaming*

tillrohrmann closed pull request #14424: URL: https://github.com/apache/flink/pull/14424 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 g

[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&focusedCommentId=17252736#comment-17252736 ] Till Rohrmann commented on FLINK-20648: --- As a quick update, I don't intend to fix

[GitHub] [flink] fsk119 opened a new pull request #14444: [Flink-20091][avro] add ignore-parse-error for

fsk119 opened a new pull request #1: URL: https://github.com/apache/flink/pull/1 ## What is the purpose of the change *Add ignore-parse-error for avro format, avro-confluent.* ## Brief change log - *move the option IGNORE_PARSE_ERROR to FactoryUtil*

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

zentol commented on a change in pull request #14431: URL: https://github.com/apache/flink/pull/14431#discussion_r546605468 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@ -797,52 +796,75 @@ private void startJobExecution() thro

[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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #14444: [Flink-20091][avro] add ignore-parse-error for

flinkbot commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-748886111 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 pro

[jira] [Updated] (FLINK-20619) Remove InputDependencyConstraint and InputDependencyConstraintChecker

[ https://issues.apache.org/jira/browse/FLINK-20619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-20619: Description: InputDependencyConstraint was used by legacy scheduler and lazy-from-sources scheduling strat

[jira] [Closed] (FLINK-20683) TaskSlotTableImplTest.testTryMarkSlotActiveDeactivatesSlotTimeout test failed with "The slot timeout should have been deactivated."

[ https://issues.apache.org/jira/browse/FLINK-20683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-20683. Fix Version/s: (was: 1.12.1) (was: 1.13.0) Resolution: Wo

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

[ https://issues.apache.org/jira/browse/FLINK-19369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-19369. - Fix Version/s: 1.12.1 1.11.4 1.13.0 Resolution: Fixe

[jira] [Commented] (FLINK-20657) Migrate jdbc connection code of JdbcInputFormat, JdbcLookupFunction, JdbcRowDataLookupFunction to SimpleJdbcConnectionProvider

[ https://issues.apache.org/jira/browse/FLINK-20657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252746#comment-17252746 ] Roman Khachatryan commented on FLINK-20657: --- I think synchronized isn't strict

[jira] [Updated] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20309: -- Affects Version/s: 1.13.0 > UnalignedCheckpointTestBase.execute is failed > --

[jira] [Updated] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-20309: -- Fix Version/s: 1.13.0 > UnalignedCheckpointTestBase.execute is failed > --

[jira] [Reopened] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reopened FLINK-20309: --- I've seen another instance of this failure even though the branch contained the fix for it: ht

[GitHub] [flink] flinkbot edited a comment on pull request #14410: [FLINK-20616][python] Support row-based operation to accept user-defined function directly

flinkbot edited a comment on pull request #14410: URL: https://github.com/apache/flink/pull/14410#issuecomment-747440691 ## CI report: * c40710b468a239841a062702183352fbace8907a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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&focusedCommentId=17252749#comment-17252749 ] Yang Wang commented on FLINK-20648: --- Thanks for your information. But it seems that we

[GitHub] [flink] flinkbot commented on pull request #14444: [FLINK-20091][avro] add ignore-parse-error for

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

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20091: --- Labels: pull-request-available (was: ) > Introduce avro.ignore-parse-errors for AvroRowDat

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

tillrohrmann commented on pull request #14430: URL: https://github.com/apache/flink/pull/14430#issuecomment-748897162 Thanks for the review @zentol. Merging this PR now. This is an automated message from the Apache Git Servic

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

tillrohrmann closed pull request #14430: URL: https://github.com/apache/flink/pull/14430 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 g

[jira] [Closed] (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 ] Till Rohrmann closed FLINK-20677. - Resolution: Fixed Fixed via c5596859317316dc800ccc7198cae934428d3415 > Let JobManagerRunner ret

[GitHub] [flink] flinkbot edited a comment on pull request #8952: [FLINK-10868][flink-runtime] Add failure rater for resource manager

flinkbot edited a comment on pull request #8952: URL: https://github.com/apache/flink/pull/8952#issuecomment-513724324 ## CI report: * f5c053117296cab1417bfbf98a0a8e63f48def5b Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[jira] [Assigned] (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 ] Roman Khachatryan reassigned FLINK-20654: - Assignee: Roman Khachatryan > Unaligned checkpoint recovery may lead to corrupt

[jira] [Commented] (FLINK-20686) CLI help message should include 'run-application' action

[ https://issues.apache.org/jira/browse/FLINK-20686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252758#comment-17252758 ] Kostas Kloudas commented on FLINK-20686: Yes, I think so too [~fly_in_gis] > CL

[GitHub] [flink] flinkbot edited a comment on pull request #14410: [FLINK-20616][python] Support row-based operation to accept user-defined function directly

flinkbot edited a comment on pull request #14410: URL: https://github.com/apache/flink/pull/14410#issuecomment-747440691 ## CI report: * c40710b468a239841a062702183352fbace8907a Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #14444: [FLINK-20091][avro] add ignore-parse-error for

flinkbot edited a comment on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-748895134 ## CI report: * e2e10a062a779aabc7717c643623c74ff4cbd5cb Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] vishalovercome commented on pull request #11338: [FLINK-10052][ha] Tolerate temporarily suspended ZooKeeper connections

vishalovercome commented on pull request #11338: URL: https://github.com/apache/flink/pull/11338#issuecomment-748905190 We're seeing lots of job terminations due to this as well as job not being to able to recover from checkpoint and starting out afresh. Can we expect this fix to be ready

[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 ] Piotr Nowojski updated FLINK-20654: --- Priority: Blocker (was: Critical) > Unaligned checkpoint recovery may lead to corrupted dat

[jira] [Commented] (FLINK-20682) Add configuration options related to hadoop

[ https://issues.apache.org/jira/browse/FLINK-20682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252762#comment-17252762 ] Ruguo Yu commented on FLINK-20682: -- OK [~trohrmann], please assign this task to me and

[jira] [Assigned] (FLINK-20519) Extend HBase notice with transitively bundled dependencies

[ https://issues.apache.org/jira/browse/FLINK-20519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-20519: Assignee: Xintong Song > Extend HBase notice with transitively bundled dependencies > ---

[GitHub] [flink] rkhachatryan opened a new pull request #14445: [FLINK-20654][tests] Temporarily ignore UnalignedCheckpointITCase

rkhachatryan opened a new pull request #14445: URL: https://github.com/apache/flink/pull/14445 Temporarily ignore `UnalignedCheckpointITCase` until fixed (to prevent failing builds of un-related changes). This is an auto

[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 ] ASF GitHub Bot updated FLINK-20654: --- Labels: pull-request-available (was: ) > Unaligned checkpoint recovery may lead to corrupte

[jira] [Commented] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252769#comment-17252769 ] Chesnay Schepler commented on FLINK-20695: -- Did the jobs finish successfully, o

[jira] [Commented] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17252763#comment-17252763 ] Chesnay Schepler commented on FLINK-20695: -- Could you clarify which 1.11 versio

[GitHub] [flink-statefun] igalshilman commented on pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes

igalshilman commented on pull request #186: URL: https://github.com/apache/flink-statefun/pull/186#issuecomment-748908086 How about we'll close this PR for now? This is an automated message from the Apache Git Service. To res

[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&focusedCommentId=17252771#comment-17252771 ] Piotr Nowojski commented on FLINK-20654: Test was temporarily disabled as d42c33

[jira] [Updated] (FLINK-20695) Zookeeper node under leader and leaderlatch is not deleted after job finished

[ https://issues.apache.org/jira/browse/FLINK-20695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-20695: - Description: I used flink 1.11 in standalone cluster mode for batch job. The enviornment

[GitHub] [flink] pnowojski merged pull request #14445: [FLINK-20654][tests] Temporarily ignore UnalignedCheckpointITCase

pnowojski merged pull request #14445: URL: https://github.com/apache/flink/pull/14445 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 t

  1   2   3   4   5   >