[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 150a5be15d8605d4fe2214e2e02a97d9bd73bdf7 Azure:

[GitHub] [flink] PChou commented on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

PChou commented on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-952562549 `ClassPathPackagedProgramRetriever` is replaced by `DefaultPackagedProgramRetriever` on master branch, and `DefaultPackagedProgramRetriever` has been support `Configuration` as

[GitHub] [flink] flinkbot edited a comment on pull request #14891: [FLINK-21289][deployment] FIX missing load pipeline.classpaths in app…

flinkbot edited a comment on pull request #14891: URL: https://github.com/apache/flink/pull/14891#issuecomment-774628149 ## CI report: * 150a5be15d8605d4fe2214e2e02a97d9bd73bdf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

flinkbot edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 ## CI report: * 3dd575059ec3e136b282f1bfb5c7fd538fe40b87 Azure:

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737116940 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #17555: [FLINK-24381][table] Add support for setting Options sensitive

flinkbot edited a comment on pull request #17555: URL: https://github.com/apache/flink/pull/17555#issuecomment-950569581 ## CI report: * 907d080f302fcd5851afb178e981a122de09bbb5 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737114021 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737111607 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737105753 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] xuyangzhong commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

xuyangzhong commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737105590 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737100142 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java ## @@ -455,9

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737099501 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java ## @@ -455,9

[GitHub] [flink-ml] guoweiM commented on a change in pull request #16: [FLINK-9][iteration] Support per-round iteration

guoweiM commented on a change in pull request #16: URL: https://github.com/apache/flink-ml/pull/16#discussion_r736240831 ## File path: flink-ml-iteration/src/main/java/org/apache/flink/iteration/PerRoundSubGraphBuilder.java ## @@ -0,0 +1,67 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737083797 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] JingsongLi commented on a change in pull request #17537: [FLINK-19722][table-planner]Pushdown Watermark to SourceProvider (new Source)

JingsongLi commented on a change in pull request #17537: URL: https://github.com/apache/flink/pull/17537#discussion_r737082587 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecTableSourceScan.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] PatrickRen commented on pull request #16940: [FLINK-23914][connector/testing-framework] Improve logging and error message in testing framework

PatrickRen commented on pull request #16940: URL: https://github.com/apache/flink/pull/16940#issuecomment-952509350 Thanks @AHeise ! AZP run has passed. Could you help to merge the PR when you are available? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] tsreaper commented on a change in pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

tsreaper commented on a change in pull request #17570: URL: https://github.com/apache/flink/pull/17570#discussion_r737077180 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java ## @@ -455,9

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[GitHub] [flink] PatrickRen commented on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

PatrickRen commented on pull request #17516: URL: https://github.com/apache/flink/pull/17516#issuecomment-952504483 Sorry for my late response @AHeise . I updated the commit message and rebased the latest master -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #17516: [FLINK-23391][connector/kafka] Fix flaky Kafka source metric test by retrying notifyCheckpointComplete until success or timeout

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

[jira] [Closed] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

[ https://issues.apache.org/jira/browse/FLINK-24662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-24662. --- Fix Version/s: 1.13.4 1.14.1 1.15.0 1.12.6

[jira] [Commented] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

[ https://issues.apache.org/jira/browse/FLINK-24662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434649#comment-17434649 ] Dian Fu commented on FLINK-24662: - It should be caused by the latest release docutils

[jira] [Commented] (FLINK-21289) Application mode ignores the pipeline.classpaths configuration

[ https://issues.apache.org/jira/browse/FLINK-21289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434648#comment-17434648 ] Zhou Parker commented on FLINK-21289: - [~wangyang0918] Since it’s been a long time in the past, I am

[jira] [Closed] (FLINK-24541) ConfigurationUtils#assembleDynamicConfigsStr should consider special characters

[ https://issues.apache.org/jira/browse/FLINK-24541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-24541. Fix Version/s: (was: 1.14.1) Resolution: Fixed Fixed via: - master (1.15):

[GitHub] [flink] xintongsong closed pull request #17533: [FLINK-24541][runtime] Quoting the external resource list in generati…

xintongsong closed pull request #17533: URL: https://github.com/apache/flink/pull/17533 -- 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 the specific comment. To unsubscribe, e-mail:

[jira] [Created] (FLINK-24662) PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden"

Dian Fu created FLINK-24662: --- Summary: PyFlink sphinx check failed with "node class 'meta' is already registered, its visitors will be overridden" Key: FLINK-24662 URL: https://issues.apache.org/jira/browse/FLINK-24662

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * de579d6e83aa94b92dc583c79c34ac085fb4b912 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 756027340bfe8a48fd5947c6eddd8db22beca44a Azure:

[jira] [Created] (FLINK-24661) ConfigOption add isSecret method to judge sensitive options

Ada Wong created FLINK-24661: Summary: ConfigOption add isSecret method to judge sensitive options Key: FLINK-24661 URL: https://issues.apache.org/jira/browse/FLINK-24661 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

flinkbot edited a comment on pull request #17556: URL: https://github.com/apache/flink/pull/17556#issuecomment-950605426 ## CI report: * 756027340bfe8a48fd5947c6eddd8db22beca44a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * 368a7c41cde52ad3c0fde6c30e95ddf5308f8c16 Azure:

[jira] [Comment Edited] (FLINK-24610) Flink projection common expression elimination

[ https://issues.apache.org/jira/browse/FLINK-24610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434275#comment-17434275 ] Lyn Zhang edited comment on FLINK-24610 at 10/27/21, 2:33 AM: -- [~jark] 

[GitHub] [flink] flinkbot edited a comment on pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

flinkbot edited a comment on pull request #17520: URL: https://github.com/apache/flink/pull/17520#issuecomment-946592172 ## CI report: * 368a7c41cde52ad3c0fde6c30e95ddf5308f8c16 Azure:

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r737055199 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/AllCallbackWrapper.java ## @@ -0,0 +1,25

[GitHub] [flink] tsreaper commented on a change in pull request #17520: [FLINK-24565][avro] Port avro file format factory to BulkReaderFormatFactory

tsreaper commented on a change in pull request #17520: URL: https://github.com/apache/flink/pull/17520#discussion_r737052999 ## File path: flink-formats/flink-avro/pom.xml ## @@ -47,13 +47,11 @@ under the License. -

[GitHub] [flink] ruanhang1993 commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

ruanhang1993 commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r737048082 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperExtension.java ## @@ -0,0 +1,64 @@ +package

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

flinkbot edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 ## CI report: * 8e67703b26eb31fc91419ba343e9ee30b46bdb53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

flinkbot edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 ## CI report: * 8e67703b26eb31fc91419ba343e9ee30b46bdb53 Azure:

[GitHub] [flink] meetjunsu commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

meetjunsu commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-952456458 @snuyanzin updated in latest commit -- 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

[jira] [Commented] (FLINK-20286) Support streaming source for filesystem SQL connector

[ https://issues.apache.org/jira/browse/FLINK-20286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434628#comment-17434628 ] Hadi commented on FLINK-20286: -- [~slinkydeveloper] can this support in Flink SQL ? I found

[jira] [Closed] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

[ https://issues.apache.org/jira/browse/FLINK-24641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hadi closed FLINK-24641. Resolution: Duplicate > Flink SQL FileSystem read hdfs Path, when Path's file name change, the

[jira] [Commented] (FLINK-24641) Flink SQL FileSystem read hdfs Path, when Path's file name change, the sql will not find the file.

[ https://issues.apache.org/jira/browse/FLINK-24641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434625#comment-17434625 ] Hadi commented on FLINK-24641: -- [~MartijnVisser] thank u for ur replay. a duplicate issues

[jira] [Created] (FLINK-24660) Allow setting KafkaSubscriber in KafkaSourceBuilder

Mason Chen created FLINK-24660: -- Summary: Allow setting KafkaSubscriber in KafkaSourceBuilder Key: FLINK-24660 URL: https://issues.apache.org/jira/browse/FLINK-24660 Project: Flink Issue Type:

[jira] [Updated] (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:all-tabpanel ] Flink Jira Bot updated FLINK-18983: --- Labels: stale-major stale-minor (was: stale-major) I am the [Flink Jira

[jira] [Updated] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23525: --- Labels: auto-deprioritized-blocker stale-critical test-stability (was:

[jira] [Updated] (FLINK-18574) DownloadPipelineArtifact failes occasionally

[ https://issues.apache.org/jira/browse/FLINK-18574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18574: --- Labels: auto-deprioritized-critical stale-major test-stability (was:

[jira] [Updated] (FLINK-12912) Incorrect handling of task.checkpoint.alignment.max-size when one checkpoint subsumes another one

[ https://issues.apache.org/jira/browse/FLINK-12912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12912: --- Labels: stale-major stale-minor (was: stale-major) I am the [Flink Jira

[jira] [Commented] (FLINK-24580) Kinesis connect time out error is not handled as recoverable

[ https://issues.apache.org/jira/browse/FLINK-24580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434604#comment-17434604 ] John Karp commented on FLINK-24580: --- I've tested out this patch, it seems to work in my manual

[GitHub] [flink] rkhachatryan commented on a change in pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

rkhachatryan commented on a change in pull request #15204: URL: https://github.com/apache/flink/pull/15204#discussion_r736856052 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointableKeyedStateBackend.java ## @@ -45,5 +46,6 @@ * write

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 2e33c87239fdd6a082ed3ae41a4e2c49c5e92031 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

flinkbot edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 ## CI report: * 8e67703b26eb31fc91419ba343e9ee30b46bdb53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17573: [FLINK-24190][runtime] Forbid to split the first record in the buffer if it physically fit it.

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

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * d1470a5514b0990a18976d1dbb7ab5767dd00e69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * d1470a5514b0990a18976d1dbb7ab5767dd00e69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * d1470a5514b0990a18976d1dbb7ab5767dd00e69 Azure:

[GitHub] [flink] zentol commented on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

zentol commented on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-952185469 @flinkbot run azure -- 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 the specific

[GitHub] [flink] zentol commented on a change in pull request #17556: [FLINK-24627][tests] add some Junit5 extensions to replace the existed Junit4 rules

zentol commented on a change in pull request #17556: URL: https://github.com/apache/flink/pull/17556#discussion_r735366139 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/zookeeper/ZooKeeperExtension.java ## @@ -0,0 +1,64 @@ +package

[GitHub] [flink] flinkbot edited a comment on pull request #17535: [FLINK-24609][akka][build] Use same Scala properties as root pom

flinkbot edited a comment on pull request #17535: URL: https://github.com/apache/flink/pull/17535#issuecomment-948487840 ## CI report: * 906e27be8cc278d75fd10d5216ca34275168df96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17571: [FLINK-23015][table-runtime-blink] Implement streaming window Deduplicate operator

flinkbot edited a comment on pull request #17571: URL: https://github.com/apache/flink/pull/17571#issuecomment-951900326 ## CI report: * 62c680fc5948737a1cfce1730886f54501deff84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[jira] [Comment Edited] (FLINK-21068) Add new timeout options for Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434433#comment-17434433 ] Henrique Mota edited comment on FLINK-21068 at 10/26/21, 3:52 PM: -- My

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * d1470a5514b0990a18976d1dbb7ab5767dd00e69 Azure:

[jira] [Commented] (FLINK-21068) Add new timeout options for Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434433#comment-17434433 ] Henrique Mota commented on FLINK-21068: --- My flink cluster is located in Europe and my

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[jira] [Commented] (FLINK-21068) Add new timeout options for Elasticsearch connector

[ https://issues.apache.org/jira/browse/FLINK-21068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17434429#comment-17434429 ] Henrique Mota commented on FLINK-21068: --- Is there any release prevision? > Add new timeout

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix] Fix typos.

flinkbot edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 ## CI report: * 7f141027c52de01193332217049392ad4ff6fe88 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17463: [Hotfix][docs-zh] Fix typo in the 'SHOW COLUMNS' section.

flinkbot edited a comment on pull request #17463: URL: https://github.com/apache/flink/pull/17463#issuecomment-942081615 ## CI report: * 7f141027c52de01193332217049392ad4ff6fe88 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * d1470a5514b0990a18976d1dbb7ab5767dd00e69 Azure:

[jira] [Created] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase

Anton Kalashnikov created FLINK-24659: - Summary: Two active miniCluster in RemoteBenchmarkBase Key: FLINK-24659 URL: https://issues.apache.org/jira/browse/FLINK-24659 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17570: [FLINK-24654][table] Fix NPE on RetractableTopNFunction when some records were cleared by state ttl

flinkbot edited a comment on pull request #17570: URL: https://github.com/apache/flink/pull/17570#issuecomment-951871383 ## CI report: * e820ed21c45e611a1a8c718e4f9b51bedeb92141 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

flinkbot edited a comment on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-943076656 ## CI report: * d1470a5514b0990a18976d1dbb7ab5767dd00e69 Azure:

[GitHub] [flink] zentol commented on pull request #17472: [FLINK-24486][rest] Make async result store duration configurable

zentol commented on pull request #17472: URL: https://github.com/apache/flink/pull/17472#issuecomment-952057861 @flinkbot run azure -- 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 the specific

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17569: [FLINK-24648] CEIL and FLOOR should support DECADE, CENTURY, MILLENNIUM

flinkbot edited a comment on pull request #17569: URL: https://github.com/apache/flink/pull/17569#issuecomment-951868685 ## CI report: * 2730f733c2cd70dea5c1c9862e1a016ecd9705e2 Azure:

[jira] [Updated] (FLINK-24657) Add metric of the total real size of input/output buffers queue

[ https://issues.apache.org/jira/browse/FLINK-24657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24657: -- Component/s: (was: Runtime / Network) Runtime / Metrics > Add

[jira] [Created] (FLINK-24658) Debug logs for buffer size calculation

Anton Kalashnikov created FLINK-24658: - Summary: Debug logs for buffer size calculation Key: FLINK-24658 URL: https://issues.apache.org/jira/browse/FLINK-24658 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #17572: [FLINK-23647][checkpointing] Wait for CheckpointsCleaner to complete before closing cluster

flinkbot edited a comment on pull request #17572: URL: https://github.com/apache/flink/pull/17572#issuecomment-952040222 ## CI report: * 5c20827f354a6f033d0ccfd71d353f9e5f6669c7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17539: [FLINK-24612][connectors/kafka] Configure Kafka test container log le…

flinkbot edited a comment on pull request #17539: URL: https://github.com/apache/flink/pull/17539#issuecomment-948660144 ## CI report: * 5d39e589b9ce9157a2680a2008fa96f516b3c267 Azure:

  1   2   3   4   >