(e3257ca432492b30): java.lang.IllegalStateException: Unable to decode tag list using org.apache.beam.sdk.coders.SerializableCoder@3c95e640
        com.google.cloud.dataflow.worker.WindmillStateReader.bagPageValues(WindmillStateReader.java:563)
        com.google.cloud.dataflow.worker.WindmillStateReader.consumeBag(WindmillStateReader.java:585)
        com.google.cloud.dataflow.worker.WindmillStateReader.consumeResponse(WindmillStateReader.java:492)
        com.google.cloud.dataflow.worker.WindmillStateReader.startBatchAndBlock(WindmillStateReader.java:411)
        com.google.cloud.dataflow.worker.WindmillStateReader$WrappedFuture.get(WindmillStateReader.java:306)
        com.google.cloud.dataflow.worker.repackaged.com.google.common.util.concurrent.Futures$1.get(Futures.java:679)
        com.google.cloud.dataflow.worker.WindmillStateInternals$WindmillBag.fetchData(WindmillStateInternals.java:498)
        com.google.cloud.dataflow.worker.WindmillStateInternals$WindmillBag.read(WindmillStateInternals.java:530)
        com.google.cloud.dataflow.worker.WindmillStateInternals$WindmillBag.read(WindmillStateInternals.java:449)
        com.myjobs.jobs.BufferMessagesDoFn.flush(BufferMessagesDoFn.scala:138)
        com.myjobs.jobs.BufferMessagesDoFn.onTimerFired(BufferMessagesDoFn.scala:102)
Caused by: java.io.InvalidClassException: com.myjobs.jobs.MessageWithAttributes; local class incompatible: stream classdesc serialVersionUID = -5160195612720162441, local class serialVersionUID = -9104690746829156208
        java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:616)
        java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1630)
        java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1521)
        java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1781)
        java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1353)
        java.io.ObjectInputStream.readObject(ObjectInputStream.java:373)
        org.apache.beam.sdk.coders.SerializableCoder.decode(SerializableCoder.java:136)
        org.apache.beam.sdk.coders.SerializableCoder.decode(SerializableCoder.java:47)
        org.apache.beam.sdk.coders.Coder.decode(Coder.java:170)
        com.google.cloud.dataflow.worker.WindmillStateReader.bagPageValues(WindmillStateReader.java:561)
        com.google.cloud.dataflow.worker.WindmillStateReader.consumeBag(WindmillStateReader.java:585)
        com.google.cloud.dataflow.worker.WindmillStateReader.consumeResponse(WindmillStateReader.java:492)
        com.google.cloud.dataflow.worker.WindmillStateReader.startBatchAndBlock(WindmillStateReader.java:411)
        com.google.cloud.dataflow.worker.WindmillStateReader$WrappedFuture.get(WindmillStateReader.java:306)
        com.google.cloud.dataflow.worker.repackaged.com.google.common.util.concurrent.Futures$1.get(Futures.java:679)
        com.google.cloud.dataflow.worker.WindmillStateInternals$WindmillBag.fetchData(WindmillStateInternals.java:498)
        com.google.cloud.dataflow.worker.WindmillStateInternals$WindmillBag.read(WindmillStateInternals.java:530)
        com.google.cloud.dataflow.worker.WindmillStateInternals$WindmillBag.read(WindmillStateInternals.java:449)
        com.myjobs.jobs.BufferMessagesDoFn.flush(BufferMessagesDoFn.scala:138)
        com.myjobs.jobs.BufferMessagesDoFn.onTimerFired(BufferMessagesDoFn.scala:102)
        com.myjobs.jobs.BufferMessagesDoFn$OnTimerInvoker$endOfWindow$ZW5kT2ZXaW5kb3c.invokeOnTimer(Unknown Source)
        org.apache.beam.sdk.transforms.reflect.ByteBuddyDoFnInvokerFactory$DoFnInvokerBase.invokeOnTimer(ByteBuddyDoFnInvokerFactory.java:171)
        org.apache.beam.runners.core.SimpleDoFnRunner.onTimer(SimpleDoFnRunner.java:171)
        com.google.cloud.dataflow.worker.SimpleParDoFn.processUserTimer(SimpleParDoFn.java:349)
        com.google.cloud.dataflow.worker.SimpleParDoFn.access$600(SimpleParDoFn.java:70)
        com.google.cloud.dataflow.worker.SimpleParDoFn$TimerType$1.processTimer(SimpleParDoFn.java:428)
        com.google.cloud.dataflow.worker.SimpleParDoFn.processTimers(SimpleParDoFn.java:457)
        com.google.cloud.dataflow.worker.SimpleParDoFn.processTimers(SimpleParDoFn.java:342)
        com.google.cloud.dataflow.worker.util.common.worker.ParDoOperation.finish(ParDoOperation.java:56)
        com.google.cloud.dataflow.worker.util.common.worker.MapTaskExecutor.execute(MapTaskExecutor.java:76)
        com.google.cloud.dataflow.worker.StreamingDataflowWorker.process(StreamingDataflowWorker.java:1069)
        com.google.cloud.dataflow.worker.StreamingDataflowWorker.access$1000(StreamingDataflowWorker.java:133)
        com.google.cloud.dataflow.worker.StreamingDataflowWorker$8.run(StreamingDataflowWorker.java:841)
        java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        java.lang.Thread.run(Thread.java:745)