Работа Pyspark, которая обычно занимает 45 секунд. Иногда в журналах показывалось следующее сообщение:
20/04/25 01:33:43 WARN ControlConnection: Found invalid row in system.peers: [peer=/IP_ADDRESS, rpc_address=null, host_id=null, data_center=null, rack=null]. This is likely a gossip or snitch issue, this host will be ignored.
20/04/25 01:34:03 WARN Utils: Service 'SparkUI' could not bind on port 4040. Attempting port 4041.
20/04/25 01:34:03 WARN DefaultPromise: An exception was thrown by com.datastax.driver.core.Connection$1.operationComplete()
java.lang.NullPointerException
at io.netty.channel.group.DefaultChannelGroup.add(DefaultChannelGroup.java:146)
at io.netty.channel.group.DefaultChannelGroup.add(DefaultChannelGroup.java:42)
at com.datastax.driver.core.Connection$1.operationComplete(Connection.java:162)
at com.datastax.driver.core.Connection$1.operationComplete(Connection.java:149)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:507)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:481)
at io.netty.util.concurrent.DefaultPromise.access$000(DefaultPromise.java:34)
at io.netty.util.concurrent.DefaultPromise$1.run(DefaultPromise.java:431)
at io.netty.util.concurrent.GlobalEventExecutor$TaskRunner.run(GlobalEventExecutor.java:233)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Я искал много вещей, но до сих пор не получил никакой помощи.
Спасибо в авансовый