If I run the script below: val results12 = sqlContext.sql("SELECT * FROM products")
Perception sport swifty 9.5 pro#
| 373 | 17 | Perfect Fitness Multi Gym Pro | | 39.99 | | | 365 | 17 | Perfect Fitness Perfect Rip Deck | | 59.99 | | | 362 | 17 | Perfect Fitness Perfect Ab Strap Pro | | 29.99 | | | product_id | product_category_id | product_name | product_description | product_price | product_image | The expected result from mysql is as below for your reference: mysql> select * from products where product_name like 'Per%' It would be greatly appreciated if someone can tell me what's wrong here? : empty StringĪt (FloatingDecimal.java:1842)Īt (FloatingDecimal.java:122) Presumably there should be 12 records as shown in its mysql data source.ġ8/03/05 21:02:48 INFO HadoopRDD: Input split: I have a dataframe generated through sqlContext.sql operation in Scala. I've never heard of this but it happens here:
0 kommentar(er)
