Работа Pyspark, которая обычно занимает 45 секунд. иногда случайно застревает

Question

Работа 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)

Я искал много вещей, но до сих пор не получил никакой помощи.

Спасибо в авансовый