0
SQL Serverデータベースからデータをフェッチしようとしていて、スパークデータセットを作成しました。私がorientdbにデータセットを永続させるとき、それを行うことはできません。接続の例外が発生しました::データベース開けるのエラー 'JDBCを:オリエント:REMOTE:localhostの/テスト'orientdbにスパークデータセットを永続化できません
スレッド "メイン" java.lang.RuntimeExceptionでエラー例外の下に取得
ここ
は私のコードです:
Map<String, String> options = new HashMap<>();
options.put("driver", "com.microsoft.sqlserver.jdbc.SQLServerDriver");
options.put("url", "jdbc:sqlserver://localhost:1433;databaseName=sample");
options.put("user", "username");
options.put("password", "password");
DataFrameReader jdbcDF = spark.read().format("jdbc").options(options);
Dataset<Row> tableDataSet = jdbcDF.option("dbtable", "Table1").load();
tableDataSet.createOrReplaceTempView("TEMP_V");
Dataset<Row> tableDataset1 = spark.sql("SELECT ID AS DEPT_ID, NAME AS DEPT_NAME FROM TEMP_V");
tableDataset1.write().format("org.apache.spark.orientdb.graphs")
.option("dburl", "jdbc:orient:remote:localhost/test")
.option("user", "root")
.option("password", "root")
.option("spark", "true")
.option("vertextype", "DEPARTMENT")
.mode(SaveMode.Overwrite)
.save();
エラーメッセージにはtestdbがありますが、あなたのコードはurlでテスト済みです。ここに混乱がありますか? – BDR
バラージュなし。そこに入力ミス(testdb)。私は、どのorientdbデータベースにもデータセットを書くことができません。 –