Apache Druid原生SQL引擎不支持INSERT，如何通过MSQ解决？

核心问题 #

虽已加载MSQ扩展，但JDBC连接默认仍使用native引擎，而native引擎不支持INSERT操作，需强制指定使用MSQ引擎并验证相关配置。

具体解决方案 #

• 修改JDBC连接URL，强制指定MSQ引擎
  在原有连接地址后添加engine=msq参数，修改后的完整URL：

  jdbc:avatica:remote:url=http://54.210.239.246:8888/druid/v2/sql/avatica/;transparent_reconnection=true;engine=msq
  

  该参数会让Avatica JDBC请求直接路由到MSQ引擎执行。

• 验证MSQ扩展加载状态

  1. 访问Druid状态页面http://54.210.239.246:8888/status，在loadedExtensions列表中确认druid-multi-stage-query存在。
  2. 检查common.runtime.properties中的扩展配置，确保格式正确（不要遗漏其他必要扩展）：

     druid.extensions.loadList=["druid-multi-stage-query", "druid-histogram", "druid-datasketches"]
     

  3. 确认Druid已重启，扩展加载需重启集群生效。

• 适配MSQ的INSERT语法要求
  MSQ不支持单条VALUES格式的INSERT，必须使用SELECT子句批量写入，示例语法：

  INSERT INTO target_table
  SELECT col1, col2, col3
  FROM source_table
  WHERE condition;
  

  同时要保证SELECT字段与目标表的列名、数据类型完全匹配。

• 检查集群资源与权限

  1. 自动模式下确认集群worker节点有足够内存、CPU资源运行MSQ任务，避免因资源不足导致任务失败。
  2. 确保执行JDBC请求的用户具备MSQ任务提交权限，以及目标表的写入权限。

内容的提问来源于stack exchange，提问作者Abhishek Sharma