[GitHub] [flink] flinkbot edited a comment on pull request #18418: [FLINK-25719][python] Support General Python UDF in Thread Mode

flinkbot edited a comment on pull request #18418: URL: https://github.com/apache/flink/pull/18418#issuecomment-1017307428 ## CI report: * 4e95ae2d0e8a2e2a2e3d85640d5ab125e86ede6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18402: [FLINK-25678][runtime] Make TaskExecutorStateChangelogStoragesManager.shutdown thread-safe

flinkbot edited a comment on pull request #18402: URL: https://github.com/apache/flink/pull/18402#issuecomment-1016522710 ## CI report: * b1c8b62f507402d3e3ea03f3d48100e8c9834c59 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * 82871d3416aefbce86d6e32e3e26a51c12841534 Azure:

[jira] [Updated] (FLINK-25199) StreamEdges are not unique in self-union blocking propagation of watermarks

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25199: --- Fix Version/s: 1.13.6 1.14.4 > StreamEdges are not unique in self-union

[jira] [Updated] (FLINK-25199) StreamEdges are not unique in self-union blocking propagation of watermarks

[ https://issues.apache.org/jira/browse/FLINK-25199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25199: --- Affects Version/s: 1.13.5 1.12.7 > StreamEdges are not unique in

[GitHub] [flink] JingsongLi commented on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

JingsongLi commented on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1018265039 @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 #18435: [BP-1.14][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

flinkbot edited a comment on pull request #18435: URL: https://github.com/apache/flink/pull/18435#issuecomment-1018092237 ## CI report: * d17e0ea06e4050bda831de56c25f8b6adf90c4d8 Azure:

[GitHub] [flink] pnowojski merged pull request #18420: [FLINK-25199][network] Make sure StreamEdges are unique

pnowojski merged pull request #18420: URL: https://github.com/apache/flink/pull/18420 -- 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 #18402: [FLINK-25678][runtime] Make TaskExecutorStateChangelogStoragesManager.shutdown thread-safe

flinkbot edited a comment on pull request #18402: URL: https://github.com/apache/flink/pull/18402#issuecomment-1016522710 ## CI report: * b1c8b62f507402d3e3ea03f3d48100e8c9834c59 Azure:

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r789427624 ## File path: flink-table/flink-table-planner/src/test/resources/META-INF/services/org.apache.flink.table.factories.Factory ## @@ -13,8 +13,8 @@ #

[GitHub] [flink] rkhachatryan commented on pull request #18432: [FLINK-25739][dist] Add Changelog to dist/opt

rkhachatryan commented on pull request #18432: URL: https://github.com/apache/flink/pull/18432#issuecomment-1018262677 CI failure unrelated: https://issues.apache.org/jira/browse/FLINK-25740 -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Commented] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479875#comment-17479875 ] Roman Khachatryan commented on FLINK-25740: ---

[GitHub] [flink] flinkbot edited a comment on pull request #18436: [BP-1.13][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

flinkbot edited a comment on pull request #18436: URL: https://github.com/apache/flink/pull/18436#issuecomment-1018094327 ## CI report: * f87a46d760404ab5d51b2d5ed554459d3b07fde6 Azure:

[GitHub] [flink] LadyForest commented on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

LadyForest commented on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1018261453 > Can you split this to multiple commits? Sure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] rkhachatryan commented on pull request #18402: [FLINK-25678][runtime] Make TaskExecutorStateChangelogStoragesManager.shutdown thread-safe

rkhachatryan commented on pull request #18402: URL: https://github.com/apache/flink/pull/18402#issuecomment-1018260949 Thanks for the reivew! I'll squash the commits and merge the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] wangyang0918 commented on pull request #18436: [BP-1.13][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

wangyang0918 commented on pull request #18436: URL: https://github.com/apache/flink/pull/18436#issuecomment-1018261093 @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] JingsongLi commented on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1018260095 Can you split this to multiple commits? -- 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] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r789416976 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java ## @@ -72,4 +85,8 @@ public

