1 Reply Latest reply on Aug 18, 2016 5:16 AM by SrikanthAdapa-Oracle

    Coherence 12 , Not able to submit the task to Cluster member.

    SrikanthAdapa-Oracle

      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>