2017-02-28 6 views
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(); 
+0

エラーメッセージにはtestdbがありますが、あなたのコードはurlでテスト済みです。ここに混乱がありますか? – BDR

+0

バラージュなし。そこに入力ミス(testdb)。私は、どのorientdbデータベースにもデータセットを書くことができません。 –

答えて

0

orientdbのJDBCドライバを書いている時点ではABLではありませんスパークデータセットを持続させる。サメの互換性を向上させるために、パッチを当てるべきです。ただし、orientdbから読み込み、データセットを読み込むことはできます。 問題をオープンしてください。

関連する問題