Coherence 12 , Not able to submit the task to Cluster member.
Hi,
I am working on coherence upgrade from 3.7 to 12.2.1. I am using the incubator jars coherence-processingpattern, and coherence-common (version 12.3.1).
I am facing issue, when calling the method SubmissionOutcome.get() (Class : com.oracle.coherence.patterns.processing.SubmissionOutcome).
SubmissionOutcome outcome = processingSession.submit( task, submissionConfiguration, taskId, retentionPolicy, taskListener ) of com.oracle.coherence.patterns.processing.ProcessingSession.
Above method is return the value, but when I call outcome.get() , system is not returning the control.
Exception:
2016-07-29 13:38:05.937/2053.103 Oracle Coherence GE 12.2.1.0.0 <Warning> (thread=PacketPublisher, member=3): Experienced a 13604 ms communication delay (probable remote GC) with Member(Id=1, Timestamp=2016-07-29 12:36:48.706, Address=10.176.136.196:42222, MachineId=46614, Location=site:in.oracle.com,machine:SADAPA-IN,process:1336,member:XYZ_MEMBERNAME, Role=WeblogicServer); 84 packets rescheduled, PauseRate=0.0067, Threshold=2080
2016-07-29 13:54:37.430/3044.578 Oracle Coherence GE 12.2.1.0.0 <D6> (thread=NonBlockingTimer, member=3): DaemonPool "Proxy:TcpAcceptorPool" increasing the pool size from 1 to 2 thread(s) due to the pool being shaken
2016-07-29 13:54:47.431/3054.579 Oracle Coherence GE 12.2.1.0.0 <D6> (thread=NonBlockingTimer, member=3): DaemonPool "Proxy:TcpAcceptorPool" decreasing the pool size from 2 to 1 thread(s) due to the pool being underutilized
Can you anyone suggestion if I am missing any configuration or any steps.
Really appreciate your help in resolving the issue.
Note: Same configuration is working with Coherence 3.7.1.0 with some namespace changes.
Configuration is mentioned below.
Configuration:
Agent :
<coherence xml-override="/tangosol-coherence-override.xml">
<cluster-config>
<member-identity>
<cluster-name>XYZ_CLUSTER</cluster-name>
<member-name>XYZ_MEMBERNAME</member-name>
</member-identity>
<unicast-listener>
<address>localhost</address>
<port>8088</port>
<port-auto-adjust>false</port-auto-adjust>
<well-known-addresses>
<socket-address id="1">
<address>localhost</address>
<port>8088</port>
</socket-address>
</well-known-addresses>
</unicast-listener>
</cluster-config>
<logging-config>
<destination>stdout</destination>
<severity-level>3</severity-level>
</logging-config>
</coherence>
Client :
<coherence xml-override="/tangosol-coherence-override.xml">
<cluster-config>
<member-identity>
<cluster-name>XYZ_CLUSTER</cluster-name>
<member-name>XYZ_CLIENT</member-name>
</member-identity>
<unicast-listener>
<well-known-addresses>
<socket-address id="1">
<address>localhost</address>
<port>8088</port>
</socket-address>
</well-known-addresses>
</unicast-listener>
</cluster-config>
<logging-config>
<destination system-property="tangosol.coherence.log">stdout</destination>
<severity-level system-property="tangosol.coherence.log.level">9</severity-level>
</logging-config>
</coherence>
Agent:
<!DOCTYPE cache-config SYSTEM "cache-config.dtd">
<cache-config
xmlns:processing="class://com.oracle.coherence.patterns.processing.config.xml.ProcessingPatternNamespaceHandler"
xmlns:element="class://com.oracle.coherence.common.namespace.preprocessing.XmlPreprocessingNamespaceHandler"
element:introduce-cache-config="coherence-cache-config.xml">
<processing:cluster-config pof="true">
<processing:dispatchers>
<processing:task-dispatcher displayname="Task Dispatcher" priority="1">
<processing:composite-policy>
<processing:attribute-match-policy />
<processing:round-robin-policy />
</processing:composite-policy>
</processing:task-dispatcher>
</processing:dispatchers>
<!-- MAKE SURE THAT ALL IDs ARE UNIQUE ACROSS THE CLUSTER, OR THE MEMBER WILL NOT PARTICIPATE IN GRID PROCESSING -->
<processing:taskprocessors>
<processing:taskprocessordefinition id="CycleRunnableTaskProcessor" displayname="Cycle Runnable Task Processor" type="SINGLE" taskpattern="SingleTask">
<processing:default-taskprocessor id="Cycle Runnable Task Processor" threadpoolsize="10"></processing:default-taskprocessor>
<processing:attribute name="type">runnable</processing:attribute>
</processing:taskprocessordefinition>
<processing:taskprocessordefinition id="CycleResumableTaskProcessor" displayname="Cycle Resumable Task Processor" type="SINGLE" taskpattern="SingleTask">
<processing:default-taskprocessor id="Cycle Resumable Task Processor" threadpoolsize="5"></processing:default-taskprocessor>
<processing:attribute name="type">resumable</processing:attribute>
</processing:taskprocessordefinition>
</processing:taskprocessors>
</processing:cluster-config>
<!-- ============================ -->
<!-- Map Caches to the NearScheme -->
<!-- ============================ -->
<caching-scheme-mapping>
<cache-mapping>
<cache-name>CORE</cache-name>
<scheme-name>SampleNearScheme</scheme-name>
</cache-mapping>
<cache-mapping>
<cache-name>CYCLE</cache-name>
<scheme-name>SampleNearScheme</scheme-name>
</cache-mapping>
</caching-scheme-mapping>
<caching-schemes>
<!-- ===================== -->
<!-- Local In-memory Cache -->
<!-- ===================== -->
<local-scheme>
<scheme-name>SampleMemoryScheme</scheme-name>
</local-scheme>
<!-- ================================== -->
<!-- Size limited Local In-memory Cache -->
<!-- ================================== -->
<local-scheme>
<scheme-name>SampleMemoryLimitedScheme</scheme-name>
<low-units>10</low-units>
<high-units>32000</high-units>
</local-scheme>
<!-- =========================== -->
<!-- Distributed In-memory Cache -->
<!-- =========================== -->
<distributed-scheme>
<scheme-name>SamplePartitionedScheme</scheme-name>
<backing-map-scheme>
<local-scheme>
<scheme-ref>SampleMemoryScheme</scheme-ref>
</local-scheme>
</backing-map-scheme>
</distributed-scheme>
<!-- ======================== -->
<!-- Cache Cluster Definition -->
<!-- ======================== -->
<near-scheme>
<scheme-name>SampleNearScheme</scheme-name>
<front-scheme>
<local-scheme>
<scheme-ref>SampleMemoryLimitedScheme</scheme-ref>
</local-scheme>
</front-scheme>
<back-scheme>
<distributed-scheme>
<scheme-ref>SamplePartitionedScheme</scheme-ref>
</distributed-scheme>
</back-scheme>
</near-scheme>
</caching-schemes>
</cache-config>
Client:
<!DOCTYPE cache-config SYSTEM "cache-config.dtd">
<cache-config
xmlns:processing="class://com.oracle.coherence.patterns.processing.config.xml.ProcessingPatternNamespaceHandler"
xmlns:element="class://com.oracle.coherence.common.namespace.preprocessing.XmlPreprocessingNamespaceHandler"
element:introduce-cache-config="coherence-cache-config.xml">
<processing:cluster-config pof="true"/>
<!-- ============================ -->
<!-- Map Caches to the NearScheme -->
<!-- ============================ -->
<caching-scheme-mapping>
<cache-mapping>
<cache-name>CYCLE</cache-name>
<scheme-name>SampleNearScheme</scheme-name>
</cache-mapping>
</caching-scheme-mapping>
<caching-schemes>
<!-- ===================== -->
<!-- Local In-memory Cache -->
<!-- ===================== -->
<local-scheme>
<scheme-name>SampleMemoryScheme</scheme-name>
</local-scheme>
<!-- ================================== -->
<!-- Size limited Local In-memory Cache -->
<!-- ================================== -->
<local-scheme>
<scheme-name>SampleMemoryLimitedScheme</scheme-name>
<low-units>10</low-units>
<high-units>32000</high-units>
</local-scheme>
<!-- =========================== -->
<!-- Distributed In-memory Cache -->
<!-- =========================== -->
<distributed-scheme>
<scheme-name>SamplePartitionedScheme</scheme-name>
<backing-map-scheme>
<local-scheme>
<scheme-ref>SampleMemoryScheme</scheme-ref>
</local-scheme>
</backing-map-scheme>
</distributed-scheme>
<!-- ======================== -->
<!-- Cache Cluster Definition -->
<!-- ======================== -->
<near-scheme>
<scheme-name>SampleNearScheme</scheme-name>
<front-scheme>
<local-scheme>
<scheme-ref>SampleMemoryLimitedScheme</scheme-ref>
</local-scheme>
</front-scheme>
<back-scheme>
<distributed-scheme>
<scheme-ref>SamplePartitionedScheme</scheme-ref>
</distributed-scheme>
</back-scheme>
</near-scheme>
</caching-schemes>
</cache-config>