spark-shell --packages com.databricks:spark-csv_2.11:1.5.0
spark > val flightData2015 = spark.read.option("inferSchema", "true").option("header","true").csv("/Users/me/Desktop/2015-summary.csv")
Я получаю это исключение .
java.io.IOException: Не удалось подключиться к /192.168.1.112:51351 в org.apache.spark.network.client.TransportClientFactory.createClient (TransportClientFactory.java:232) в org.apache.spark.network.client.TransportClientFactory.createClient (TransportClientFactory.java:182) в org.apache.sptyent.park.park.park.NettyRpcEnv.scala: 366) в org.apache.spark.rpc.netty.NettyRpcEnv.openChannel (NettyRpcEnv.scala: 332) в org.apache.spark.util.Utils $ .doFetchFile (Utils.scala: 654) в org.apache.spark.util.Utils $ .fetchFile (Utils.scala: 480) в org.apache.spark.executor.Executor $$ anonfun $ org $ apache $ spark $ executor $ Executor $$ updateDependencies $ 5.apply (Executor.scala: 696) at org.apache.spark.executor.Executor $$ anonfun $ org $ apache $ spark $ executor $ Executor $$ updateDependencies $ 5.apply (Executor.scala: 688) в scala.collection.TraversableLike $ WithFilter $$ anonfun$ foreach $ 1.apply (TraversableLike.scala: 733) на scala.collection.Iterator $ class.foreach (Iterator.scala: 893) на scala.collection.AbstractIterator.foreach (Iterator.scala: 1336) на scala.collection.IterableLike $ class.foreach (IterableLike.scala: 72) на scala.collection.AbstractIterable.foreach (Iterable.scala: 54) в scala.collection.TraversableLike $ WithFilter.foreach (TraversableLike.scala: 732) в org.apache.spark.executor.Executor.org $ apache $ spark $ executor $ Executor $$ updateDependencies (Executor.scala: 688) в org.apache.spark.executor.Executor $ TaskRunner.run (Executor.scala: 308) в java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1149) в java.util.concur.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:624) в java.lang.Thread.run (Thread.java:748) Причина: io.netty.channel.AbstractChannel $ AnnotatedConnectException: Тайм-аут операции: /192.168.1.112:51351 в sun.nio.ch.SocketChannelImpl.checkConnect (собственный метод) в sun.nio.ch.SocketChannelImpl.finishConnect (SocketChannelImpl.java:717) в io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect (NioSocketChannel.java:257) по адресу io.netty.channel.nio.AbstractNioChannel $ AbstractNioUnsafe.finishConnect (AbstractNioChannel.java:291) по адресу io.netty.channel.nio.NioEventLava.Eo.Nej.JeEпо адресу io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized (NioEventLoop.java:566) по адресу io.netty.channel.nio.NioEventLoop.processSelectedKeys (NioEventLoop.java:480) по адресу io.netty.NioN(NioEventLoop.java:442) в io.netty.util.concurrent.SingleThreadEventExecutor $ 2.run (SingleThreadEventExecutor.java:131) в io.netty.util.concurrent.DefaultThreadFactory $ DefaultRunnableDecorator.run (по умолчанию). Еще 1