tongchenkeji 发表于：2023-10-18 17:40:150次点击 已关注取消关注 关注 私信 实时计算 Flink版使用dinky来运行flinksql为啥没有sink呢？[阿里云实时计算 Flink版] 暂停朗读为您朗读 实时计算 Flink版使用dinky来运行flinksql为啥没有sink呢？ 「点点赞赏，手留余香」 赞赏 还没有人赞赏，快来当第一个赞赏的人吧！ 海报 实时计算Flink版# 实时计算 Flink版3179# 流计算2236
KingingAM 2023-11-27 18:44:47 1 实时计算 Flink 版使用 Blink Planner（也称为 Dinky）作为 Flink 的 SQL & Table API 的执行引擎，Dinky 是 Flink 在版本1.11及以后引入的一种执行计划器。然而，在某些情况下，可能会发现在 Dinky 中没有特定的 Sink 操作。 这是因为在 Dinky 计划器中，对于 Flink 的 SQL & Table API，不再使用传统的 Sink 操作符。相反，Dinky 使用了更灵活的方式来定义输出目标。输出目标的定义通过在 SQL 或 Table API 中使用 INSERT INTO 语句来指定。INSERT INTO 语句用于将数据流发送到目标系统。 用法示例： 在 SQL 中使用 INSERT INTO： INSERT INTO outputTable SELECT * FROM inputTable WHERE ... 在 Table API 中使用 insertInto()： tableEnv.executeSql("CREATE TABLE outputTable (...) WITH (...)");Table outputTable = tableEnv.from("inputTable").where(...);outputTable.insertInto("outputTable"); 通过使用 INSERT INTO 语句，你可以将数据流定义为输出目标。具体输出目标的配置（如写入数据库、写入文件等），将由相应的 outputTable 的定义来确定。 需要注意的是，Dinky 计划器的很多特性和语法可能与传统的 Flink 计划器（如 Blink 计划器）有所不同。如果你在 Dinky 中遇到了问题或需要进一步了解，建议查阅相关文档和官方资源，或向 Flink 社区寻求支持和指导。
wljslmzAM 2023-11-27 18:44:47 2 Dinky是阿里巴巴开源的基于Flink的流批一体化数据汇聚、数据同步的实时计算平台。在Dinky中运行Flink SQL，您应该可以在SQL语句中使用INSERT INTO语句来指定输出到哪个表或文件。然而，如果在您的查询中没有看到sink相关的语法，可能是因为某些版本的Dinky不支持某些特定的sink。在这种情况下，建议您检查您的Dinky版本和文档，以确定可用的选项和语法。如果问题依然存在，可能需要寻求专业的技术支持或者考虑升级到支持所需功能的Dinky版本。
实时计算 Flink 版使用 Blink Planner（也称为 Dinky）作为 Flink 的 SQL & Table API 的执行引擎，Dinky 是 Flink 在版本1.11及以后引入的一种执行计划器。然而，在某些情况下，可能会发现在 Dinky 中没有特定的 Sink 操作。
这是因为在 Dinky 计划器中，对于 Flink 的 SQL & Table API，不再使用传统的 Sink 操作符。相反，Dinky 使用了更灵活的方式来定义输出目标。输出目标的定义通过在 SQL 或 Table API 中使用
INSERT INTO语句来指定。INSERT INTO语句用于将数据流发送到目标系统。用法示例：
在 SQL 中使用
INSERT INTO：在 Table API 中使用
insertInto()：通过使用
INSERT INTO语句，你可以将数据流定义为输出目标。具体输出目标的配置（如写入数据库、写入文件等），将由相应的outputTable的定义来确定。需要注意的是，Dinky 计划器的很多特性和语法可能与传统的 Flink 计划器（如 Blink 计划器）有所不同。如果你在 Dinky 中遇到了问题或需要进一步了解，建议查阅相关文档和官方资源，或向 Flink 社区寻求支持和指导。
Dinky是阿里巴巴开源的基于Flink的流批一体化数据汇聚、数据同步的实时计算平台。在Dinky中运行Flink SQL，您应该可以在SQL语句中使用INSERT INTO语句来指定输出到哪个表或文件。然而，如果在您的查询中没有看到sink相关的语法，可能是因为某些版本的Dinky不支持某些特定的sink。在这种情况下，建议您检查您的Dinky版本和文档，以确定可用的选项和语法。如果问题依然存在，可能需要寻求专业的技术支持或者考虑升级到支持所需功能的Dinky版本。