当前位置: 首页 > 知识库问答 >
问题:

Talend中使用雪花组件的几个问题

江光明
2023-03-14

为了将数据从Ms sql Server2008传输到Snowflake,我使用了talend,但每次我都错误为

java.io.IOException: net.snowflake.client.loader.Loader$ConnectionError: State: CREATE_TEMP_TABLE, SQL compilation error: error line 1 at position 68
invalid identifier '"columnname"'
                at org.talend.components.snowflake.runtime.SnowflakeWriter.close(SnowflakeWriter.java:397)
                at org.talend.components.snowflake.runtime.SnowflakeWriter.close(SnowflakeWriter.java:52)
                at local_project.load_jobnotes_0_1.Load_Jobnotes.tMSSqlInput_1Process(Load_Jobnotes.java:2684)
                at local_project.load_jobnotes_0_1.Load_Jobnotes.runJobInTOS(Load_Jobnotes.java:3435)
                at local_project.load_jobnotes_0_1.Load_Jobnotes.main(Load_Jobnotes.java:2978)
Caused by: net.snowflake.client.loader.Loader$ConnectionError: State: CREATE_TEMP_TABLE, SQL compilation error: error line 1 at position 68
invalid identifier '"ID"'
                at net.snowflake.client.loader.ProcessQueue.run(ProcessQueue.java:349)
                at java.lang.Thread.run(Thread.java:748)
Caused by: net.snowflake.client.jdbc.SnowflakeSQLException: SQL compilation error: error line 1 at position 68

如果我在没有双引号的情况下手动执行相同的查询,它的工作很好,你能让我们知道这个问题的解决方案吗

talend在snowflake中执行的查询供参考

CREATE TEMPORARY TABLE "Tablename_20171024_115736_814_1" 
AS SELECT "column1","column2","column3"
FROM "database"."schema"."table" WHERE FALSE

共有1个答案

汝楷
2023-03-14

该问题很可能是由于Snowflake中的对象名称与通过连接器发送的内容之间的大小写不匹配造成的。在雪花一侧,所有对象名称都以大写形式存储。建议您尝试传递COLUMN1、COLUMN2等,看看是否有效。

您还可以尝试将QUOTED_IDENTIFIERS_IGNORE_CASE设置为true,这可能会有所帮助。

 类似资料:
  • 我是新来的雪花,所以请原谅我。我试图做一件非常简单的事情--通过文字指定列名,但却得到sql编译错误

  • 我试图通过SQL语句将多行数组和结构插入到Snowflake中。要在列中插入值数组,我使用函数,要插入结构/字典/对象,我使用函数。 这将导致异常: SQL编译错误:VALUES子句中的表达式[Array_Construct(0,1,2)]无效 使用以下语法插入一行可以工作:

  • 我正在搜索TABLE命令的官方文档(它与TABLE( ))不同。 我搜索了所有命令/查询语法,但没有太多成功。

  • 本文向大家介绍Kafka中有哪几个组件?相关面试题,主要包含被问及Kafka中有哪几个组件?时的应答技巧和注意事项,需要的朋友参考一下 答:Kafka最重要的元素是: 主题:Kafka主题是一堆或一组消息。 生产者:在Kafka,生产者发布通信以及向Kafka主题发布消息。 消费者:Kafka消费者订阅了一个主题,并且还从主题中读取和处理消息。 经纪人:在管理主题中的消息存储时,我们使用Kafka

  • 我如何一次加载5年的拼花数据并复制到一个表中?因为1个月的负荷比我1.5个小时,5年就要花我90个小时。如果有可能并行加载?我该怎么做呢? 谢谢