[jira] [Assigned] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33211: - Assignee: Zhenqiu Huang (was: Peter Huang) > Implement table lineage graph >

[jira] [Assigned] (FLINK-33211) Implement table lineage graph

[ https://issues.apache.org/jira/browse/FLINK-33211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33211: - Assignee: Peter Huang > Implement table lineage graph > - > >

[jira] [Closed] (FLINK-33210) Introduce lineage graph relevant interfaces

[ https://issues.apache.org/jira/browse/FLINK-33210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-33210. - Fix Version/s: 1.20.0 Resolution: Resolved Closed by 6b9c282b5090720a02b941586cb7f5389691dba9 >

[jira] [Updated] (FLINK-34460) Jdbc driver get rid of flink-core

[ https://issues.apache.org/jira/browse/FLINK-34460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-34460: -- Description: Currently jdbc driver depends on flink-core/flink-runtime modules, users need to upgrade

[jira] [Assigned] (FLINK-34466) Implement Lineage Interface in Kafka Connector

[ https://issues.apache.org/jira/browse/FLINK-34466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34466: - Assignee: Zhenqiu Huang > Implement Lineage Interface in Kafka Connector >

[jira] [Assigned] (FLINK-34468) Implement Lineage Interface in Cassandra Connector

[ https://issues.apache.org/jira/browse/FLINK-34468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34468: - Assignee: Zhenqiu Huang > Implement Lineage Interface in Cassandra Connector >

[jira] [Assigned] (FLINK-34467) Implement Lineage Interface in Jdbc Connector

[ https://issues.apache.org/jira/browse/FLINK-34467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34467: - Assignee: Zhenqiu Huang > Implement Lineage Interface in Jdbc Connector >

[jira] [Created] (FLINK-34460) Jdbc driver get rid of flink-core

Fang Yong created FLINK-34460: - Summary: Jdbc driver get rid of flink-core Key: FLINK-34460 URL: https://issues.apache.org/jira/browse/FLINK-34460 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815486#comment-17815486 ] Fang Yong commented on FLINK-34239: --- [~mallikarjuna] DONE > Introduce a deep copy method of

[jira] [Assigned] (FLINK-34239) Introduce a deep copy method of SerializerConfig for merging with Table configs in org.apache.flink.table.catalog.DataTypeFactoryImpl

[ https://issues.apache.org/jira/browse/FLINK-34239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34239: - Assignee: Kumar Mallikarjuna > Introduce a deep copy method of SerializerConfig for merging

[jira] [Assigned] (FLINK-34402) Class loading conflicts when using PowerMock in ITcase.

[ https://issues.apache.org/jira/browse/FLINK-34402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-34402: - Assignee: yisha zhou > Class loading conflicts when using PowerMock in ITcase. >

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813003#comment-17813003 ] Fang Yong commented on FLINK-31275: --- Hi [~mobuchowski] [~ZhenqiuHuang], I feel that there are many

[jira] [Created] (FLINK-34090) Introduce SerializerConfig for serialization

Fang Yong created FLINK-34090: - Summary: Introduce SerializerConfig for serialization Key: FLINK-34090 URL: https://issues.apache.org/jira/browse/FLINK-34090 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34037) FLIP-398: Improve Serialization Configuration And Usage In Flink

Fang Yong created FLINK-34037: - Summary: FLIP-398: Improve Serialization Configuration And Usage In Flink Key: FLINK-34037 URL: https://issues.apache.org/jira/browse/FLINK-34037 Project: Flink

[jira] [Assigned] (FLINK-33682) Reuse source operator input records/bytes metrics for SourceOperatorStreamTask

[ https://issues.apache.org/jira/browse/FLINK-33682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33682: - Assignee: Zhanghao Chen > Reuse source operator input records/bytes metrics for

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789890#comment-17789890 ] Fang Yong commented on FLINK-31275: --- [~mobuchowski] Sorry for the late reply. What does the `DataSet`

[jira] [Created] (FLINK-33626) Wrong style in flink ui

Fang Yong created FLINK-33626: - Summary: Wrong style in flink ui Key: FLINK-33626 URL: https://issues.apache.org/jira/browse/FLINK-33626 Project: Flink Issue Type: Bug Components:

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17785782#comment-17785782 ] Fang Yong commented on FLINK-31275: --- [~mobuchowski] Sorry for the late reply, I think I get your point

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783147#comment-17783147 ] Fang Yong edited comment on FLINK-31275 at 11/6/23 9:17 AM: Hi

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17783147#comment-17783147 ] Fang Yong commented on FLINK-31275: --- Hi [~mobuchowski] Thanks for your reply. I think our ideas are

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17782461#comment-17782461 ] Fang Yong commented on FLINK-31275: --- [~ZhenqiuHuang] Sounds nice to me, I think we can consider this

[jira] [Comment Edited] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781613#comment-17781613 ] Fang Yong edited comment on FLINK-31275 at 11/1/23 9:04 AM: Hi

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17781613#comment-17781613 ] Fang Yong commented on FLINK-31275: --- Hi [~mobuchowski], thanks for your comments. In the currently

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778890#comment-17778890 ] Fang Yong commented on FLINK-31275: --- [~ZhenqiuHuang] Sorry for the late reply, and please feel free to

[jira] [Assigned] (FLINK-33210) Introduce lineage graph relevant interfaces

[ https://issues.apache.org/jira/browse/FLINK-33210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33210: - Assignee: Fang Yong > Introduce lineage graph relevant interfaces >

[jira] [Closed] (FLINK-33166) Support setting root logger level by config

[ https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-33166. - Resolution: Fixed Fixed by b14411e7062c235cb28582a37e37decc7c425476 > Support setting root logger

[jira] [Assigned] (FLINK-33221) Add config options for administrator JVM options

[ https://issues.apache.org/jira/browse/FLINK-33221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33221: - Assignee: Zhanghao Chen > Add config options for administrator JVM options >

[jira] [Assigned] (FLINK-32309) Shared classpaths and jars manager for jobs in sql gateway cause confliction

[ https://issues.apache.org/jira/browse/FLINK-32309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32309: - Assignee: Fang Yong (was: FangYong) > Shared classpaths and jars manager for jobs in sql

[jira] [Closed] (FLINK-33205) Replace Akka with Pekko in the description of "pekko.ssl.enabled"

[ https://issues.apache.org/jira/browse/FLINK-33205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-33205. - Assignee: Zhanghao Chen Resolution: Fixed Fixed by d652238e84037a25eb0cef137f34edb37d9e1ac2 >

[jira] [Created] (FLINK-33212) Introduce job status changed listener for lineage

Fang Yong created FLINK-33212: - Summary: Introduce job status changed listener for lineage Key: FLINK-33212 URL: https://issues.apache.org/jira/browse/FLINK-33212 Project: Flink Issue Type:

[jira] [Created] (FLINK-33211) Implement table lineage graph

Fang Yong created FLINK-33211: - Summary: Implement table lineage graph Key: FLINK-33211 URL: https://issues.apache.org/jira/browse/FLINK-33211 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33210) Introduce lineage graph relevant interfaces

Fang Yong created FLINK-33210: - Summary: Introduce lineage graph relevant interfaces Key: FLINK-33210 URL: https://issues.apache.org/jira/browse/FLINK-33210 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-31275: - Assignee: Fang Yong > Flink supports reporting and storage of source/sink tables relationship

[jira] [Updated] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-31275: -- Description: FLIP-314 has been accepted

[jira] [Commented] (FLINK-31275) Flink supports reporting and storage of source/sink tables relationship

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17772734#comment-17772734 ] Fang Yong commented on FLINK-31275: --- [~ZhenqiuHuang] Thanks for your attention, FLIP-314 is on voting

[jira] [Assigned] (FLINK-33166) Support setting root logger level by config

[ https://issues.apache.org/jira/browse/FLINK-33166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33166: - Assignee: Zhanghao Chen > Support setting root logger level by config >

[jira] [Closed] (FLINK-32405) Initialize catalog listener for CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32405. - Resolution: Duplicate Duplicate with FLINK-32404 > Initialize catalog listener for CatalogManager >

[jira] [Commented] (FLINK-32405) Initialize catalog listener for CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17767354#comment-17767354 ] Fang Yong commented on FLINK-32405: --- OK, it is a duplicate issue with FLINK-32404 > Initialize

[jira] [Reopened] (FLINK-32405) Initialize catalog listener for CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reopened FLINK-32405: --- > Initialize catalog listener for CatalogManager > -- > >

[jira] [Closed] (FLINK-32848) [JUnit5 Migration] The persistence, query, registration, rpc and shuffle packages of flink-runtime module

[ https://issues.apache.org/jira/browse/FLINK-32848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32848. - Resolution: Fixed Fixed by

[jira] [Assigned] (FLINK-33033) Add haservice micro benchmark for olap

[ https://issues.apache.org/jira/browse/FLINK-33033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33033: - Assignee: Fang Yong > Add haservice micro benchmark for olap >

[jira] [Assigned] (FLINK-33051) GlobalFailureHandler interface should be retired in favor of LabeledGlobalFailureHandler

[ https://issues.apache.org/jira/browse/FLINK-33051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-33051: - Assignee: Matt Wang > GlobalFailureHandler interface should be retired in favor of >

[jira] [Closed] (FLINK-32396) Support timestamp for jdbc driver and gateway

[ https://issues.apache.org/jira/browse/FLINK-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32396. - Fix Version/s: 1.19.0 Resolution: Fixed Fixed by c33a6527d8383dc571e0b648b8a29322416ab9d6 >

[jira] [Created] (FLINK-33033) Add haservice micro benchmark for olap

Fang Yong created FLINK-33033: - Summary: Add haservice micro benchmark for olap Key: FLINK-33033 URL: https://issues.apache.org/jira/browse/FLINK-33033 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-25356) Add benchmarks for performance in OLAP scenarios

[ https://issues.apache.org/jira/browse/FLINK-25356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-25356: -- Parent: (was: FLINK-25318) Issue Type: Technical Debt (was: Sub-task) > Add benchmarks

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761807#comment-17761807 ] Fang Yong commented on FLINK-32667: --- [~mapohl] As we discussed in the threads

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Fix Version/s: 1.19.0 > Add quick start guide for Flink OLAP > >

[jira] [Closed] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32755. - Resolution: Fixed Fixed by fbef3c22757a2352145599487beb84e02aaeb389 > Add quick start guide for Flink

[jira] [Closed] (FLINK-32749) Sql gateway supports default catalog loaded by CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32749. - Fix Version/s: 1.19.0 Resolution: Fixed Fixed by 1797a70c0074b9e0cbfd20abc2c33050a7906578 > Sql

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: FLINK-32898 Issue Type: Sub-task (was: Improvement) > Add quick start guide for

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: (was: FLINK-32898) Issue Type: Improvement (was: Sub-task) > Add quick start

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: FLINK-32898 Issue Type: Sub-task (was: Improvement) > Add quick start guide for

[jira] [Updated] (FLINK-32755) Add quick start guide for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-32755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32755: -- Parent: (was: FLINK-25318) Issue Type: Improvement (was: Sub-task) > Add quick start

[jira] [Closed] (FLINK-32968) Fix doc for customized catalog listener

[ https://issues.apache.org/jira/browse/FLINK-32968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32968. - Fix Version/s: 1.18.0 1.19.0 Resolution: Fixed Fixed by

[jira] [Assigned] (FLINK-32396) Support timestamp for jdbc driver and gateway

[ https://issues.apache.org/jira/browse/FLINK-32396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32396: - Assignee: Fang Yong > Support timestamp for jdbc driver and gateway >

[jira] [Assigned] (FLINK-32749) Sql gateway supports default catalog loaded by CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32749: - Assignee: Fang Yong > Sql gateway supports default catalog loaded by CatalogStore >

[jira] [Assigned] (FLINK-32968) Fix doc for customized catalog listener

[ https://issues.apache.org/jira/browse/FLINK-32968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32968: - Assignee: Fang Yong > Fix doc for customized catalog listener >

[jira] [Updated] (FLINK-32968) Fix doc for customized catalog listener

[ https://issues.apache.org/jira/browse/FLINK-32968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32968: -- Summary: Fix doc for customized catalog listener (was: Update doc for customized catalog listener)

[jira] [Created] (FLINK-32968) Update doc for customized catalog listener

Fang Yong created FLINK-32968: - Summary: Update doc for customized catalog listener Key: FLINK-32968 URL: https://issues.apache.org/jira/browse/FLINK-32968 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17759072#comment-17759072 ] Fang Yong commented on FLINK-32798: --- [~ruanhang1993] Thanks for your suggestions and I will create an

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17758019#comment-17758019 ] Fang Yong commented on FLINK-32798: --- [~ruanhang1993] I checked the implementation in sql-gateway and

[jira] [Updated] (FLINK-32794) Release Testing: Verify FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway

[ https://issues.apache.org/jira/browse/FLINK-32794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32794: -- Description: Document for jdbc driver:

[jira] [Commented] (FLINK-32794) Release Testing: Verify FLIP-293: Introduce Flink Jdbc Driver For Sql Gateway

[ https://issues.apache.org/jira/browse/FLINK-32794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757760#comment-17757760 ] Fang Yong commented on FLINK-32794: --- Thanks [~renqs], DONE > Release Testing: Verify FLIP-293:

[jira] [Commented] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17757759#comment-17757759 ] Fang Yong commented on FLINK-32798: --- [~renqs] I have add the document link in the "Description" >

[jira] [Updated] (FLINK-32798) Release Testing: Verify FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32798: -- Description: The document about catalog modification listener is:

[jira] [Closed] (FLINK-32653) Add doc for catalog store

[ https://issues.apache.org/jira/browse/FLINK-32653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32653. - Fix Version/s: 1.19.0 Resolution: Fixed Thanks [~hackergin], fixed by

[jira] [Assigned] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-25015: - Assignee: xiangyu feng (was: KevinyhZou) > job name should not always be `collect` submitted

[jira] [Closed] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-31259. - Resolution: Fixed See https://issues.apache.org/jira/browse/FLINK-32427 > Gateway supports

[jira] [Closed] (FLINK-32660) Support external file systems in FileCatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32660. - Resolution: Fixed Thanks [~ferenc-csaky], fixed with f68967a7c938f6258125c3221be74522965d1ff2 >

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753091#comment-17753091 ] Fang Yong commented on FLINK-32667: --- [~mapohl] Thanks for your detailed explanation and I caught it.

[jira] [Comment Edited] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17753091#comment-17753091 ] Fang Yong edited comment on FLINK-32667 at 8/11/23 8:00 AM: [~mapohl] Thanks

[jira] [Commented] (FLINK-32747) Fix ddl operations for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752610#comment-17752610 ] Fang Yong commented on FLINK-32747: --- Fixed with 76554d186ad198384ff783e3e3f040dd738b7571 > Fix ddl

[jira] [Closed] (FLINK-32747) Fix ddl operations for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32747. - Fix Version/s: 1.18.0 Resolution: Fixed > Fix ddl operations for catalog from CatalogStore >

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752214#comment-17752214 ] Fang Yong commented on FLINK-32667: --- [~chesnay] In addition to the above solution, I think we can add

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752036#comment-17752036 ] Fang Yong commented on FLINK-32667: --- [~chesnay] [~mapohl] Currently ha service consists of two parts

[jira] [Updated] (FLINK-32747) Fix ddl operations for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32747: -- Description: Fix ddl operations for catalog which loaded by CatalogStore (was: Support ddl for

[jira] [Updated] (FLINK-32747) Fix ddl operations for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-32747: -- Summary: Fix ddl operations for catalog from CatalogStore (was: Support ddl for catalog from

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751092#comment-17751092 ] Fang Yong commented on FLINK-32667: --- [~mapohl] I think performance testing is a good suggestion, we

[jira] [Created] (FLINK-32749) Sql gateway supports default catalog loaded by CatalogStore

Fang Yong created FLINK-32749: - Summary: Sql gateway supports default catalog loaded by CatalogStore Key: FLINK-32749 URL: https://issues.apache.org/jira/browse/FLINK-32749 Project: Flink Issue

[jira] [Commented] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750938#comment-17750938 ] Fang Yong commented on FLINK-32667: --- [~mapohl] We have an internally e2e test for olap queries to

[jira] [Assigned] (FLINK-32747) Support ddl for catalog from CatalogStore

[ https://issues.apache.org/jira/browse/FLINK-32747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32747: - Assignee: Fang Yong > Support ddl for catalog from CatalogStore >

[jira] [Created] (FLINK-32747) Support ddl for catalog from CatalogStore

Fang Yong created FLINK-32747: - Summary: Support ddl for catalog from CatalogStore Key: FLINK-32747 URL: https://issues.apache.org/jira/browse/FLINK-32747 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

[ https://issues.apache.org/jira/browse/FLINK-32667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32667: - Assignee: Fang Yong > Use standalone store and embedding writer for jobs with

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747827#comment-17747827 ] Fang Yong commented on FLINK-25015: --- Hi [~zouyunhe], are you still working on this issue? I found this

[jira] [Updated] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong updated FLINK-25015: -- Parent: FLINK-25318 Issue Type: Sub-task (was: Improvement) > job name should not always be

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747763#comment-17747763 ] Fang Yong commented on FLINK-25015: --- [~zouyunhe] What's the progress of this issue, there're conflicts

[jira] [Commented] (FLINK-32698) Add getCheckpointOptions interface in ManagedSnapshotContext

[ https://issues.apache.org/jira/browse/FLINK-32698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747737#comment-17747737 ] Fang Yong commented on FLINK-32698: --- [~Ming Li] `ManagedSnapshotContext` is a `public` interface and

[jira] [Commented] (FLINK-32402) FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747719#comment-17747719 ] Fang Yong commented on FLINK-32402: --- [~knaufk] Currently I think it's better to add this in

[jira] [Assigned] (FLINK-32676) Add doc for catalog modification listener

[ https://issues.apache.org/jira/browse/FLINK-32676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong reassigned FLINK-32676: - Assignee: Fang Yong > Add doc for catalog modification listener >

[jira] [Created] (FLINK-32676) Add doc for catalog modification listener

Fang Yong created FLINK-32676: - Summary: Add doc for catalog modification listener Key: FLINK-32676 URL: https://issues.apache.org/jira/browse/FLINK-32676 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-32402) FLIP-294: Support Customized Catalog Modification Listener

[ https://issues.apache.org/jira/browse/FLINK-32402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17747235#comment-17747235 ] Fang Yong commented on FLINK-32402: --- Thanks [~knaufk], I'll create an issue to add doc for this

[jira] [Created] (FLINK-32667) Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster

Fang Yong created FLINK-32667: - Summary: Use standalone store and embedding writer for jobs with no-restart-strategy in session cluster Key: FLINK-32667 URL: https://issues.apache.org/jira/browse/FLINK-32667

[jira] [Created] (FLINK-32665) Support read null value for csv format

Fang Yong created FLINK-32665: - Summary: Support read null value for csv format Key: FLINK-32665 URL: https://issues.apache.org/jira/browse/FLINK-32665 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-29317) Add WebSocket in Dispatcher to support olap query submission and push results in session cluster

[ https://issues.apache.org/jira/browse/FLINK-29317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746784#comment-17746784 ] Fang Yong commented on FLINK-29317: --- Hi [~dmvk] Sorry for so late rely. Currently we would like to

[jira] [Created] (FLINK-32643) Introduce off-heap shared state cache across stateful operators in TM

Fang Yong created FLINK-32643: - Summary: Introduce off-heap shared state cache across stateful operators in TM Key: FLINK-32643 URL: https://issues.apache.org/jira/browse/FLINK-32643 Project: Flink

[jira] [Closed] (FLINK-32405) Initialize catalog listener for CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-32405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fang Yong closed FLINK-32405. - Resolution: Fixed > Initialize catalog listener for CatalogManager >

[jira] [Created] (FLINK-32633) Kubernetes e2e test is not stable

Fang Yong created FLINK-32633: - Summary: Kubernetes e2e test is not stable Key: FLINK-32633 URL: https://issues.apache.org/jira/browse/FLINK-32633 Project: Flink Issue Type: Technical Debt

[jira] [Commented] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

[ https://issues.apache.org/jira/browse/FLINK-32622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744215#comment-17744215 ] Fang Yong commented on FLINK-32622: --- cc [~libenchao] [~zoudan] > Do not add mini-batch assigner

[jira] [Created] (FLINK-32622) Do not add mini-batch assigner operator if it is useless

Fang Yong created FLINK-32622: - Summary: Do not add mini-batch assigner operator if it is useless Key: FLINK-32622 URL: https://issues.apache.org/jira/browse/FLINK-32622 Project: Flink Issue

[jira] [Commented] (FLINK-32370) JDBC SQl gateway e2e test is unstable

[ https://issues.apache.org/jira/browse/FLINK-32370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739896#comment-17739896 ] Fang Yong commented on FLINK-32370: --- [~Sergey Nuyanzin] Sorry that I checked the shell and found the

  1   2   3   >