scala> mockDataDF1.write.format("doris"
| ).option("doris.table.identifier", "xy.odbc_table3"
| ).option("doris.fenodes", "192.168.0.152:8030"
| ).option("user", "root"
| ).option("password", "root123"
| ).option("doris.write.fields","id"
| ).save()
java.lang.RuntimeException: org.apache.doris.spark.sql.DorisSourceProvider does not allow create table as select.
at scala.sys.package$.error(package.scala:27)
at org.apache.spark.sql.execution.datasources.DataSource.planForWriting(DataSource.scala:526)
at org.apache.spark.sql.DataFrameWriter.saveToV1Source(DataFrameWriter.scala:281)
at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:270)
... 57 elided
大佬们好,我在Doris中建好表了,为什么一直写入写不进去呢?
同问
各位大佬,萌新请教一个问题。我在三台机器上部署了doris,一台fe、be混部,两台单独部署be。doris版本是0.15.0
在用spark DataFrame向doris导入数据时,一开始可以正常导入,但是后面会报如下的错误
2022-01-26 14:29:41,867 ERROR Executor:94 Executor task launch worker for task 11714 718847 - Exception in task 9.0 in stage 8206.0 (TID 11714)
org.apache.doris.spark.exception.StreamLoadException: stream load error: too many filtered rows
at org.apache.doris.spark.DorisStreamLoad.load(DorisStreamLoad.java:162)
at org.apache.doris.spark.DorisStreamLoad.load(DorisStreamLoad.java:149)
at org.apache.doris.spark.sql.DorisSourceProvider
KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲createRelation$…: anonfun$createRelation$1
anonfun$org$apache$doris$spark$sql$DorisSourceProvideranonfunflush$1$1KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲apply$mcV$sp$1.…: anonfun$apply$mcV$sp$1.apply$mcVI$sp(DorisSourceProvider.scala:96)
at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:160)
at org.apache.doris.spark.sql.DorisSourceProvider
anonfun$createRelation$1KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲org$apache$dori…: anonfun$org$apache$doris$spark$sql$DorisSourceProvider
anonfunKaTeX parse error: Can't use function '$' in math mode at position 6: flush$̲1$1.apply$mcV$s…: flush$1$1.apply$mcV$sp(DorisSourceProvider.scala:86)
at scala.util.control.Breaks.breakable(Breaks.scala:38)
at org.apache.doris.spark.sql.DorisSourceProvider
anonfun$createRelation$1.org$apache$doris$spark$sql$DorisSourceProvideranonfunflush$1(DorisSourceProvider.scala:84)KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲createRelation$…: anonfun$createRelation$1
anonfun$apply$2.apply(DorisSourceProvider.scala:70)KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲createRelation$…: anonfun$createRelation$1
anonfun$apply$2.apply(DorisSourceProvider.scala:62)KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲createRelation$…: anonfun$createRelation$1.apply(DorisSourceProvider.scala:62)
at org.apache.doris.spark.sql.DorisSourceProvider
anonfun$createRelation$1.apply(DorisSourceProvider.scala:60)KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲foreachPartitio…: anonfun$foreachPartition$1
anonfun$apply$28.apply(RDD.scala:935)KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲foreachPartitio…: anonfun$foreachPartition$1
anonfun$apply$28.apply(RDD.scala:935)KaTeX parse error: Can't use function '$' in math mode at position 8: anonfun$̲runJob$5.apply(…: anonfun$runJob$5.apply(SparkContext.scala:2121)
at org.apache.spark.SparkContext
anonfun$runJob$5.apply(SparkContext.scala:2121)今年上半年doris有哪些规划?
Roadmap 2022: apache/incubator-doris#7502