[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=17479869#comment-17479869 ] Xuannan Su commented on FLINK-25685: [~wangyang0918] You are right. (y) The fix is to use

[GitHub] [flink] flinkbot edited a comment on pull request #18423: [hotfix][source][pulsar] Two small hotfix commits from FLIP-182 PoC branch

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] wangyang0918 commented on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

wangyang0918 commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1018258424 > do I understand you correctly that we have to integrate the `KubernetesLabel` at some other places to make the check also work for the standalone k8s cluster with HA

[GitHub] [flink] flinkbot edited a comment on pull request #18423: [hotfix][source][pulsar] Two small hotfix commits from FLIP-182 PoC branch

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] pnowojski commented on pull request #18423: [hotfix][source][pulsar] Two small hotfix commits from FLIP-182 PoC branch

pnowojski commented on pull request #18423: URL: https://github.com/apache/flink/pull/18423#issuecomment-1018253467 @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] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r789416407 ## File path: flink-formats/flink-orc/pom.xml ## @@ -145,6 +145,19 @@ under the License. test test-jar

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

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

[jira] [Commented] (FLINK-25715) Application Mode: Add option to submit a failed job on application error

[ https://issues.apache.org/jira/browse/FLINK-25715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479863#comment-17479863 ] Yang Wang commented on FLINK-25715: --- This is really a useful feature when integrate application mode

[jira] [Updated] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-25470: - Description: FLINK-25557  only resolves part of the problems.  Eventually, we should answer questions:

[GitHub] [flink] Myasuka commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

Myasuka commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r789409368 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[jira] [Reopened] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei reopened FLINK-25470: -- > Add/Expose/Differentiate metrics of checkpoint size between changelog size vs > materialization size >

[GitHub] [flink] curcur commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

curcur commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r789407543 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[GitHub] [flink] curcur commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

curcur commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r789407543 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

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

[GitHub] [flink] XComp commented on pull request #17819: [FLINK-15816][k8s] Prevent labels using kubernetes.cluster-id to exceed the limit of 63 characters

XComp commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-1018242501 Have we come up with a conclusion on this PR? I don't have the overview over what names are actually used as labels which fall under the 63 characters limit? @wangyang0918 do I

[GitHub] [flink] curcur commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

curcur commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r789407543 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[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: * 750404ad179f476f0895f643e63f7af625bb45c7 Azure:

[GitHub] [flink] curcur commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

curcur commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r789407543 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

flinkbot edited a comment on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067 ## CI report: * 3c3aedefda07bea1b5cf7223b4f0305f469d9e15 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: * 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

flinkbot edited a comment on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067 ## CI report: * 3c3aedefda07bea1b5cf7223b4f0305f469d9e15 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: * 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:

[jira] [Commented] (FLINK-25743) Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar

[ https://issues.apache.org/jira/browse/FLINK-25743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479861#comment-17479861 ] Yang Wang commented on FLINK-25743: --- I believe the flink.yarn. config option could work as expected.

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

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

[GitHub] [flink] flinkbot edited a comment on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

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

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

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

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 41ed8dfb2e8b804827e761eda9dc2082f7a553d7 Azure:

[GitHub] [flink] simenliuxing commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

simenliuxing commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789396137 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

[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=17479856#comment-17479856 ] Yang Wang commented on FLINK-25685: --- I believe the test will pass if you use

[GitHub] [flink] flinkbot edited a comment on pull request #18433: [FLINK-25741][runtime] Skip buffer pools which have no floating buffe…

flinkbot edited a comment on pull request #18433: URL: https://github.com/apache/flink/pull/18433#issuecomment-1018075249 ## CI report: * 6742f87862c468edf026bb9fb1a61558f9a93a99 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 41ed8dfb2e8b804827e761eda9dc2082f7a553d7 Azure:

[GitHub] [flink] twalthr commented on pull request #18408: [FLINK-24865][cep] Support MATCH_RECOGNIZE in Batch mode

twalthr commented on pull request #18408: URL: https://github.com/apache/flink/pull/18408#issuecomment-1018221669 Thanks for working on this @SteNicholas. I will review it today or Monday latest. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #18377: [FLINK-25664][runtime] Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == tr

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

[GitHub] [flink] flinkbot edited a comment on pull request #18377: [FLINK-25664][runtime] Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == tr

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

[GitHub] [flink] JingsongLi commented on a change in pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

JingsongLi commented on a change in pull request #18412: URL: https://github.com/apache/flink/pull/18412#discussion_r789390013 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java ## @@ -65,7 +67,9 @@ *

[GitHub] [flink] JingsongLi commented on a change in pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

JingsongLi commented on a change in pull request #18412: URL: https://github.com/apache/flink/pull/18412#discussion_r789389668 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/sink/KafkaWriter.java ## @@ -391,6 +401,10 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

flinkbot edited a comment on pull request #18405: URL: https://github.com/apache/flink/pull/18405#issuecomment-1017071379 ## CI report: * 50343b760eb8a73f6ed654e1452f80ad19204627 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

flinkbot edited a comment on pull request #18405: URL: https://github.com/apache/flink/pull/18405#issuecomment-1017071379 ## CI report: * 50343b760eb8a73f6ed654e1452f80ad19204627 Azure:

[GitHub] [flink] JingsongLi commented on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

JingsongLi commented on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1018212419 So I am thinking maybe we can move forward in https://github.com/JingsongLi/flink/pull/18#discussion_r765610007 Add a method to `InitContext`: ``` /** * Returns

[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: * 0ef6880cf18be2c419d5045893690cbc6f0d200f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18434: [FLINK-25742][akka] Remove the serialization of rpc invocation at Fli…

flinkbot edited a comment on pull request #18434: URL: https://github.com/apache/flink/pull/18434#issuecomment-1018078894 ## CI report: * 123918f917a1e4fbea09c64c97c88b20f9a18792 Azure:

[GitHub] [flink] JingsongLi commented on pull request #18412: [FLINK-25696][datastream] Introduce MetadataPublisher interface to SinkWriter

JingsongLi commented on pull request #18412: URL: https://github.com/apache/flink/pull/18412#issuecomment-1018210567 Thanks @fapaul for the review, I've rethought it and it's probably not a good idea either way. - approach 1: `SinkWriter` implements `MetadataPublisher`, actually,

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

flinkbot edited a comment on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067 ## CI report: * 3c3aedefda07bea1b5cf7223b4f0305f469d9e15 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: * 0ef6880cf18be2c419d5045893690cbc6f0d200f Azure:

[GitHub] [flink] beyond1920 commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

beyond1920 commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789384222 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation where

[GitHub] [flink] MartijnVisser commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

MartijnVisser commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789383574 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

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

[GitHub] [flink] simenliuxing commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

simenliuxing commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789382619 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

[jira] [Commented] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479846#comment-17479846 ] Martijn Visser commented on FLINK-25740: CC [~affe] > PulsarSourceOrderedE2ECase fails on

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479843#comment-17479843 ] Martijn Visser commented on FLINK-18356: We've just merged a fix for

[GitHub] [flink] MartijnVisser commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

MartijnVisser commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789377665 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

[GitHub] [flink] simenliuxing commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

simenliuxing commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789375653 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

[jira] [Updated] (FLINK-25689) Introduce atomic commit

[ https://issues.apache.org/jira/browse/FLINK-25689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25689: - Description: This ticket introduces an atomic commit transaction for file store. # Before

[jira] (FLINK-25700) flinksql Cascading Window TVF Aggregation exception

[ https://issues.apache.org/jira/browse/FLINK-25700 ] simenliuxing deleted comment on FLINK-25700: -- was (Author: simen): [~wenlong.lwl]  Thank you for your reply, I have fixed this document problem https://github.com/apache/flink/pull/18414 ,

[jira] [Closed] (FLINK-25689) Introduce atomic commit

[ https://issues.apache.org/jira/browse/FLINK-25689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25689. Resolution: Fixed master: 8b080e108d3ac3ff4425f2deb41c154e0e0c5504 > Introduce atomic commit >

[GitHub] [flink] MartijnVisser commented on pull request #18408: [FLINK-24865][cep] Support MATCH_RECOGNIZE in Batch mode

MartijnVisser commented on pull request #18408: URL: https://github.com/apache/flink/pull/18408#issuecomment-1018197916 @SteNicholas I have to check, let me get back to you asap -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-table-store] JingsongLi merged pull request #12: [FLINK-25689] Introduce atomic commit

JingsongLi merged pull request #12: URL: https://github.com/apache/flink-table-store/pull/12 -- 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] MartijnVisser commented on pull request #17560: [FLINK-22315][table] Support ADD column/constraint/watermark for ALTER TABLE statement.

MartijnVisser commented on pull request #17560: URL: https://github.com/apache/flink/pull/17560#issuecomment-1018197635 Thank you for your contribution @RocMarshal - Please don't ping multiple people. It can be quite annoying for people who are working on open source contributions and can

[GitHub] [flink] MartijnVisser commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

MartijnVisser commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789373449 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

[jira] [Closed] (FLINK-25562) hive sql connector dependency conflicts

[ https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25562. -- Resolution: Not A Problem > hive sql connector dependency conflicts >

[jira] [Updated] (FLINK-25681) CodeSplitITCase produces large stacktraces and potentially out of memory errors

[ https://issues.apache.org/jira/browse/FLINK-25681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-25681: - Fix Version/s: 1.15.0 > CodeSplitITCase produces large stacktraces and potentially out of

[jira] [Closed] (FLINK-25681) CodeSplitITCase produces large stacktraces and potentially out of memory errors

[ https://issues.apache.org/jira/browse/FLINK-25681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25681. Resolution: Fixed master: 8c8e658636de1874b2abcf28827f34043bc49aff > CodeSplitITCase produces

[GitHub] [flink] JingsongLi merged pull request #18404: [FLINK-25681][table-planner] Remove failure test in CodeSplitITCase to avoid deep exception stack

JingsongLi merged pull request #18404: URL: https://github.com/apache/flink/pull/18404 -- 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] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Description: We have an application that contains a broadcast process stage. The none-broadcast input

[jira] [Created] (FLINK-25743) Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar

HunterHunter created FLINK-25743: Summary: Parameter flink.yarn. has no effect in yarn-session mode with flink-shade-hadoop-2-uber.jar Key: FLINK-25743 URL: https://issues.apache.org/jira/browse/FLINK-25743

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure:

[GitHub] [flink] flinkbot commented on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot commented on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174611 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 #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

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

[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: * 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:

[jira] [Updated] (FLINK-25712) Merge flink-connector-testing into flink-connector-test-utils

[ https://issues.apache.org/jira/browse/FLINK-25712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25712: --- Labels: pull-request-available (was: ) > Merge flink-connector-testing into

[GitHub] [flink] PatrickRen opened a new pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

PatrickRen opened a new pull request #18437: URL: https://github.com/apache/flink/pull/18437 ## What is the purpose of the change This pull request merges module `flink-connector-testing` into `flink-connector-test-utils`. ## Brief change log - Use

[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: * 66280958ba0046cbef940e575fc61a4ec6d62253 Azure:

[jira] [Commented] (FLINK-25529) java.lang.ClassNotFoundException: org.apache.orc.PhysicalWriter when write bulkly into hive-2.1.1 orc table

[ https://issues.apache.org/jira/browse/FLINK-25529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17479812#comment-17479812 ] luoyuxia commented on FLINK-25529: -- [~straw]Thanks for your reporting, you're right. There's no

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

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

[GitHub] [flink] wangyang0918 commented on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

wangyang0918 commented on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-1018142894 @spoon-lz I believe that you forget the changes in `ClusterEntrypoint.java` when you squash and refine the commits. -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-25728) Protential memory leeks in StreamMultipleInputProcessor

[ https://issues.apache.org/jira/browse/FLINK-25728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] pc wang updated FLINK-25728: Description: We have an application that contains a broadcast process stage. The none-broadcast input

[GitHub] [flink] simenliuxing commented on a change in pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

simenliuxing commented on a change in pull request #18414: URL: https://github.com/apache/flink/pull/18414#discussion_r789333463 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-agg.md ## @@ -199,7 +199,7 @@ The following shows a cascading window aggregation

  1   2   3   4   5   6   7   8   9   >