我使用sqoop将表从mysql导入到hdfs location /user/cloudera/table1,现在应该使用什么命令将该表加载到pyspark代码中。我只是像下面这样写简单的代码。SparkConf().setAppName("Spark Count") data = code here to import table from hdfs
你能告诉我错误是从哪里发生的吗,以及如何解决这个错误。提前谢谢。./ --connect jdbc:mysql://localhost/mydb --username root --password yashu123 --table shipper --m 1 --Consider using -P instead.
2017-02-07 10:30:00,349 INFO [main] manager.MySQLManager: Preparing to use a MySQLAccording