0 Replies Latest reply: Sep 28, 2010 2:43 PM by 653147 RSS

    Processing Pattern Example not working?

    653147
      I am trying to run the Processing Pattern example for the first time. I'm using the .cmd files provided with the example.

      The server starts up without error and its logs show loading some Processing Pattern TaskProcessor classes:

      2010-09-28 14:30:47.616/4.839 Oracle Coherence GE 3.5.2/463 <Info> (thread=Thread-4, member=1): Starting dispatcher Task Dispatcher Class:com.oracle.coherence.patterns.processing.dispatchers.AbstractDispatcher
      2010-09-28 14:30:47.632/4.855 Oracle Coherence GE 3.5.2/463 <Info> (thread=SimpleEventDispatcher:Thread-2, member=1): DefaultTask Processor Definition Manager starting Class:com.oracle.coherence.patterns.processing.internal.task.DefaultTaskProcessorDefinitionManager
      2010-09-28 14:30:47.632/4.855 Oracle Coherence GE 3.5.2/463 <Info> (thread=Thread-4, member=1): Starting dispatcher Local Dispatcher Class:com.oracle.coherence.patterns.processing.dispatchers.AbstractDispatcher
      2010-09-28 14:30:47.632/4.855 Oracle Coherence GE 3.5.2/463 <Info> (thread=ReplicatedCache:ReplicatedServiceForProcessingPattern:EventDispatcher, member=1): Registering TaskProcessorDefinition TPD:{Identifier{GridTaskProcessor},Grid Task Processor,GRID} Class:com.oracle.coherence.patterns.processing.dispatchers.task.DefaultTaskDispatcher$1
      2010-09-28 14:30:47.663/4.886 Oracle Coherence GE 3.5.2/463 <Info> (thread=DistributedCache:DistributedServiceForProcessingPattern:EventDispatcher, member=1): TaskProcessorMediator inserted TPSK:{Identifier{GridTaskProcessor},1} Class:com.oracle.coherence.patterns.processing.dispatchers.task.DefaultTaskDispatcher$2
      2010-09-28 14:30:47.663/4.886 Oracle Coherence GE 3.5.2/463 <Info> (thread=DistributedCache:DistributedServiceForProcessingPattern:EventDispatcher, member=1): TaskProcessorMediator inserted TPSK:{Identifier{SingleTaskProcessor},0} Class:com.oracle.coherence.patterns.processing.dispatchers.task.DefaultTaskDispatcher$2
      2010-09-28 14:30:47.679/4.902 Oracle Coherence GE 3.5.2/463 <Info> (thread=ReplicatedCache:ReplicatedServiceForProcessingPattern:EventDispatcher, member=1): Registering TaskProcessorDefinition TPD:{Identifier{SingleTaskProcessor},Single Task Processor,SINGLE} Class:com.oracle.coherence.patterns.processing.dispatchers.task.DefaultTaskDispatcher$1

      However, when I attempt to run the example I'm getting a runtime error:

      "C:\Java\jdk1.5.0_14"\bin\java -Dtangosol.coherence.clusterport=COH_OPTSCLUSTER_PORT -Dtangosol.coherence.cacheconfig=coherence-processingpattern-cac
      he-config.xml -Dtangosol.pof.config=file:/C:\temp\coherence-incubator-examples-1.1.1.14471\resource\processingpattern\examples-pof-config.xml -Dtangos
      ol.coherence.log=C:\temp\coherence-incubator-examples-1.1.1.14471\bin\..\log\PiCalculationSample-9001.log -Dtangosol.coherence.cacheconfig=C:\temp\coh
      erence-incubator-examples-1.1.1.14471\resource\processingpattern\processing-cache-config.xml -Dtangosol.coherence.distributed.localstorage=false -cp C
      :\temp\coherence-incubator-examples-1.1.1.14471\bin\..\lib\coherence-common-1.6.1.14470.jar;C:\temp\coherence-incubator-examples-1.1.1.14471\bin\..\li
      b\coherence-commandpattern-2.6.1.14471.jar;C:\temp\coherence-incubator-examples-1.1.1.14471\bin\..\lib\coherence-functorpattern-1.3.1.14471.jar;C:\tem
      p\coherence-incubator-examples-1.1.1.14471\bin\..\lib\coherence-messagingpattern-2.6.1.14471.jar;C:\temp\coherence-incubator-examples-1.1.1.14471\bin\
      ..\lib\coherence-pushreplicationpattern-2.6.1.14471.jar;C:\temp\coherence-incubator-examples-1.1.1.14471\bin\..\lib\coherence-processingpattern-1.2.1.
      14471.jar;"C:\tools\Coherence-3.5.2"\lib\coherence.jar;C:\temp\coherence-incubator-examples-1.1.1.14471\bin\..\classes -Xms256m -Xmx256m com.oracle.c
      oherence.examples.incubator.processingpattern.task.PiCalculationSample
      Testing PI calculation

      Using the Incubator Extensible Environment for Coherence Cache Configuration
      Copyright (c) 2010, Oracle Corporation. All Rights Reserved.

      java.lang.RuntimeException: Storage is not configured
      at com.tangosol.coherence.component.util.daemon.queueProcessor.service.grid.DistributedCache$BinaryMap.onMissingStorage(DistributedCache.CDB:9
      *)*
      at com.tangosol.coherence.component.util.daemon.queueProcessor.service.grid.DistributedCache$BinaryMap.addMapListener(DistributedCache.CDB:59)

      at com.tangosol.coherence.component.util.daemon.queueProcessor.service.grid.DistributedCache$ViewMap.addMapListener(DistributedCache.CDB:1)
      at com.tangosol.coherence.component.util.SafeNamedCache.addMapListener(SafeNamedCache.CDB:12)
      at com.tangosol.coherence.component.util.SafeNamedCache.addMapListener(SafeNamedCache.CDB:47)
      at com.oracle.coherence.patterns.processing.internal.DefaultProcessingSession.<init>(DefaultProcessingSession.java:218)
      at com.oracle.coherence.examples.incubator.processingpattern.task.PiCalculationSample.executeSample(PiCalculationSample.java:75)
      at com.oracle.coherence.examples.incubator.processingpattern.task.PiCalculationSample.main(PiCalculationSample.java:56)

      The server log shows an error also after I attempt to run the example:

      *2010-09-28 14:32:54.322/131.545 Oracle Coherence GE 3.5.2/463 <D5> (thread=DistributedCache:DistributedServiceForProcessingPattern, member=1): Service DistributedServiceForProcessingPattern joined the cluster with senior service member 1*
      *2010-09-28 14:32:57.740/134.963 Oracle Coherence GE 3.5.2/463 <Info> (thread=ClientLeaseCoordinator:Thread-5, member=1): Restarting NamedCache: coherence.patterns.processing.taskprocessormediator*
      *2010-09-28 14:32:58.614/135.837 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:06.232/143.455 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:13.850/151.073 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:21.452/158.675 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:29.054/166.277 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:36.656/173.879 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:44.258/181.481 Oracle Coherence GE 3.5.2/463 <Info> (thread=PacketListenerN, member=1): Scheduled senior member heartbeat is overdue; rejoining multicast group.*
      *2010-09-28 14:33:51.766/188.989 Oracle Coherence GE 3.5.2/463 <Error> (thread=PacketListenerN, member=1): Stopping cluster due to unhandled exception: com.tangosol.net.messaging.ConnectionException: Unable to refresh sockets: [UnicastUdpSocket{State=STATE_OPEN, address:port=10.100.153.51:8088}, MulticastUdpSocket{State=STATE_OPEN, address:port=224.3.5.2:8087, InterfaceAddress=10.100.153.51, TimeToLive=4}, TcpSocketAccepter{State=STATE_OPEN, ServerSocket=10.100.153.51:8088}]; last failed socket: MulticastUdpSocket{State=STATE_OPEN, address:port=224.3.5.2:8087, InterfaceAddress=10.100.153.51, TimeToLive=4}*
      *     at com.tangosol.coherence.component.net.Cluster$SocketManager.refreshSockets(Cluster.CDB:91)*
      *     at com.tangosol.coherence.component.net.Cluster$SocketManager$MulticastUdpSocket.onInterruptedIOException(Cluster.CDB:9)*
      *     at com.tangosol.coherence.component.net.socket.UdpSocket.receive(UdpSocket.CDB:33)*
      *     at com.tangosol.coherence.component.net.UdpPacket.receive(UdpPacket.CDB:4)*
      *     at com.tangosol.coherence.component.util.daemon.queueProcessor.packetProcessor.PacketListener.onNotify(PacketListener.CDB:19)*
      *     at com.tangosol.coherence.component.util.Daemon.run(Daemon.CDB:42)*
      *     at java.lang.Thread.run(Thread.java:595)*
      Caused by: java.net.SocketTimeoutException: Receive timed out
      *     at java.net.PlainDatagramSocketImpl.receive0(Native Method)*
      *     at java.net.PlainDatagramSocketImpl.receive(PlainDatagramSocketImpl.java:136)*
      *     at java.net.DatagramSocket.receive(DatagramSocket.java:712)*
      *     at com.tangosol.coherence.component.net.socket.UdpSocket.receive(UdpSocket.CDB:20)*
      *     at com.tangosol.coherence.component.net.UdpPacket.receive(UdpPacket.CDB:4)*
      *     at com.tangosol.coherence.component.util.daemon.queueProcessor.packetProcessor.PacketListener.onNotify(PacketListener.CDB:19)*
      *     at com.tangosol.coherence.component.util.Daemon.run(Daemon.CDB:42)*
      *     at java.lang.Thread.run(Thread.java:595)*

      Has anyone had similar experiences? Any advice to help me understand and get this going would be appreciated.

      Thanks !!