[
https://issues.apache.org/jira/browse/FLINK-33780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17795574#comment-17795574
]
Yubin Li edited comment on FLINK-33780 at 12/12/23 3:21 AM:
------------------------------------------------------------
[~hackergin] Hi, we could make modifitions in the `CatalogManager` construct
function as follows:
!image-2023-12-12-11-09-53-075.png|width=1165,height=593!
DefaultCatalog is the current catalog of a session including SqlGateway,
`default_catalog` is like `d2` under the context `use catalog d2`, only the
difference is that it is created implicitly by Flink, we should treat them
equally for semantic consistency, WDYT?
was (Author: liyubin117):
[~hackergin] Hi, we could make modifitions in the `CatalogManager` construct
function as follows:
!image-2023-12-12-11-09-53-075.png|width=1165,height=593!
DefaultCatalog is the current catalog of a session including SqlGateway,
`default_catalog` is like `d2`, only the difference is that it is created
implicitly by Flink, we should treat them equally for semantic consistency,
WDYT?
!image-2023-12-11-14-14-10-002.png|width=805,height=565!
> Support to store default catalog in CatalogStore
> ------------------------------------------------
>
> Key: FLINK-33780
> URL: https://issues.apache.org/jira/browse/FLINK-33780
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Affects Versions: 1.19.0
> Reporter: Yubin Li
> Priority: Major
> Attachments: image-2023-12-11-13-47-29-623.png,
> image-2023-12-11-14-14-10-002.png, image-2023-12-12-11-09-53-075.png
>
>
> Flink initially creates a default catalog which is included in the
> `Map<String, Catalog> catalogs`, but is not stored in the CatalogStore.
> After conducting thorough investigation, I've determined that the necessary
> modification can be made within the `CatalogManager`.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
