ring) e.getValue())
));
Best,
Junrui
Tauseef Janvekar 于2023年12月5日周二 16:30写道：
> Dear Team,
>
> I am getting cast exception in flink.
> Caused by: org.apache.flink.client.program.ProgramInvocationException: The
> main method caused an error: class java.lang.String cannot be cast to class
>
Dear Team,
>
> I am getting cast exception in flink.
> Caused by: org.apache.flink.client.program.ProgramInvocationException: The
> main method caused an error: class java.lang.String cannot be cast to class
> java.lang.Double (java.lang.String and java.lang.Double are in modu
Dear Team,
I am getting cast exception in flink.
Caused by: org.apache.flink.client.program.ProgramInvocationException: The
main method caused an error: class java.lang.String cannot be cast to class
java.lang.Double (java.lang.String and java.lang.Double are in module
java.base of loader
to write to
> tables that are stored in separate s3 buckets, we have run into issues.
The
> first jobs submitted to the cluster run fine, however, when submitting
more
> jobs for sink tables with the same name (in separate database schemas and
> s3 buckets), we run i
tables with the same name (in separate database schemas and
s3 buckets), we run into a class cast exception as well as
an org.apache.hadoop.metrics2.MetricsException error stating: Metrics
source S3AMetrics{bucket-name} already exists!
Attached are both the error logs as well as the main code
