z:net.snowflake.spark.snowflake.utils.runquery::java.lang.nullpointerexception异常

sirbozc5  于 2021-05-31  发布在  Hadoop
关注(0)|答案(2)|浏览(379)

根据我的用例,我正在尝试将数据从s3写入snowflake。我的应用程序是用python/pyspark编写的,运行在aws eks集群上。
代码是:

def write_from_audience_parquet_to_snowflake(self):
    self.logger.info('write_from_audience_parquet_to_snowflake started')

    path = os.path.dirname(os.path.abspath(__file__))
    parquet_stage = read_template(path + '/sql/staging_audience_attribute.sql')
    input_base_s3 = self.base_input_s3_path.replace("s3a://", "s3://")

    self.logger.info("input_base_s3 = {}".format(input_base_s3))

    parquet_stage = parquet_stage.render(input_base_s3=input_base_s3, mab_id=self.mab_id,
                                         mab_send_id=self.mab_send_id, access_key=self.aws_access_key,
                                         secret_key=self.aws_secret_key, session_token=self.aws_session_key)

    create_table_template = read_template(path + '/sql/create_audience_table.sql')
    create_table_sql = create_table_template.render(audience_table=self.audience_table)

    upload_stage = read_template(path + '/sql/upload_audience_stage.sql')
    upload_stage = upload_stage.render(audience_table=self.audience_table)

    try:
        self.utilSf.runQuery(self.sfoptions, parquet_stage)
        self.utilSf.runQuery(self.sfoptions, create_table_sql)
        self.utilSf.runQuery(self.sfoptions, upload_stage)
    except Exception as e:
        self.logger.exception(e)
        raise e

    self.logger.info('write_from_audience_parquet_to_snowflake completed successfully')

错误是:

An error occurred while calling z:net.snowflake.spark.snowflake.Utils.runQuery.
: java.lang.NullPointerException
    at java.util.Hashtable.put(Hashtable.java:460)
    at net.snowflake.spark.snowflake.JDBCWrapper.getConnector(SnowflakeJDBCWrapper.scala:141)
    at net.snowflake.spark.snowflake.Utils$.getJDBCConnection(Utils.scala:244)
    at net.snowflake.spark.snowflake.Utils$.getJDBCConnection(Utils.scala:249)
    at net.snowflake.spark.snowflake.Utils$.runQuery(Utils.scala:391)
    at net.snowflake.spark.snowflake.Utils.runQuery(Utils.scala)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
    at py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
    at py4j.Gateway.invoke(Gateway.java:282)
    at py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
    at py4j.commands.CallCommand.execute(CallCommand.java:79)
    at py4j.GatewayConnection.run(GatewayConnection.java:238)
    at java.lang.Thread.run(Thread.java:748)

请在这里找到完整的错误日志
我已经读到,这是因为spark提供的scala版本控制问题。我正在使用spark 2.4.5和外部添加的hadoop 3.1.2。另外,我用的是这些雪花罐:
spark-snowflake\ u 2.11-2.4.10-spark\ u 2.4.jar
snowflake-ingest-sdk-0.9.5.jar
雪花-jdbc-3.6.15.jar
如果需要更多的细节,请通过评论让我知道。

q43xntqr

q43xntqr1#

看起来您使用的是旧版本的snowflake spark连接器和jdbc驱动程序。请使用最新的雪花Spark连接器(2.7.0-spark_.4)和jdbc驱动程序(3.12.2)进行测试
https://search.maven.org/classic/#search%7cgav%7c1%7cg%3a%22净雪花%22%20和%20a%3a%22Spark雪花\u 2.11%22
https://repo1.maven.org/maven2/net/snowflake/snowflake-jdbc/3.12.2/
如果您能够复制最新的连接器和驱动程序的问题,然后请打开一个与我们的日志案件。谢谢!

tvokkenx

tvokkenx2#

错误发生在它尝试连接到snowflake时。我建议检查“self.sfoptions”中的值,以确保正确指定了所有必需的选项。下面是一个例子:

sfOptions = {
  "sfURL" : "<account_name>.<cloud_domain>",
  "sfAccount" : "<account_name>",
  "sfUser" : "<user_name>",
  "sfPassword" : "<password>",
  "sfDatabase" : "<database>",
  "sfSchema" : "<schema>",
  "sfWarehouse" : "<warehouse>",
}

相关问题