Advertisement
Guest User

Untitled

a guest
Aug 16th, 2017
83
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.59 KB | None | 0 0
  1. jdbc_url <- "jdbc:mysql://localhost:3306/dashboard?user=<username>&password=<password>"
  2.  
  3. df <- sqlContext %>%
  4. loadDF(source = "jdbc",
  5. url = jdbc_url,
  6. driver = "com.mysql.jdbc.Driver",
  7. dbtable = "db.table_name")
  8.  
  9. write.df(df = df,
  10. path = "NULL",
  11. source = "jdbc",
  12. url = jdbc_url,
  13. driver = "com.mysql.jdbc.Driver",
  14. dbtable = "db.table_name",
  15. mode = "append")
  16.  
  17. ERROR RBackendHandler: save on 55 failed
  18. Error in invokeJava(isStatic = FALSE, objId$id, methodName, ...) :
  19. java.lang.RuntimeException: org.apache.spark.sql.execution.datasources.jdbc.DefaultSource does not allow create table as select.
  20. at scala.sys.package$.error(package.scala:27)
  21. at org.apache.spark.sql.execution.datasources.ResolvedDataSource$.apply(ResolvedDataSource.scala:259)
  22. at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:148)
  23. at org.apache.spark.sql.DataFrame.save(DataFrame.scala:2066)
  24. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  25. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  26. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  27. at java.lang.reflect.Method.invoke(Method.java:498)
  28. at org.apache.spark.api.r.RBackendHandler.handleMethodCall(RBackendHandler.scala:141)
  29. at org.apache.spark.api.r.RBackendHandler.channelRead0(RBackendHandler.scala:86)
  30. at org.apache.spark.api.r.RBackendHandler.channelRead0(RBackendHandler.scala:38)
  31. at io.netty.channel.SimpleChannelIn
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement