Hi, can you provide some more code from your job and a full stack trace for your problem? That would help us to figure out the reason.
Best, Stefan > Am 31.08.2016 um 13:00 schrieb Pushpendra Jaiswal > <pushpendra.jaiswa...@gmail.com>: > > > ---------- Forwarded message ---------- > From: Pushpendra Jaiswal <pushpendra.jaiswa...@gmail.com > <mailto:pushpendra.jaiswa...@gmail.com>> > Date: Wed, Aug 31, 2016 at 3:52 PM > Subject: Not able to query : Queryable State > To: user@flink.apache.org <mailto:user@flink.apache.org> > > > Hi > I have been trying to use QueryableState with my project. > It's always failing the query saying. > > Job 461acde52fae479a6e02c6b2922cd9c1 not found > > Both keys(one in queryablestate and one in query) are of same type containing > same data. > Still I am not able to fetch the result. > Type of key Class : > case class Record(val fields: Seq[String], val ab: Double = 0.0, val cd: > Double = 0.0, val count: Long = 0) extends Serializable with Addable[Record] > with Comparable[Record]{ > > override def +(other: Record) = { > new Record(fields, > ab + other.ab, > cd + other.cd <http://other.cd/>, > count + other.count) > } > > override def equals(obj: scala.Any): Boolean = { > obj match { > case other: Record => fields == other.fields > case _ => false > } > } > > override def hashCode(): Int = { > var hashCode = 0 > fields.foreach(x => hashCode= hashCode+ 31 * x.hashCode) > // Math.abs(hashCode) > hashCode > } > > override def compareTo(o: Record): Int = { > var i = 0 > i = i + (count - o.count).toInt > i = i+ (ab - o.ab).toInt > i = i+ (cd - o.cd <http://o.cd/>).toInt > return i > } > } > > Is there problem with serialization? > Can I not use complex object as key (it is implementing comparable) > > Thanks and Regards > Pushpendra Jaiswal >
