Hi Val, the class is listed below. Two more updates:
* The "Ignoring entry for partition ..." is also present on the slow cluster, where the data is loaded correctly. * The clocks are significantly out of sync on the fast cluster. One is off by more than one minute. I am having this rectified, but it is not my cluster, so it is taking some time. Here is the key class. import java.io.Serializable; import java.util.UUID; import java.util.Date; public class FcPortStatsKey implements Serializable { private Date hour; // partition 1 -- timestamp truncated at the hour private Integer bucket; // partition 2 -- switch_id hashed to buckets private Date dateTime; // cluster 1 -- date_time private UUID portId; // cluster 2 -- port_id // default constructor public FcPortStatsKey() { super(); } public Date getHour() { return hour; } public Integer getBucket() { return bucket; } public Date getDateTime() { return dateTime; } public UUID getPortId() { return portId; } public void setHour( Date hour) { this.hour = hour; } public void setBucket( Integer bucket) { this.bucket = bucket; } public void setDateTime( Date dateTime) { this.dateTime = dateTime; } public void setPortId( UUID portId) { this.portId = portId; } @Override public String toString() { return String.format( "FcPortStatsKey: %s, %d, %s, %s", hour.toString(), bucket, dateTime.toString(), portId.toString()); } @Override public boolean equals( Object obj) { if (this == obj) return true; if (!(obj instanceof FcPortStatsKey)) return false; FcPortStatsKey other = (FcPortStatsKey) obj; // partition keys are derived; need not be included if (dateTime != null && dateTime.equals( other.dateTime) && portId != null && portId.equals( other.portId)) return true; else return false; } @Override public int hashCode() { // partition keys are derived; need not be included int result = 91; result = 127 * result + portId.hashCode(); result = 127 * result + dateTime.hashCode(); return result; } } And here is the related configuration: <persistence keyspace="test_11" table="fc_port_stats"> <keyPersistence class="com.brocade.poc.icpoc.model.FcPortStatsKey" strategy="POJO"> <partitionKey> <field name="hour"/> <field name="bucket"/> </partitionKey> <clusterKey> <field name="dateTime" column="date_time"/> <field name="portId" column="port_id"/> </clusterKey> </keyPersistence> Roger -----Original Message----- From: vkulichenko [mailto:valentin.kuliche...@gmail.com] Sent: Tuesday, July 25, 2017 5:16 PM To: user@ignite.apache.org Subject: Re: Missing object when loading from Cassandra with multiple queries Hi Roger, Can you show the FcPortStatsKey class? -Val -- View this message in context: https://urldefense.proofpoint.com/v2/url?u=http-3A__apache-2Dignite-2Dusers.70518.x6.nabble.com_Missing-2Dobject-2Dwhen-2Dloading-2Dfrom-2DCassandra-2Dwith-2Dmultiple-2Dqueries-2Dtp15644p15645.html&d=DwICAg&c=IL_XqQWOjubgfqINi2jTzg&r=1esZO0r0bYS90lcsaLA6N4AFxuNo6lzauhETGwdJQoQ&m=s1zSUsG_hFKhGsE9HpBCQWzuPCJa-iX4tmT8kmN7-d0&s=u8-EePeYS6JZ8u9cp9pMGJ8WGAoSvDZFBy93_jKNrIM&e= Sent from the Apache Ignite Users mailing list archive at Nabble.com.