spark-doris-connector,Unknown column 'null' in 'table list' #57877
Unanswered
para-99
asked this question in
A - General / Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
I am using the Spark-Doris-Connector to read data from Doris, then perform some computations, and finally write the results back to Doris.
When I use the following Java code to read from Doris:
String filterString = "cust_no = '111'";
sparkSession.read()
.format("doris")
.option("doris.table.identifier", "busidb.tb_tx")
.option("doris.fenodes", "123")
.option("user", "123")
.option("password", "123")
.option("doris.filter", filterString)
.load();
Then I perform some computations, and finally write the result (allRslt) back to Doris using:
allRslt.write()
.format("doris")
.option("doris.table.identifier", "busidb.tb_rslt")
.option("doris.fenodes", "123")
.option("user", "123")
.option("password", "123")
.mode(SaveMode.Append)
.save();
I get the following error:
query plan failed, exception: errCode = 2, detailMessage = Unknown column 'null' in 'table list'
However, I have printed the columns of allRslt, and there is no column named "null" in it.
More strangely, if I read the data using .read().jdbc().load()(e.g., from a traditional database like MySQL) instead of Doris, this issue does not occur.
Has anyone else encountered this problem? Is this a problem with the Spark-Doris-Connector?
My Spark version is 3.4.3, and the Spark-Doris-Connector version is 25.1.0.
Beta Was this translation helpful? Give feedback.
All reactions