还有一种做法就是使用datastream，datastream支持sideoutput，但 flink
sql不支持，不过有一种迂回的做法就是flinksql -> datastream -> flink
sql，可以查一下官网资料，flinksql和datastream可以互相转换。
Xuyang 于2023年10月30日周一 10:17写道：
> Flink SQL目前对于脏数据没有类似side output的机制来输出，这个需求用自定义connector应该可以实现。
>
>
>
>
>
>
>
> --
>
> Best！
> Xuyang
>
>
>
>
>
Hi casel,
Flink JDBC 链接到 gateway 目前使用的是 flink 的 gateway 接口，所以你在启动 gateway
的时候不用指定 endpoint 为 hiveserver2 类型，用 Flink 默认的 gateway endpoint 类型即可。
casel.chen 于2023年10月29日周日 17:24写道：
>
> 1. 启动flink集群
> bin/start-cluster.sh
>
>
> 2. 启动sql gateway
> bin/sql-gateway.sh start
Hi, CatalogStore 的引入我理解是为了Catalog能被更好地管理、注册和元数据存储，具体motivation可以参考Flip295[1].
我的理解是倒不是说“引入CatalogStore后才可以提供show create
catalog语法支持”，而是之前没有直接存储catalog配置的地方和能力，在CatalogStore之后，天然支持了对catalog配置的存储，因此这个feat就可以直接快速的支持了。
[1]
Flink SQL目前对于脏数据没有类似side output的机制来输出，这个需求用自定义connector应该可以实现。
--
Best！
Xuyang
在 2023-10-29 10:23:38，"casel.chen" 写道：
>场景：使用flink
>sql将数据写入下游OLAP系统，如doris，遇到一些异常情况，比如字段值超长或者分区字段值为当前doris表不存在的分区（需要先人为创建）等等，当前写入这些脏数据会使得作业写入报错，进而导致作业失败。我们是希望能够将这些“脏”数据单独发到一个kafka
>
请问flink 1.18引入的CatalogStore是为了解决什么问题呢？为什么引入CatalogStore后才可以提供show create
catalog语法支持？
在 2023-10-20 17:03:46，"李宇彬" 写道：
>Hi Feng
>
>
>我之前建过一个jira（https://issues.apache.org/jira/browse/FLINK-24939），引入CatalogStore后，实现这个特性的时机应该已经成熟了，我们这边业务场景里用到了很多catalog，管理起来很麻烦，有这个特性会好很多。
>| |
>
1. 启动flink集群
bin/start-cluster.sh
2. 启动sql gateway
bin/sql-gateway.sh start -Dsql-gateway.endpoint.type=hiveserver2
3. 将flink-sql-jdbc-driver-bundle-1.18.0.jar放到apache-hive-3.1.2-bin/lib目录下
4. 到apache-hive-3.1.2-bin目录下启动beeline连接sql gateway，提示输入用户名和密码时直接按的回车
$ bin/beeline
SLF4J: Class path
