Uploaded image for project: 'JGroups'
  1. JGroups
  2. JGRP-2531

failed handling message java.nio.channels.NotYetConnectedException: null after upgrade from jgroups-5.0.4 to jgroups-5.1.5

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 5.2, 5.1.9, 4.2.16, 4.2.18
    • 5.1.5
    • None

      we use jgoups TCP_NIO2 protocol stacks

      after we upgrade to jgroups 5.1.5 throw following exception in our dev env.

      21-02-25 14:42:50.357 WARN [NioConnection.Reader [172.30.1.161:7802]-27,shared=common TCP_NIO2.warn:120]failed handling message
      java.nio.channels.NotYetConnectedException: null
      at java.base/sun.nio.ch.SocketChannelImpl.ensureOpenAndConnected(SocketChannelImpl.java:178)
      at java.base/sun.nio.ch.SocketChannelImpl.beginRead(SocketChannelImpl.java:312)
      at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:347)
      at org.jgroups.nio.Buffers.readLengthAndData(Buffers.java:128)
      at org.jgroups.blocks.cs.NioConnection._receive(NioConnection.java:247)
      at org.jgroups.blocks.cs.NioConnection$Reader._run(NioConnection.java:483)
      at org.jgroups.blocks.cs.NioConnection$Reader.run(NioConnection.java:471)
      at java.base/java.lang.Thread.run(Thread.java:834)
      21-02-25 14:42:53.348 WARN [main AbstractJGroupsMessenger.viewAccepted:228][system.messenger.common]jgroups discover[TIMEOUT]: 1, elapsed time: 6293 ms
      21-02-25 14:43:02.501 WARN [hedging.persister.database AbstractJournaler.loop:369][hedging.persister.database]failed to seek: 1364436024374509085
      21-02-25 14:43:02.513 WARN [holding.persister.database AbstractJournaler.loop:369][holding.persister.database]failed to seek: 1348674154999584257
      21-02-25 14:43:02.567 WARN [pricing.persister.redis AbstractJournaler.loop:369][pricing.persister.redis]failed to seek: 1364471253746595885
      21-02-25 14:43:02.569 WARN [pricing.persister.database AbstractJournaler.loop:369][pricing.persister.database]failed to seek: 1364471253746595885
      21-02-25 14:43:02.605 WARN [trading.persister.database.0 AbstractJournaler.loop:369][trading.persister.database.0]failed to seek: 1364234418297976373
      21-02-25 14:43:02.610 WARN [trading.persister.database.1 AbstractJournaler.loop:369][trading.persister.database.1]failed to seek: 1364234418297975861
      21-02-25 14:43:02.645 WARN [dealing.persister.database AbstractJournaler.loop:369][dealing.persister.database]failed to seek: 1364436024417785365
      21-02-25 14:43:02.674 WARN [customer.persister.database AbstractJournaler.loop:369][customer.persister.database]failed to seek: 1364234470919554125
      21-02-25 14:43:02.704 WARN [courier.mail.customer.pump AbstractJournaler.loop:369][courier.mail.customer.pump]failed to seek: 1361051105273893941
      21-02-25 14:43:02.720 WARN [courier.push.customer.pump AbstractJournaler.loop:369][courier.push.customer.pump]failed to seek: 1361051105273893941
      21-02-25 14:43:11.859 WARN [NioConnection.Reader [172.30.1.161:7805]-38,shared=common TCP_NIO2.warn:120]failed handling message
      java.nio.channels.NotYetConnectedException: null
      at java.base/sun.nio.ch.SocketChannelImpl.ensureOpenAndConnected(SocketChannelImpl.java:178)
      at java.base/sun.nio.ch.SocketChannelImpl.beginRead(SocketChannelImpl.java:312)
      at java.base/sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:347)
      at org.jgroups.nio.Buffers.readLengthAndData(Buffers.java:128)
      at org.jgroups.blocks.cs.NioConnection._receive(NioConnection.java:247)
      at org.jgroups.blocks.cs.NioConnection$Reader._run(NioConnection.java:483)
      at org.jgroups.blocks.cs.NioConnection$Reader.run(NioConnection.java:471)
      at java.base/java.lang.Thread.run(Thread.java:834)

       

      jgroups properties

      <config xmlns="urn:org:jgroups" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups.xsd"
      version="5.0.4.Final">

      <TCP_NIO2
      recv_buf_size="2M"
      send_buf_size="2M"
      max_bundle_size="64K"
      max_send_buffers="32"
      sock_conn_timeout="3000"
      reader_idle_time="300000"
      enable_diagnostics="false"
      thread_pool.enabled="true"
      thread_naming_pattern="cl"
      logical_addr_cache_max_size="100000"
      logical_addr_cache_expiration="3600000"

      bind_port="${jgroups.tcp.bind.port}"
      port_range="${jgroups.tcp.port.range}"
      thread_pool.min_threads="${jgroups.threads.min}"
      thread_pool.max_threads="${jgroups.threads.max}"
      thread_pool.keep_alive_time = "${jgroups.threads.ttl}"/>

      <TCPPING
      async_discovery="true"
      port_range="${jgroups.tcp.port.range}"
      initial_hosts="${jgroups.tcp.initial.hosts}"
      async_discovery_use_separate_thread_per_request="true"/>

      <MERGE3 min_interval="10000" max_interval="30000"/>
      <!-- <FD_SOCK/> --><FD_ALL3 timeout="30000"/>
      <VERIFY_SUSPECT timeout="3000"/>
      <!-- <BARRIER /> -->

      <pbcast.NAKACK2 use_mcast_xmit="false" xmit_interval="300" xmit_table_max_compaction_time="30000"/>
      <UNICAST3 xmit_interval="300" xmit_table_max_compaction_time="30000"/>

      <pbcast.STABLE desired_avg_gossip="60000" max_bytes="4M"/>
      <pbcast.GMS join_timeout="5000" max_join_attempts="0"/>

      <UFC max_credits="6M" min_threshold="0.4"/>
      <MFC max_credits="6M" min_threshold="0.4"/>
      <FRAG2 frag_size="60K"/>

      <!-RSVP resend_interval="2000" timeout="10000"/->
      <!-- <pbcast.STATE_TRANSFER/> -->
      </config>

       

        1. JGroupsTest.java
          4 kB
          Bela Ban
        2. test-jgroups-tcp.xml
          1 kB
          Bela Ban

              rhn-engineering-bban Bela Ban
              leonchen83 Baoyi Chen (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

                Created:
                Updated:
                Resolved: