> %pyspark from pyspark.ml.feature import Tokenizer from
> pyspark.sql.functions import col, udf from pyspark.sql.types import
> IntegerType
Я пытаюсь запустить этот блокнот zeppelin, и это первый блок кода, и я получаю это значительное сообщение об ошибке.
java.net.ConnectException: Тайм-аут операции на java.base / sun.nio.ch.Net.connect0 (собственный метод) на java.base / sun.nio.ch.Net.connect(Net.java:493) в java.base / sun.nio.ch.Net.connect (Net.java:482) в java.base / sun.nio.ch.NioSocketImpl.connect (NioSocketImpl.java:588) вjava.base / java.net.SocksSocketImpl.connect (SocksSocketImpl.java:339) в java.base / java.net.Socket.connect (Socket.java:585) в org.apache.thrift.transport.TSocket.open (TSocket.java:182) в org.apache.zeppelin.interpreter.remote.ClientFactory.create (ClientFactory.java:51) в org.apache.zeppelin.interpreter.remote.ClientFactory.create (ClientFactory.java:37) в org.apache.commons.pool2.BasePooledObjectFactory.makeObject (BasePooledObjectFactory.java:60) в org.apache.commons.pool2.impl.GenericObjectPool.create (GenericObjectPool.java:861) в org.apachebject.Po. .borrowObject (GenericObjectPool.java:435) в org.apache.commons.pool2.impl.GenericObjectPool.borrowObject (GenericObjectПул.apache.zeppelin.interpreter.remote.RemoteInterpreter.interpret (RemoteInterpreter.java:228) в org.apache.zeppelin.notebook.Paragraph.jobRun (Paragraph.java:449) в org.apache.zeppelin.scheduler.Jobrun(Job.java:188) в org.apache.zeppelin.scheduler.RemoteScheduler $ JobRunner.run (RemoteScheduler.java:315) в java.base / java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:515) в java.base / java.util.concurrent.FutureTask.run (FutureTask.java:264) в java.base / java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.javab4)java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1128) в java.base / java.util.concurrent.ThreadPoolExecutor $ Worker.run (потокPoolExecutor.java:628) в java.base / java.lang.Thread.run (Thread.java:830) java.net.ConnectException: истекло время ожидания операции в java.base / sun.nio.ch.Net.connect0 (NativeМетод) в java.base / sun.nio.ch.Net.connect (Net.java:493) в java.base / sun.nio.ch.Net.connect (Net.java:482) в java.base / sun.nio.ch.NioSocketImpl.connect (NioSocketImpl.java:588) в java.base / java.net.SocksSocketImpl.connect (SocksSocketImpl.java:339) в java.base / java.net.Socket.connect (Socket.java: 585) в org.apache.thrift.transport.TSocket.open (TSocket.java:182) в org.apache.zeppelin.interpreter.remote.ClientFactory.create (ClientFactory.java:51) в org.apache.zeppelin. interpreter.remote.ClientFactory.create (ClientFactory.java:37) в org.apache.commons.pool2.BasePooledObjectFactory.makeObject (BasePooledObjectFactory.java:60) в org.apache.commons.pool2.impl.GenericObjectPol. Java: 861) в org.apache.commons.pool2.impl.GenericObjectPool.borrowObject (GenericObjectPool.java:435) в org.apache.commons.pool2.impl.GenericObjectPool.borrowObject (GenericObjectPool.java:363) в org.apache.zeppelin.interpreter.remote.RemoteInterpreterProcess.getClient (RemoteInterpreterProcess.java:62) в org.apacheinterm. RemoteInterpreterProcess.java:133) в org.apache.zeppelin.interpreter.remote.RemoteInterpreter.interpret (RemoteInterpreter.java:228) в org.apache.zeppelin.notebook.Paragraph.jobRun (Paragraph.java:449) в org.ap.zeppelin.scheduler.Job.run (Job.java:188) в org.apache.zeppelin.scheduler.RemoteScheduler $ JobRunner.run (RemoteScheduler.java:315)в java.base / java.util.concurrent.Executors $ RunnableAdapter.call (Executors.java:515) в java.base / java.util.concurrent.FutureTask.run (FutureTask.java:264) в java.base / java.util.concurrent. $ Worker.run (ThreadPoolExecutor.java:628) в java.base / java.lang.Thread.run (Thread.java:830)