Infinispan Cache DSL translator: materialization incomplete results during view's loading

<?xml version="1.0" encoding="UTF-8"?>
<vdb name="jdg-remote" version="1">
  <description>For testing of materialized views</description>
  <property name ="lib" value ="org.jboss.qe.jdg.pojos"></property>
  <model name="jdgSource">
    <source name="jdgSource" translator-name="jdg-override"
      connection-jndi-name="java:/jdg-mat-ds" />
      <metadata type="DDL"><![CDATA[
        CREATE FOREIGN TABLE CustomerReport(
        customerId integer not null OPTIONS (SEARCHABLE 'Searchable', NATIVE_TYPE 'int'),
        totalAmount integer,
        CONSTRAINT PK_ID PRIMARY KEY(customerId)
        ) OPTIONS (NAMEINSOURCE '${db.table.prefix}jdg-mat', UPDATABLE TRUE);]]>
      </metadata>
  </model>
  <model name="h2Source">
    <source name="h2Source" translator-name="h2" connection-jndi-name="java:/h2-ds" />
  </model>
  <model name="View" type="VIRTUAL">
    <metadata type="DDL"><![CDATA[
        CREATE VIEW external_long_ttl (
           customerId integer NOT NULL,
           totalAmount integer
        ) OPTIONS (MATERIALIZED 'TRUE',
            MATERIALIZED_TABLE 'jdgSource.CustomerReport',
            "teiid_rel:ALLOW_MATVIEW_MANAGEMENT" 'true',
            "teiid_rel:MATVIEW_LOAD_SCRIPT" 'INSERT INTO jdgSource.CustomerReport(customerId,totalAmount) SELECT c.id AS customerId, CONVERT(SUM(o.amount),integer) AS totalAmount FROM DV_MATVIEWS_CUSTOMERS c INNER JOIN DV_MATVIEWS_ORDERS o ON c.id = o.customer_id GROUP BY c.id;',
            "teiid_rel:MATVIEW_STATUS_TABLE" 'h2Source.DB.PUBLIC.DV_MATVIEWS_STATUSTABLE',
            "teiid_rel:MATVIEW_BEFORE_LOAD_SCRIPT" 'execute jdgSource.native(''truncate cache'');',
            "teiid_rel:MATVIEW_AFTER_LOAD_SCRIPT" 'execute jdgSource.native(''swap cache names'');',
            "teiid_rel:MATVIEW_ONERROR_ACTION" 'WAIT',
            "teiid_rel:MATVIEW_TTL" 10000
        )
            AS SELECT c.id AS customerId, CONVERT(SUM(o.amount),integer) AS totalAmount FROM DV_MATVIEWS_CUSTOMERS c INNER JOIN DV_MATVIEWS_ORDERS o ON c.id = o.customer_id GROUP BY c.id;
     ]]>
    </metadata>
  </model>
  <translator name="jdg-override" type="infinispan-cache-dsl">
    <property name="SupportsDirectQueryProcedure" value="true" />
  </translator>
</vdb>

<resource-adapter id="jdg-mat">
    <module slot="main" id="org.jboss.teiid.resource-adapter.infinispan.dsl"/>
    <connection-definitions>
        <connection-definition class-name="org.teiid.resource.adapter.infinispan.dsl.InfinispanManagedConnectionFactory" jndi-name="java:/jdg-mat-ds" enabled="true" pool-name="jdg-mat">
            <config-property name="ProtobufDefinitionFile">
                /org/jboss/qe/jdg/remote/protobuf/CustomerReport.proto
            </config-property>
            <config-property name="AliasCacheName">
                ${db.table.prefix}jdg-alias
            </config-property>
            <config-property name="MessageMarshallers">
                org.jboss.qe.jdg.pojo.CustomerReport:org.jboss.qe.jdg.remote.marshaller.CustomerReportMarshaller
            </config-property>
            <config-property name="RemoteServerList">
                [remote-server-address]:11322
            </config-property>
            <config-property name="StagingCacheName">
                ${db.table.prefix}jdg-mat-stage
            </config-property>
            <config-property name="CacheTypeMap">
                ${db.table.prefix}jdg-mat:org.jboss.qe.jdg.pojo.CustomerReport;customerId
            </config-property>
            <config-property name="MessageDescriptor">
                org.jboss.qe.jdg.remote.protobuf.CustomerReport
            </config-property>
            <config-property name="Module">
                org.jboss.qe.jdg.pojos
            </config-property>
        </connection-definition>
    </connection-definitions>
</resource-adapter>

<xa-datasource jndi-name="java:/h2-ds" pool-name="h2-xa-ds" enabled="true">
    <xa-datasource-property name="URL">
        jdbc:h2:tcp://localhost:9292/db;TRACE_LEVEL_FILE=4
    </xa-datasource-property>
    <driver>h2</driver>
    <security>
        <user-name>sa</user-name>
    </security>
</xa-datasource>

SELECT COUNT(*) FROM external_long_ttl;