[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] wanglijie95 commented on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

wanglijie95 commented on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1041767728 @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

[GitHub] [flink] rkhachatryan merged pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

rkhachatryan merged pull request #18798: URL: https://github.com/apache/flink/pull/18798 -- 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 #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

flinkbot edited a comment on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147 ## CI report: * 15dc3494e8378bd67fd2ca859eeb317d88d45c95 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

flinkbot edited a comment on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1040524147 ## CI report: * 50789f74f16c2bd3e42a61754f426877a3376056 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[jira] [Comment Edited] (FLINK-26085) Statefun Support PbJson Type

[ https://issues.apache.org/jira/browse/FLINK-26085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493297#comment-17493297 ] Igal Shilman edited comment on FLINK-26085 at 2/16/22, 3:33 PM: Hi

[jira] [Commented] (FLINK-26085) Statefun Support PbJson Type

[ https://issues.apache.org/jira/browse/FLINK-26085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493297#comment-17493297 ] Igal Shilman commented on FLINK-26085: -- Hi [~ychensha] , Can you please elaborate a bit more what

[GitHub] [flink] godfreyhe commented on pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

godfreyhe commented on pull request #18785: URL: https://github.com/apache/flink/pull/18785#issuecomment-1041693363 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * 72851364f75d1b6e40ea1688408c3b85dccd6ec7 Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

godfreyhe commented on a change in pull request #18785: URL: https://github.com/apache/flink/pull/18785#discussion_r808121812 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java ## @@ -136,25

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot commented on pull request #18806: [FLINK-26105][e2e] Fixes log file extension

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

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot commented on pull request #18806: [FLINK-26105][e2e] Fixes log file extension

flinkbot commented on pull request #18806: URL: https://github.com/apache/flink/pull/18806#issuecomment-1041643326 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] zentol commented on pull request #18800: [FLINK-26187][docs] Chinese docs only redirect for chinese urls

zentol commented on pull request #18800: URL: https://github.com/apache/flink/pull/18800#issuecomment-1041634954 I'll amend the PR in a bit. -- 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

[GitHub] [flink] zentol commented on pull request #18800: [FLINK-26187][docs] Chinese docs only redirect for chinese urls

zentol commented on pull request #18800: URL: https://github.com/apache/flink/pull/18800#issuecomment-1041627285 Nah, the regex didn't find them. The number of spaces before the alias isn't standardized  -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26105: --- Labels: pull-request-available test-stability (was: test-stability) > Running HA (hashmap,

[GitHub] [flink] XComp opened a new pull request #18806: [FLINK-26105][e2e] Fixes log file extension

XComp opened a new pull request #18806: URL: https://github.com/apache/flink/pull/18806 Rolling log file naming strategy is enabled by default which might cause test instabilities do to the relevant substring not being present in the *.log file. This change expands the grep and

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

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

[GitHub] [flink] godfreyhe commented on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

godfreyhe commented on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1041607483 waiting azure test result -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * 48412828133309fc4f4cddecfedcdfcbbbee8ebf Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

gaoyunhaii commented on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1041597793 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18406: WIP: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * a08f9136849f34b2a902435c7f3c3b8b2be8b74e Azure:

[jira] [Created] (FLINK-26194) Deprecate nullCheck in TableConfig

Marios Trivyzas created FLINK-26194: --- Summary: Deprecate nullCheck in TableConfig Key: FLINK-26194 URL: https://issues.apache.org/jira/browse/FLINK-26194 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18769: [FLINK-25188][python][build] Support m1 chip.

flinkbot edited a comment on pull request #18769: URL: https://github.com/apache/flink/pull/18769#issuecomment-1039977246 ## CI report: * cf8a3915328570f8497893b3608900e46c85f69d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18406: WIP: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * a08f9136849f34b2a902435c7f3c3b8b2be8b74e Azure:

[jira] [Commented] (FLINK-22665) Add a Flink BigQuery Connector

[ https://issues.apache.org/jira/browse/FLINK-22665?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493274#comment-17493274 ] Sergey Nuyanzin commented on FLINK-22665: - Hi [~joern] we are also willing to have it. Could you

[GitHub] [flink] flinkbot edited a comment on pull request #18796: [FLINK-26166][runtime-web] Add auto newline detection to prettier formatter

flinkbot edited a comment on pull request #18796: URL: https://github.com/apache/flink/pull/18796#issuecomment-1041224101 ## CI report: * 39c86af3f4ab34c03537f845a90a4f3f78e0b835 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18800: [FLINK-26187][docs] Chinese docs only redirect for chinese urls

flinkbot edited a comment on pull request #18800: URL: https://github.com/apache/flink/pull/18800#issuecomment-1041369861 ## CI report: * 48331ca936e4630eb198a3e28f3240888d99e5d8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18406: WIP: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * a08f9136849f34b2a902435c7f3c3b8b2be8b74e Azure:

[jira] [Commented] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large

[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493268#comment-17493268 ] Igal Shilman commented on FLINK-25670: -- Hi [~JSilent], I'm happy that it did worked out.  I

[jira] [Closed] (FLINK-25670) StateFun: Unable to handle oversize HTTP message if state size is large

[ https://issues.apache.org/jira/browse/FLINK-25670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman closed FLINK-25670. Resolution: Not A Problem > StateFun: Unable to handle oversize HTTP message if state size is

[jira] [Commented] (FLINK-24855) Source Coordinator Thread already exists. There should never be more than one thread driving the actions of a Source Coordinator.

[ https://issues.apache.org/jira/browse/FLINK-24855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493265#comment-17493265 ] WangMinChao commented on FLINK-24855: - yeah，i will going  

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[GitHub] [flink] rkhachatryan commented on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

rkhachatryan commented on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041572996 @zentol do you have any further feedback? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #18406: WIP: [FLINK-25686][pulsar]: add schema evolution support for pulsar source connector

flinkbot edited a comment on pull request #18406: URL: https://github.com/apache/flink/pull/18406#issuecomment-1017085273 ## CI report: * 25fb867852a87a19d2c6dec3493f6637c340b954 Azure:

[GitHub] [flink] zentol commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

zentol commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r808067841 ## File path: flink-test-utils-parent/flink-connector-test-utils/pom.xml ## @@ -95,4 +95,30 @@ compile +

[GitHub] [flink] zentol commented on a change in pull request #18544: [FLINK-25851][Connectors][Cassandra][test] support dynamic tables names for POJOs

zentol commented on a change in pull request #18544: URL: https://github.com/apache/flink/pull/18544#discussion_r808066428 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java ##

[GitHub] [flink] zentol commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

zentol commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r808065325 ## File path: flink-test-utils-parent/flink-connector-test-utils/pom.xml ## @@ -95,4 +95,30 @@ compile +

[GitHub] [flink] flinkbot edited a comment on pull request #18786: [hotfix][test] add support for field assignability

flinkbot edited a comment on pull request #18786: URL: https://github.com/apache/flink/pull/18786#issuecomment-1040539589 ## CI report: * 84d45868a291322310ba3d321b580b8513b35031 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18805: Flink 26173

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

[GitHub] [flink] flinkbot edited a comment on pull request #18799: [FLINK-26145][docs] fix a kubernetes image that does not exist in the…

flinkbot edited a comment on pull request #18799: URL: https://github.com/apache/flink/pull/18799#issuecomment-1041334465 ## CI report: * 73640cb14e6a68cacc27b281f8d5508a5ffa21ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[jira] [Comment Edited] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493219#comment-17493219 ] Matthias Pohl edited comment on FLINK-26105 at 2/16/22, 2:38 PM: -

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * f8e6b0336c935a75323efa5b959d2638378a35fa Azure:

[jira] [Comment Edited] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493219#comment-17493219 ] Matthias Pohl edited comment on FLINK-26105 at 2/16/22, 2:37 PM: -

[jira] [Comment Edited] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493260#comment-17493260 ] Matthias Pohl edited comment on FLINK-26105 at 2/16/22, 2:37 PM: - The

[jira] [Comment Edited] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493260#comment-17493260 ] Matthias Pohl edited comment on FLINK-26105 at 2/16/22, 2:37 PM: - The

[jira] [Commented] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493260#comment-17493260 ] Matthias Pohl commented on FLINK-26105: --- The issue is caused by us enabling rolling log file names

[GitHub] [flink] ruanhang1993 commented on a change in pull request #18496: [FLINK-25289][tests] add sink test suite in connector testframe

ruanhang1993 commented on a change in pull request #18496: URL: https://github.com/apache/flink/pull/18496#discussion_r808051755 ## File path: flink-test-utils-parent/flink-connector-test-utils/pom.xml ## @@ -95,4 +95,30 @@ compile

[GitHub] [flink] flinkbot commented on pull request #18805: Flink 26173

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

[GitHub] [flink] flinkbot edited a comment on pull request #18798: [FLINK-26177][tests] Disable PulsarSourceITCase rescaling tests temporarily

flinkbot edited a comment on pull request #18798: URL: https://github.com/apache/flink/pull/18798#issuecomment-1041265347 ## CI report: * d87a36d6c2290af48b79a325beeeb917fe3501ba Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot commented on pull request #18805: Flink 26173

flinkbot commented on pull request #18805: URL: https://github.com/apache/flink/pull/18805#issuecomment-1041552699 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Commented] (FLINK-26105) Running HA (hashmap, async) end-to-end test failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493257#comment-17493257 ] Matthias Pohl commented on FLINK-26105: --- The failing assert checks the log files for the

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * f8e6b0336c935a75323efa5b959d2638378a35fa Azure:

[jira] [Updated] (FLINK-24474) Standalone clusters should bind to localhost by default

[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24474: - Release Note: For security purposes standalone clusters now bind the REST API and RPC

[jira] [Comment Edited] (FLINK-24474) Standalone clusters should bind to localhost by default

[ https://issues.apache.org/jira/browse/FLINK-24474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492726#comment-17492726 ] Chesnay Schepler edited comment on FLINK-24474 at 2/16/22, 2:30 PM:

[GitHub] [flink] fapaul commented on a change in pull request #18345: [FLINK-25440][doc][pulsar] Both stopCursor and startCursor now uses publish time instead of event time

fapaul commented on a change in pull request #18345: URL: https://github.com/apache/flink/pull/18345#discussion_r808044188 ## File path: flink-connectors/flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java ## @@

[GitHub] [flink] zentol merged pull request #18721: [FLINK-24474] Bind Jobmanager and Taskmanager RPC host addresses to localhost by default

zentol merged pull request #18721: URL: https://github.com/apache/flink/pull/18721 -- 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] fapaul opened a new pull request #18805: Flink 26173

fapaul opened a new pull request #18805: URL: https://github.com/apache/flink/pull/18805 ## What is the purpose of the change Sink V1's GlobalCommitter did only call filterRecoveredCommittable during the state initialization. In Sink V2 the GlobalCommitter is treated

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[jira] [Created] (FLINK-26193) Commit generated FlinkDeployment resource into Git repo

Gyula Fora created FLINK-26193: -- Summary: Commit generated FlinkDeployment resource into Git repo Key: FLINK-26193 URL: https://issues.apache.org/jira/browse/FLINK-26193 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * f8e6b0336c935a75323efa5b959d2638378a35fa Azure:

[jira] [Closed] (FLINK-25571) Update Elasticsearch Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25571. --- > Update Elasticsearch Sink to use decomposed interfaces >

[GitHub] [flink] wenlong88 commented on a change in pull request #18785: [FLINK-26167][table-planner] Explicitly set the partitioner for the sql operators whose shuffle and sort are removed

wenlong88 commented on a change in pull request #18785: URL: https://github.com/apache/flink/pull/18785#discussion_r808030853 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecExchange.java ## @@ -136,25

[jira] [Assigned] (FLINK-26183) Support kubernetes-operator metrics using the Flink metric system

[ https://issues.apache.org/jira/browse/FLINK-26183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26183: -- Assignee: Matyas Orhidi (was: Matyas Orhidi) > Support kubernetes-operator metrics using

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * f8e6b0336c935a75323efa5b959d2638378a35fa Azure:

[jira] [Created] (FLINK-26192) PulsarOrderedSourceReaderTest fails with exit code 255

Dawid Wysakowicz created FLINK-26192: Summary: PulsarOrderedSourceReaderTest fails with exit code 255 Key: FLINK-26192 URL: https://issues.apache.org/jira/browse/FLINK-26192 Project: Flink

[jira] [Closed] (FLINK-25573) Update Kafka Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25573. --- > Update Kafka Sink to use decomposed interfaces > -- > >

[jira] [Closed] (FLINK-25574) Update Async Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25574. --- > Update Async Sink to use decomposed interfaces > -- > >

[jira] [Closed] (FLINK-25578) Graduate Sink V1 interfaces to PublicEvolving and deprecate them

[ https://issues.apache.org/jira/browse/FLINK-25578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25578. --- > Graduate Sink V1 interfaces to PublicEvolving and deprecate them >

[jira] [Closed] (FLINK-25726) Implement GlobalCommitter as custom post commit topology

[ https://issues.apache.org/jira/browse/FLINK-25726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25726. --- > Implement GlobalCommitter as custom post commit topology >

[jira] [Closed] (FLINK-25575) Implement StreamGraph translation for Sink V2 interfaces

[ https://issues.apache.org/jira/browse/FLINK-25575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25575. --- > Implement StreamGraph translation for Sink V2 interfaces >

[jira] [Closed] (FLINK-25570) Introduce Sink V2 extension interfaces

[ https://issues.apache.org/jira/browse/FLINK-25570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25570. --- > Introduce Sink V2 extension interfaces > -- > >

[jira] [Closed] (FLINK-25569) Introduce decomposed Sink V2 interfaces

[ https://issues.apache.org/jira/browse/FLINK-25569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul closed FLINK-25569. --- > Introduce decomposed Sink V2 interfaces > --- > >

[GitHub] [flink] flinkbot edited a comment on pull request #18804: [hotfix][docs][table] Document the new `TablePipeline` API object

flinkbot edited a comment on pull request #18804: URL: https://github.com/apache/flink/pull/18804#issuecomment-1041525289 ## CI report: * 46d0dae576615a1335cdf6e76a44d7594576ce34 Azure:

[jira] [Closed] (FLINK-25980) remove unnecessary condition in IntervalJoinOperator

[ https://issues.apache.org/jira/browse/FLINK-25980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] hongshu closed FLINK-25980. --- > remove unnecessary condition in IntervalJoinOperator > >

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * 72851364f75d1b6e40ea1688408c3b85dccd6ec7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 633a085bb84b57c26e160a220dc3f2c5b430bae1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] flinkbot edited a comment on pull request #18363: [FLINK-25600][table-planner] Support new statement set syntax in sql client and update docs

flinkbot edited a comment on pull request #18363: URL: https://github.com/apache/flink/pull/18363#issuecomment-1012985353 ## CI report: * f8e6b0336c935a75323efa5b959d2638378a35fa Azure:

[GitHub] [flink] GOODBOY008 commented on pull request #18778: [FLINK-26150][connector/pulsar] enable requestTimeoutMs configuration.

GOODBOY008 commented on pull request #18778: URL: https://github.com/apache/flink/pull/18778#issuecomment-1041529015 Duplicated!Have fixed in https://issues.apache.org/jira/browse/FLINK-26020. -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] GOODBOY008 closed pull request #18778: [FLINK-26150][connector/pulsar] enable requestTimeoutMs configuration.

GOODBOY008 closed pull request #18778: URL: https://github.com/apache/flink/pull/18778 -- 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-26150) [pulsar] enable requestTimeoutMs configuration

[ https://issues.apache.org/jira/browse/FLINK-26150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493250#comment-17493250 ] Aiden Gong commented on FLINK-26150: Have fixed in

[jira] [Closed] (FLINK-26150) [pulsar] enable requestTimeoutMs configuration

[ https://issues.apache.org/jira/browse/FLINK-26150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aiden Gong closed FLINK-26150. -- Resolution: Duplicate > [pulsar] enable requestTimeoutMs configuration >

[GitHub] [flink] flinkbot commented on pull request #18804: [hotfix][docs][table] Document the new `TablePipeline` API object

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

[GitHub] [flink] flinkbot edited a comment on pull request #18789: [FLINK-26168][runtime] The judgment of chainable ignores StreamExchangeMode when partitioner is ForwardForConsecutiveHashPartitioner

flinkbot edited a comment on pull request #18789: URL: https://github.com/apache/flink/pull/18789#issuecomment-1040944258 ## CI report: * 72851364f75d1b6e40ea1688408c3b85dccd6ec7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18757: [FLINK-25226][doc] Add documentation about the AdaptiveBatchScheduler

flinkbot edited a comment on pull request #18757: URL: https://github.com/apache/flink/pull/18757#issuecomment-1039117115 ## CI report: * 11e85ed08b4d481aa5418c5d61f88a0c38ab49b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18759: [FLINK-25698][connectors/elasticsearch] Enable logging for Elasticsearch containers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

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

[GitHub] [flink] echauchot commented on a change in pull request #18544: [FLINK-25851][Connectors][Cassandra][test] support dynamic tables names for POJOs

echauchot commented on a change in pull request #18544: URL: https://github.com/apache/flink/pull/18544#discussion_r808009701 ## File path: flink-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/CassandraConnectorITCase.java

<    1   2   3   4   5   6   7   8   9   >