java.lang.IllegalStateException: RpcEnv already stopped.

talendforge.org | 7 months ago
tip
Click on the to mark the solution that helps you, Samebug will learn from it.
As a community member, you’ll be rewarded for you help.

Root Cause Analysis

  1. java.net.ConnectException

    Connection timed out: connect

    at io.netty.channel.AbstractChannelHandlerContext.fireChannelUnregistered()
  2. Netty
    SingleThreadEventExecutor.runAllTasks
    1. io.netty.channel.AbstractChannelHandlerContext.fireChannelUnregistered(AbstractChannelHandlerContext.java:144)
    2. io.netty.channel.ChannelInboundHandlerAdapter.channelUnregistered(ChannelInboundHandlerAdapter.java:53)
    3. io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered(AbstractChannelHandlerContext.java:158)
    4. io.netty.channel.AbstractChannelHandlerContext.fireChannelUnregistered(AbstractChannelHandlerContext.java:144)
    5. io.netty.channel.ChannelInboundHandlerAdapter.channelUnregistered(ChannelInboundHandlerAdapter.java:53)
    6. io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered(AbstractChannelHandlerContext.java:158)
    7. io.netty.channel.AbstractChannelHandlerContext.fireChannelUnregistered(AbstractChannelHandlerContext.java:144)
    8. io.netty.channel.DefaultChannelPipeline.fireChannelUnregistered(DefaultChannelPipeline.java:739)
    9. io.netty.channel.AbstractChannel$AbstractUnsafe$8.run(AbstractChannel.java:659)
    10. io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:328)
    10 frames
  3. Java RT
    Socket.connect
    1. java.net.DualStackPlainSocketImpl.connect0(Native Method)
    2. java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79)
    3. java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
    4. java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
    5. java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
    6. java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
    7. java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
    8. java.net.Socket.connect(Socket.java:589)
    8 frames
  4. PostgreSQL JDBC Driver
    ConnectionFactoryImpl.openConnectionImpl
    1. org.postgresql.core.PGStream.<init>(PGStream.java:61)
    2. org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:129)
    2 frames
  5. org.apache.spark
    NettyRpcHandler.connectionTerminated
    1. org.apache.spark.rpc.netty.Dispatcher.postMessage(Dispatcher.scala:159)
    2. org.apache.spark.rpc.netty.Dispatcher.postToAll(Dispatcher.scala:109)
    3. org.apache.spark.rpc.netty.NettyRpcHandler.connectionTerminated(NettyRpcEnv.scala:630)
    3 frames
  6. Spark
    TransportChannelHandler.channelUnregistered
    1. org.apache.spark.network.server.TransportRequestHandler.channelUnregistered(TransportRequestHandler.java:94)
    2. org.apache.spark.network.server.TransportChannelHandler.channelUnregistered(TransportChannelHandler.java:89)
    2 frames
  7. Netty
    AbstractChannelHandlerContext.invokeChannelUnregistered
    1. io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered(AbstractChannelHandlerContext.java:158)
    2. io.netty.channel.AbstractChannelHandlerContext.fireChannelUnregistered(AbstractChannelHandlerContext.java:144)
    3. io.netty.channel.ChannelInboundHandlerAdapter.channelUnregistered(ChannelInboundHandlerAdapter.java:53)
    4. io.netty.channel.AbstractChannelHandlerContext.invokeChannelUnregistered(AbstractChannelHandlerContext.java:158)
    4 frames
  8. org.apache.spark
    ResolvedDataSource$.apply
    1. org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$$anonfun$getConnector$1.apply(JDBCRDD.scala:188)
    2. org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$$anonfun$getConnector$1.apply(JDBCRDD.scala:181)
    3. org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$.resolveTable(JDBCRDD.scala:121)
    4. org.apache.spark.sql.execution.datasources.jdbc.JDBCRelation.<init>(JDBCRelation.scala:91)
    5. org.apache.spark.sql.execution.datasources.jdbc.DefaultSource.createRelation(DefaultSource.scala:60)
    6. org.apache.spark.sql.execution.datasources.ResolvedDataSource$.apply(ResolvedDataSource.scala:158)
    6 frames
  9. Spark Project SQL
    DataFrameReader.load
    1. org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:119)
    1 frame
  10. local_project.hawqload_0_1
    HawqLoad.main
    1. local_project.hawqload_0_1.HawqLoad.tJDBCInput_1Process(HawqLoad.java:1489)
    2. local_project.hawqload_0_1.HawqLoad.run(HawqLoad.java:1950)
    3. local_project.hawqload_0_1.HawqLoad.runJobInTOS(HawqLoad.java:1754)
    4. local_project.hawqload_0_1.HawqLoad.main(HawqLoad.java:1641)
    4 frames