[GitHub] [flink] flinkbot edited a comment on pull request #18354: [FLINK-25650][docs] Added "Interplay with long-running record process…

flinkbot edited a comment on pull request #18354: URL: https://github.com/apache/flink/pull/18354#issuecomment-1014449494 ## CI report: * 80cc40f2dc4121c04d58da7f8c91202094625869 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18354: [FLINK-25650][docs] Added "Interplay with long-running record process…

flinkbot edited a comment on pull request #18354: URL: https://github.com/apache/flink/pull/18354#issuecomment-1014449494 ## CI report: * 80cc40f2dc4121c04d58da7f8c91202094625869 Azure:

[jira] [Assigned] (FLINK-25246) Make benchmarks runnable on Java 11

[ https://issues.apache.org/jira/browse/FLINK-25246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov reassigned FLINK-25246: - Assignee: Anton Kalashnikov > Make benchmarks runnable on Java 11 >

[GitHub] [flink] JingGe commented on a change in pull request #18290: [FLINK-25391][connectors][formats] Update existing table factories/format factories for catalog table options forwarding

JingGe commented on a change in pull request #18290: URL: https://github.com/apache/flink/pull/18290#discussion_r786978426 ## File path: flink-connectors/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/HBase2DynamicTableFactory.java ## @@ -136,4

[jira] [Comment Edited] (FLINK-25690) RetryRule should allow a callback to be called on exception and failure cases

[ https://issues.apache.org/jira/browse/FLINK-25690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478050#comment-17478050 ] Etienne Chauchot edited comment on FLINK-25690 at 1/18/22, 5:09 PM:

[jira] [Commented] (FLINK-25690) RetryRule should allow a callback to be called on exception and failure cases

[ https://issues.apache.org/jira/browse/FLINK-25690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478050#comment-17478050 ] Etienne Chauchot commented on FLINK-25690: -- Thanks [~chesnay] for your answer. ?? We decided

[GitHub] [flink] flinkbot edited a comment on pull request #18393: Revert "[FLINK-25399][tests] Disable changelog backend in tests"

flinkbot edited a comment on pull request #18393: URL: https://github.com/apache/flink/pull/18393#issuecomment-1015295454 ## CI report: * f59bf1fb5b1a882245df7af3fc4e7a58d448b577 Azure:

[GitHub] [flink] JingGe commented on a change in pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

JingGe commented on a change in pull request #18246: URL: https://github.com/apache/flink/pull/18246#discussion_r786968438 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/extension/KafkaContext.java ## @@ -0,0

[GitHub] [flink] JingGe commented on a change in pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

JingGe commented on a change in pull request #18246: URL: https://github.com/apache/flink/pull/18246#discussion_r786968438 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/testutils/extension/KafkaContext.java ## @@ -0,0

[GitHub] [flink] JingGe commented on a change in pull request #18246: [FLINK-25249][connector/kafka] Introduce KafkaExtension for all Kafka connector tests

JingGe commented on a change in pull request #18246: URL: https://github.com/apache/flink/pull/18246#discussion_r786885133 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/testutils/KafkaSourceTestRecordGenerator.java

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

flinkbot edited a comment on pull request #18349: URL: https://github.com/apache/flink/pull/18349#issuecomment-1011991081 ## CI report: * e4399cdc5964a3f49354cb114f5c043f5b2702dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18395: [FLINK-25685] RestClusterClient gets stuck on submitting job with local user artifact

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * ddf9f86dc3700881f03368cf494180651c0358f8 Azure:

[GitHub] [flink] rkhachatryan commented on a change in pull request #18387: [FLINK-25494][state] Duplicate element serializer during operator state sync snapshot phase

rkhachatryan commented on a change in pull request #18387: URL: https://github.com/apache/flink/pull/18387#discussion_r786945819 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/PartitionableListState.java ## @@ -45,23 +47,25 @@ private final

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[jira] [Commented] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact

[ https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478023#comment-17478023 ] Xuannan Su commented on FLINK-25685: I create a pr that adds the unit tests with and without

[GitHub] [flink] rkhachatryan commented on a change in pull request #18387: [FLINK-25494][state] Duplicate element serializer during operator state sync snapshot phase

rkhachatryan commented on a change in pull request #18387: URL: https://github.com/apache/flink/pull/18387#discussion_r786945819 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/PartitionableListState.java ## @@ -45,23 +47,25 @@ private final

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * fe55cde42b286cd76dc9f42ec32e633e67d3c900 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 89dbac69bd4891b3e564de634b3d942391d1840c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[jira] [Commented] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478006#comment-17478006 ] Martijn Visser commented on FLINK-25661: Correct me if I'm wrong [~fpaul] but if this needs to

[GitHub] [flink] flinkbot edited a comment on pull request #18396: [hotfix][connectors] Fix: Infinite loop can arise when prepareCommit(…

flinkbot edited a comment on pull request #18396: URL: https://github.com/apache/flink/pull/18396#issuecomment-1015554715 ## CI report: * 558b1a4d2c4fb4e5a6d443b753da98603c039443 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[jira] [Comment Edited] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478003#comment-17478003 ] Danny Cranmer edited comment on FLINK-25661 at 1/18/22, 4:00 PM: - I like

[jira] [Commented] (FLINK-25661) Add Custom Fatal Exception handler in AsyncSinkWriter

[ https://issues.apache.org/jira/browse/FLINK-25661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17478003#comment-17478003 ] Danny Cranmer commented on FLINK-25661: --- I like this idea. With the current Kinesis connector,

[GitHub] [flink] flinkbot commented on pull request #18396: [hotfix][connectors] Fix: Infinite loop can arise when prepareCommit(…

flinkbot commented on pull request #18396: URL: https://github.com/apache/flink/pull/18396#issuecomment-101336 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] flinkbot commented on pull request #18396: [hotfix][connectors] Fix: Infinite loop can arise when prepareCommit(…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] CrynetLogistics opened a new pull request #18396: [hotfix][connectors] Fix: Infinite loop can arise when prepareCommit(…

CrynetLogistics opened a new pull request #18396: URL: https://github.com/apache/flink/pull/18396 …flush=false) is called in AsyncSinkWriter with buffered elements ## What is the purpose of the change To fix a possible infinite loop when prepareCommit is called with

[GitHub] [flink] rkhachatryan commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r786880573 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/SharedStateRegistryTest.java ## @@ -98,6 +106,77 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r786875320 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -130,14 +155,51 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

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

[jira] [Commented] (FLINK-25679) Build arm64 Linux images for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-25679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477978#comment-17477978 ] Chesnay Schepler commented on FLINK-25679: -- Let's first publish the 1.14.3 images as usual to

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6362ee74a8f3ec811d54da0147c7afef77ef2422 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18368: [FLINK-18356][Azure] Enforce memory limits for docker containers

flinkbot edited a comment on pull request #18368: URL: https://github.com/apache/flink/pull/18368#issuecomment-1013194055 ## CI report: * 13a059ef4d8b011d5cc1cac10861e0bafa98c6d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6362ee74a8f3ec811d54da0147c7afef77ef2422 Azure:

[jira] [Closed] (FLINK-25693) User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets

[ https://issues.apache.org/jira/browse/FLINK-25693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25693. -- Resolution: Duplicate I'm suspecting that this is a duplicate of the linked issue > User

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6362ee74a8f3ec811d54da0147c7afef77ef2422 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 0645606963f50cd5924912472afa035701342ffe Azure:

[jira] [Commented] (FLINK-25693) User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets

[ https://issues.apache.org/jira/browse/FLINK-25693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477968#comment-17477968 ] Fabian Paul commented on FLINK-25693: - [~ruanhang1993] [~renqs]  can you take a look at this? >

[jira] [Commented] (FLINK-25679) Build arm64 Linux images for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-25679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477967#comment-17477967 ] Robert Metzger commented on FLINK-25679: Yes, this sounds good. Shall we add arm64 for the

[jira] [Created] (FLINK-25693) User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets

Gaurav Miglani created FLINK-25693: -- Summary: User property 'auto.offset.reset' doesn't take precedence in case of scan.startup.mode= group-offsets Key: FLINK-25693 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * 6024e28f7d315a7d1157f9af33da9b815f81a27a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18393: Revert "[FLINK-25399][tests] Disable changelog backend in tests"

flinkbot edited a comment on pull request #18393: URL: https://github.com/apache/flink/pull/18393#issuecomment-1015295454 ## CI report: * ea63cfe30faf69a789a85c2d4fda9f7522f4455e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18392: [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log warnings if usage exceeds 100%

flinkbot edited a comment on pull request #18392: URL: https://github.com/apache/flink/pull/18392#issuecomment-1015285195 ## CI report: * 7896e67a40af2b4522c6e304febfebe60f635e85 Azure:

[GitHub] [flink] matriv commented on a change in pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

matriv commented on a change in pull request #18381: URL: https://github.com/apache/flink/pull/18381#discussion_r786840392 ## File path: flink-annotations/src/main/java/org/apache/flink/FlinkVersion.java ## @@ -69,9 +71,14 @@ public boolean isNewerVersionThan(FlinkVersion

[GitHub] [flink] flinkbot edited a comment on pull request #18393: Revert "[FLINK-25399][tests] Disable changelog backend in tests"

flinkbot edited a comment on pull request #18393: URL: https://github.com/apache/flink/pull/18393#issuecomment-1015295454 ## CI report: * ea63cfe30faf69a789a85c2d4fda9f7522f4455e Azure:

[jira] [Commented] (FLINK-25679) Build arm64 Linux images for Apache Flink

[ https://issues.apache.org/jira/browse/FLINK-25679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477934#comment-17477934 ] Chesnay Schepler commented on FLINK-25679: -- Shouldn't we just let the official-images guys

[GitHub] [flink] fapaul commented on a change in pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

fapaul commented on a change in pull request #17601: URL: https://github.com/apache/flink/pull/17601#discussion_r786811633 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicTableFactoryTest.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

flinkbot edited a comment on pull request #18349: URL: https://github.com/apache/flink/pull/18349#issuecomment-1011991081 ## CI report: * 04379c97fabc5ee28e30dfcd6485bf8e5c0da69e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 51b23df97a9e47ce6ab8f4ca321cce5c04f729bd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18395: [FLINK-25685] RestClusterClient gets stuck on submitting job with local user artifact

flinkbot edited a comment on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015461969 ## CI report: * ddf9f86dc3700881f03368cf494180651c0358f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18349: [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

flinkbot edited a comment on pull request #18349: URL: https://github.com/apache/flink/pull/18349#issuecomment-1011991081 ## CI report: * 04379c97fabc5ee28e30dfcd6485bf8e5c0da69e Azure:

[GitHub] [flink] flinkbot commented on pull request #18395: [FLINK-25685] RestClusterClient gets stuck on submitting job with local user artifact

flinkbot commented on pull request #18395: URL: https://github.com/apache/flink/pull/18395#issuecomment-1015463315 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] flinkbot commented on pull request #18395: [FLINK-25685] RestClusterClient gets stuck on submitting job with local user artifact

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

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477914#comment-17477914 ] Chesnay Schepler commented on FLINK-25581: -- ??Are there any additional parameters I can set to

[GitHub] [flink] Sxnan opened a new pull request #18395: [FLINK-25685] RestClusterClient gets stuck on submitting job with local user artifact

Sxnan opened a new pull request #18395: URL: https://github.com/apache/flink/pull/18395 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Updated] (FLINK-25685) RestClusterClient gets stuck on submitting job with local user artifact

[ https://issues.apache.org/jira/browse/FLINK-25685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25685: --- Labels: pull-request-available (was: ) > RestClusterClient gets stuck on submitting job

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 6d75de07bd21a84d82600a82b837a0b91037db61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure:

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477903#comment-17477903 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] So maybe the jobs that were not archived

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * c7be04db0b58ad63ecd5d9cc831f9e49814ebabe Azure:

[GitHub] [flink] pnowojski commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

pnowojski commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1015442403 Thanks @1996fanrui , can you squash the commits before merging? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #18392: [FLINK-25590][metrics] Introduce RequestedMemoryUsage and log warnings if usage exceeds 100%

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

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * c7be04db0b58ad63ecd5d9cc831f9e49814ebabe Azure:

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477879#comment-17477879 ] Chesnay Schepler commented on FLINK-25581: -- The FileAlreadyExistsException might be caused by

[GitHub] [flink] flinkbot edited a comment on pull request #18393: Revert "[FLINK-25399][tests] Disable changelog backend in tests"

flinkbot edited a comment on pull request #18393: URL: https://github.com/apache/flink/pull/18393#issuecomment-1015295454 ## CI report: * ea63cfe30faf69a789a85c2d4fda9f7522f4455e Azure:

[jira] [Commented] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477868#comment-17477868 ] Leonid Ilyevsky commented on FLINK-25581: - [~chesnay] Yes, I found something interesting. This

[jira] [Updated] (FLINK-25581) Jobmanager does not archive completed jobs

[ https://issues.apache.org/jira/browse/FLINK-25581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonid Ilyevsky updated FLINK-25581: Attachment: error.log > Jobmanager does not archive completed jobs >

[GitHub] [flink] Airblader commented on a change in pull request #18381: [hotfix][flink-annotations] Add v1.15 as the next Flink version to master

Airblader commented on a change in pull request #18381: URL: https://github.com/apache/flink/pull/18381#discussion_r786763971 ## File path: flink-annotations/src/main/java/org/apache/flink/FlinkVersion.java ## @@ -69,9 +71,14 @@ public boolean isNewerVersionThan(FlinkVersion

[jira] [Closed] (FLINK-17321) Support for casting collection types.

[ https://issues.apache.org/jira/browse/FLINK-17321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-17321. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master:

[GitHub] [flink] twalthr closed pull request #18287: [FLINK-17321][table] Add support casting of map to map and multiset to multiset

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

[GitHub] [flink] flinkbot edited a comment on pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

flinkbot edited a comment on pull request #18391: URL: https://github.com/apache/flink/pull/18391#issuecomment-1015282046 ## CI report: * b47017f954a03267eee26e4b60c200b373a81667 Azure:

[jira] [Closed] (FLINK-25588) Add jdk8 and datetime module to jackson shaded

[ https://issues.apache.org/jira/browse/FLINK-25588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-25588. Resolution: Fixed shaded-master: 553ec5da7706dd1c7ce0d7ee373eacdcbc33595c

[GitHub] [flink-shaded] zentol merged pull request #108: [FLINK-25588] Add Jackson JDK8 types to shaded jackson

zentol merged pull request #108: URL: https://github.com/apache/flink-shaded/pull/108 -- 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] [Commented] (FLINK-24623) Prevent usage of EventTimeWindows when EventTime is disabled

[ https://issues.apache.org/jira/browse/FLINK-24623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477846#comment-17477846 ] Dario Heinisch commented on FLINK-24623: Hey [~trohrmann], Sorry for the ping but do you have a

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 6d75de07bd21a84d82600a82b837a0b91037db61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

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

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 6d75de07bd21a84d82600a82b837a0b91037db61 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18341: [FLINK-25194] Implement an API for duplicating artefacts

flinkbot edited a comment on pull request #18341: URL: https://github.com/apache/flink/pull/18341#issuecomment-1011007519 ## CI report: * 6b5b590785bb896e24fe5f6fa2729fb5ce143f07 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

Myasuka commented on a change in pull request #18083: URL: https://github.com/apache/flink/pull/18083#discussion_r786741848 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointUtils.java ## @@ -128,4 +132,80 @@ public static void

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 400d8323fff61a698e6e6d67c168bc50370a163d Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

tillrohrmann commented on a change in pull request #18083: URL: https://github.com/apache/flink/pull/18083#discussion_r786738133 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypointUtils.java ## @@ -128,4 +132,80 @@ public static

[GitHub] [flink] flinkbot edited a comment on pull request #18083: [FLINK-25402] Introduce working directory for Flink processes

flinkbot edited a comment on pull request #18083: URL: https://github.com/apache/flink/pull/18083#issuecomment-991128050 ## CI report: * 400d8323fff61a698e6e6d67c168bc50370a163d Azure:

<    1   2   3   4   5   6   >