Hi,
Are you sure the job id matches with running job? The error clearly says
JobID not found.
How are you setting the JobID, If I remember correctly, I used something
like
val jobId = JobID.fromHexString("myjob_id_here") to get the JobID object
and used it to call client.getKvState()
Thanks,
Vishnu
On Wed, Aug 31, 2016 at 10:30 AM, Stefan Richter <
s.rich...@data-artisans.com> wrote:
> 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>
> Date: Wed, Aug 31, 2016 at 3:52 PM
> Subject: Not able to query : Queryable State
> To: 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,
> 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).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
>
>
>
>
