问题一:开源flink都是可以通过这个来创建,但在blink上试用TableApi去这样写,就报错,为什么?
开源flink都是可以通过tableEvn.sqlUpdate("create table")来创建表的但是今天在blink上试了用TableApi去这样写,就报错,为什么?Unsupported SQL query! sqlUpdate() only accepts SQL statements of type INSERT and DELETE.是什么情况,不支持用代码的方式执行create语句吗,那只能用blink开发平台的sql脚本?
参考回答:
根据您提供的信息,错误提示显示“Unsupported SQL query! sqlUpdate() only accepts SQL statements of type INSERT and DELETE。”这意味着在 blink 版本上,TableApi 的 sqlUpdate() 方法只支持 INSERT 和 DELETE 类型的 SQL 语句,而不支持 CREATE 类型的语句。
在 Flink 的 TableAPI 中,sqlUpdate() 方法用于执行更新语句,例如 INSERT、DELETE、UPDATE 等操作。然而,根据 blink 版本的规定,该方法不支持 CREATE 类型的 SQL 语句。因此,您无法使用 TableAPI 的 sqlUpdate() 方法来执行 CREATE TABLE 语句。
要解决这个问题,您可以使用 blink 版本的 SQL API 来执行 CREATE TABLE 语句。根据您的描述,您已经尝试过使用 TableAPI 的 sqlUpdate() 方法来执行 CREATE TABLE 语句,并遇到了错误。因此,您应该尝试使用 SQL API 来执行相同的操作。
在 blink 版本中,您可以使用 blink 的 SQL API 来执行任意的 SQL 语句,包括 CREATE TABLE 语句。具体的实现方式取决于您使用的编程语言和 blink 版本的具体支持情况。您可以参考 blink 版本的文档或示例代码,了解如何使用 SQL API 来执行 CREATE TABLE 语句。
另外,如果您希望使用 TableAPI 来创建表,您可以尝试使用 TableFactory 或者 Catalog API 来实现。这些 API 可以让您以编程方式创建和管理表。具体的实现方式可以参考 Flink 的官方文档或示例代码。
总之,根据您提供的信息,错误提示是由于 blink 版本对 sqlUpdate() 方法的限制导致的。要解决这个问题,您应该尝试使用 blink 的 SQL API 或其他适合的 API 来执行 CREATE TABLE 语句。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565860
问题二:Flink CDC这个错误 有碰到的么?
Flink CDC这个错误 有碰到的么?指定从特殊点位启动,然后用保存点恢复 就报这个错误Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.6.4.Final,connector=mysql,name=mysql_binlog_source,ts_ms=1698235423921,db=,server_id=0,file=mysql-bin.009913,pos=4,row=0}, but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed.st
参考回答:
是不是数据库对应的binlog没了,建议加大binlog保存时间
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565527
问题三:Flinkcdc 2.4为啥还报这个错?
Flinkcdc 2.4为啥还报这个错?Caused by: java.lang.UnsupportedOperationException: Unsupported startup mode: TIMESTAMP
参考回答:
你用的连接器不支持timestamp启动
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565525
问题四:Flink CDC这个错误啥意思?
Flink CDC这个错误啥意思?
参考回答:
看好像是通信超时,长时间不回应挂掉了,丢数据了,丢数据引起的,还是搭建和集群吧
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/565524