Hi, thanks for the reply.
It was indeed the class loading issue and it’s introduced by latest version of
package “aws-kinesisanalytics-runtime”. I resolved the issue by removing the
package and customized the runtime myself.
-- Best wishes
Fu Kai
From: Arvid Heise
Date: Thursday, April 23
Hi, I’m using Flink 1.8 with JDK 8.
-- Best wishes
Fu Kai
From: Chesnay Schepler
Date: Tuesday, April 21, 2020 at 5:15 PM
To: "Fu, Kai" , "user@flink.apache.org"
Subject: RE: [EXTERNAL] Unable to unmarshall response
(com.ctc.wstx.stax.WstxInputFacto
Hi,
I’m running Flink application on AWS Kinesis Flink platform to read a kinesis
stream from another account with assumed role, while I’m getting exception like
below. But it works when I’m running the application locally, I’ve given all
the related roles admin permission. Could anyone help wh
