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>