You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@ignite.apache.org by Saurabh Sharma <sa...@nviz.com> on 2016/02/21 14:50:09 UTC

Exception during streams processing

Hi,

I am reading streams from Kafka topic (using ConsumerConnector with a thread count 4). I observed that stream processing is very slow and sometimes I am getting following exception. Could you please let me know what could be the reason of this slow processing.

I am trying to read a log file with a record count of 200K.

SEVERE: Failed to request nodes addresses.
java.net.SocketException: bad argument for IP_MULTICAST_IF: address not bound to any interface
                at java.net.TwoStacksPlainDatagramSocketImpl.socketSetOption(Native Method)
                at java.net.AbstractPlainDatagramSocketImpl.setOption(AbstractPlainDatagramSocketImpl.java:309)
                at java.net.MulticastSocket.setInterface(MulticastSocket.java:467)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.requestAddresses(TcpDiscoveryMulticastIpFinder.java:544)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.access$700(TcpDiscoveryMulticastIpFinder.java:80)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder$AddressReceiver.body(TcpDiscoveryMulticastIpFinder.java:755)
                at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62)


Thanks

Re: Exception during streams processing

Posted by Roman Shtykh <rs...@yahoo.com>.

btw, do you have the same issues on starting a basic Ignite setup (without stream processing)?

Can you share your /etc/hosts and the server log with more details (particularly "TcpDiscoveryNode" parts)?

With this information, I think you can get some more advice.


-Roman





On Monday, February 22, 2016 12:03 AM, Roman Shtykh <rs...@yahoo.com> wrote:
Hi Saurabh,

As a quick fix, will setting "-Djava.net.preferIPv4Stack=true" help?

-Roman





On Sunday, February 21, 2016 10:50 PM, Saurabh Sharma <sa...@nviz.com> wrote:




Hi,

I am reading streams from Kafka topic (using ConsumerConnector with a thread count 4). I observed that stream processing is very slow and sometimes I am getting following exception. Could you please let me know what could be the reason of this slow processing.

I am trying to read a log file with a record count of 200K.

SEVERE: Failed to request nodes addresses.
java.net.SocketException: bad argument for IP_MULTICAST_IF: address not bound to any interface
                at java.net.TwoStacksPlainDatagramSocketImpl.socketSetOption(Native Method)
                at java.net.AbstractPlainDatagramSocketImpl.setOption(AbstractPlainDatagramSocketImpl.java:309)
                at java.net.MulticastSocket.setInterface(MulticastSocket.java:467)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.requestAddresses(TcpDiscoveryMulticastIpFinder.java:544)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.access$700(TcpDiscoveryMulticastIpFinder.java:80)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder$AddressReceiver.body(TcpDiscoveryMulticastIpFinder.java:755)
                at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62)


Thanks

Re: Exception during streams processing

Posted by Roman Shtykh <rs...@yahoo.com>.

Hi Saurabh,

As a quick fix, will setting "-Djava.net.preferIPv4Stack=true" help?

-Roman




On Sunday, February 21, 2016 10:50 PM, Saurabh Sharma <sa...@nviz.com> wrote:




Hi,
 
I am reading streams from Kafka topic (using ConsumerConnector with a thread count 4). I observed that stream processing is very slow and sometimes I am getting following exception. Could you please let me know what could be the reason of this slow processing.
 
I am trying to read a log file with a record count of 200K.
 
SEVERE: Failed to request nodes addresses.
java.net.SocketException: bad argument for IP_MULTICAST_IF: address not bound to any interface
                at java.net.TwoStacksPlainDatagramSocketImpl.socketSetOption(Native Method)
                at java.net.AbstractPlainDatagramSocketImpl.setOption(AbstractPlainDatagramSocketImpl.java:309)
                at java.net.MulticastSocket.setInterface(MulticastSocket.java:467)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.requestAddresses(TcpDiscoveryMulticastIpFinder.java:544)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder.access$700(TcpDiscoveryMulticastIpFinder.java:80)
                at org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder$AddressReceiver.body(TcpDiscoveryMulticastIpFinder.java:755)
                at org.apache.ignite.spi.IgniteSpiThread.run(IgniteSpiThread.java:62)
 
 
Thanks

Re: Exception during streams processing

Posted by vkulichenko <va...@gmail.com>.

Hi Saurabh,

Is multicast enabled in your network? If it doesn't work for you, you can
switch to static IP configuration to create the cluster [1].

Let us know if it helps.

[1]
https://apacheignite.readme.io/v1.5/docs/cluster-config#static-ip-based-discovery

-Val



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Exception-during-streams-processing-tp3126p3143.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.