[GitHub] [flink] RocMarshal edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-943132915 Thanks @Airblader @twalthr @wuchong @MartijnVisser for the review. I updated it based on your comments. PTAL. Thx. -- This is an automated message from the Apache

[jira] [Updated] (FLINK-21420) Add path templating to the DataStream API

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

[jira] [Updated] (FLINK-22066) Improve Error Message on unknown Ingress Type

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

[jira] [Updated] (FLINK-22389) Expose Message Batches to SDKs

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

[jira] [Updated] (FLINK-22633) Add a Harness example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-22633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22633: --- Labels: auto-unassigned developer-experience stale-major (was: auto-unassigned

[jira] [Updated] (FLINK-22554) Support Kafka Topic Patterns in Kafka Ingress

[ https://issues.apache.org/jira/browse/FLINK-22554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22554: --- Labels: auto-unassigned pull-request-available stale-major (was: auto-unassigned

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * 237353b8cef1a7fd7747a6f62bd1910595d40d5c Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

AHeise commented on a change in pull request #17374: URL: https://github.com/apache/flink/pull/17374#discussion_r734779888 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

flinkbot edited a comment on pull request #17549: URL: https://github.com/apache/flink/pull/17549#issuecomment-949678124 ## CI report: * dd84b7ac9f4bcf38261f4c1932d83960dc943057 Azure:

[GitHub] [flink-web] AHeise merged pull request #474: [hotfix][doc] Some typos in the Release Announcement

AHeise merged pull request #474: URL: https://github.com/apache/flink-web/pull/474 -- 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] AHeise commented on pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

AHeise commented on pull request #17523: URL: https://github.com/apache/flink/pull/17523#issuecomment-949862609 Could you please create PRs with the forward port to 1.14 / master (potentially without the DataSet part)?  -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-21407) Clarify which sources and APIs support which formats

[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21407: Fix Version/s: 1.13.4 > Clarify which sources and APIs support which formats >

[jira] [Commented] (FLINK-21407) Clarify which sources and APIs support which formats

[ https://issues.apache.org/jira/browse/FLINK-21407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17433111#comment-17433111 ] Arvid Heise commented on FLINK-21407: - Merged into 1.13 as

[GitHub] [flink] AHeise merged pull request #17523: [FLINK-21407] Update formats in connectors doc for Flink 1.13 for DataSet and DataStream APIs

AHeise merged pull request #17523: URL: https://github.com/apache/flink/pull/17523 -- 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] AHeise commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

AHeise commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-949856160 Hey, thank you very much for your contribution. Could you show (ideally by adding a test case) how your solution is fixing the initial issue? I don't quite understand what

[GitHub] [flink] AHeise edited a comment on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

AHeise edited a comment on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-949856160 Hey, thank you very much for your contribution. Could you show (ideally by adding a test case) how your solution is fixing the initial issue? I don't quite understand

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[jira] [Updated] (FLINK-24622) Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync()

[ https://issues.apache.org/jira/browse/FLINK-24622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24622: Component/s: Runtime / Coordination > Unified sources do not close scheduled threads from >

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17550: [FLINK-24599][table] Replace static methods with member methods

flinkbot edited a comment on pull request #17550: URL: https://github.com/apache/flink/pull/17550#issuecomment-949779530 ## CI report: * 66c9ead84d9309bce59c77d12a913bd3471edec1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

Airblader commented on a change in pull request #17549: URL: https://github.com/apache/flink/pull/17549#discussion_r734689757 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlJsonUtils.java ## @@ -58,7 +61,9 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17550: [FLINK-24599][table] Replace static methods with member methods

flinkbot edited a comment on pull request #17550: URL: https://github.com/apache/flink/pull/17550#issuecomment-949779530 ## CI report: * 66c9ead84d9309bce59c77d12a913bd3471edec1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot commented on pull request #17550: [FLINK-24599][table] Replace static methods with member methods

flinkbot commented on pull request #17550: URL: https://github.com/apache/flink/pull/17550#issuecomment-949780576 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 #17550: [FLINK-24599][table] Replace static methods with member methods

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

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 083a2773e9edc56a79acebb824dec0e424442456 Azure:

[jira] [Updated] (FLINK-24599) Make checking for type root and family less verbose

[ https://issues.apache.org/jira/browse/FLINK-24599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24599: --- Labels: pull-request-available (was: ) > Make checking for type root and family less

[GitHub] [flink] matriv opened a new pull request #17550: [FLINK-24599][table] Replace static methods with member methods

matriv opened a new pull request #17550: URL: https://github.com/apache/flink/pull/17550 Make the code of calling `hasRoot`/`hasFamily` less verbose by replacing the static utility methods with member methods `LogicalType#is()` ## Does this pull request potentially affect one

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * e9b8cb2a13f66a727ce22c9b99dea47801701e76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * ba7ae1015a95b39276744f6cd0aaf19638e61509 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734668106 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandlerTest.java ## @@ -123,6 +122,8 @@

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734667684 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java ## @@ -132,37 +134,49 @@

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * ba7ae1015a95b39276744f6cd0aaf19638e61509 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * ba7ae1015a95b39276744f6cd0aaf19638e61509 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * ba7ae1015a95b39276744f6cd0aaf19638e61509 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

flinkbot edited a comment on pull request #17544: URL: https://github.com/apache/flink/pull/17544#issuecomment-949353495 ## CI report: * ba7ae1015a95b39276744f6cd0aaf19638e61509 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[jira] [Created] (FLINK-24622) Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync()

Mason Chen created FLINK-24622: -- Summary: Unified sources do not close scheduled threads from SplitEnumeratorContext#callAsync() Key: FLINK-24622 URL: https://issues.apache.org/jira/browse/FLINK-24622

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734657528 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandlerTest.java ## @@ -123,6 +122,8 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734656723 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734655665 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] zentol edited a comment on pull request #17498: [FLINK-14954][rest] Add OpenAPI spec generator

zentol edited a comment on pull request #17498: URL: https://github.com/apache/flink/pull/17498#issuecomment-949660400 ~~It is easier at the moment to expose it via the documentation compared to serving it at runtime because of the dependency graph.~~ ~~I don't think there's any

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734647191 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

slinkydeveloper commented on a change in pull request #17544: URL: https://github.com/apache/flink/pull/17544#discussion_r734647200 ## File path: flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSource.java ## @@ -315,13 +340,44

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17548: [FLINK-24383][streaming] Remove the deprecated SlidingTimeWindows, TumblingTimeWindows, BaseAlignedWindowAssigner.

flinkbot edited a comment on pull request #17548: URL: https://github.com/apache/flink/pull/17548#issuecomment-949581280 ## CI report: * 476986c75b18bd0e95c67c923fa86e56a11416d4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734641926 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734636854 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] slinkydeveloper commented on a change in pull request #17544: [FLINK-24165][table] Add infrastructure to support metadata for filesystem connector

slinkydeveloper commented on a change in pull request #17544: URL: https://github.com/apache/flink/pull/17544#discussion_r734637968 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/utils/ExtendedRowData.java ## @@ -0,0 +1,312 @@ +/* + *

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734636854 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandler.java ## @@ -0,0 +1,118 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 18fc33e2e39acfb20a4b42db382fce3dc5b3292b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734631223 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandlerTest.java ## @@ -0,0 +1,196 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 7847b407beb9f513d737b1cf8cdc1abf60e5ba1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734628695 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCachedOperationsHandlerTest.java ## @@ -0,0 +1,196 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

flinkbot edited a comment on pull request #17474: URL: https://github.com/apache/flink/pull/17474#issuecomment-943148500 ## CI report: * 7847b407beb9f513d737b1cf8cdc1abf60e5ba1d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] nicoweidner commented on a change in pull request #17474: [FLINK-18312] Add caching for savepoint operations to Dispatcher

nicoweidner commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r734612003 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/TriggerSavepointParameters.java ## @@ -0,0 +1,79 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

[jira] [Created] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

Chesnay Schepler created FLINK-24621: Summary: JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor Key: FLINK-24621 URL: https://issues.apache.org/jira/browse/FLINK-24621

[jira] [Updated] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24621: - Fix Version/s: 1.13.4 > JobManager fails to recover 1.13.1 checkpoint due to >

[jira] [Updated] (FLINK-24621) JobManager fails to recover 1.13.1 checkpoint due to InflightDataRescalingDescriptor

[ https://issues.apache.org/jira/browse/FLINK-24621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24621: - Priority: Blocker (was: Major) > JobManager fails to recover 1.13.1 checkpoint due to

[GitHub] [flink] flinkbot edited a comment on pull request #17549: [FLINK-16205][table-planner] Support JSON_OBJECTAGG

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

  1   2   3   >