You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@iceberg.apache.org by GitBox <gi...@apache.org> on 2021/04/10 21:57:04 UTC
[GitHub] [iceberg] ashwini-tgam opened a new issue #2455: Class not found error when use sink
ashwini-tgam opened a new issue #2455:
URL: https://github.com/apache/iceberg/issues/2455
While building in local i see this error as class not found in scala flink job:
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/table/runtime/typeutils/RowDataTypeInfo
at io.sophi.platform.realtime.snowplow.enrich.bad.archiver.Job$.main(Job.scala:129)
at io.sophi.platform.realtime.snowplow.enrich.bad.archiver.Job.main(Job.scala)
Caused by: java.lang.ClassNotFoundException: org.apache.flink.table.runtime.typeutils.RowDataTypeInfo
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 2 more
How to resolve this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org
[GitHub] [iceberg] openinx commented on issue #2455: Class not found error when use sink
Posted by GitBox <gi...@apache.org>.
openinx commented on issue #2455:
URL: https://github.com/apache/iceberg/issues/2455#issuecomment-817551881
@ashwini-tgam The `RowDataTypeInfo` is a class that comes from flink 1.11, in flink 1.12 the class was refactored to `InternalTypeInfo` (See https://github.com/apache/iceberg/pull/1956/files#diff-752b41f006e879a05750f3723df689214cdd629d8d9f48af76ed9f99c38d49b2R38). So I think you are using flink-runtime jar that was compiled from flink 1.11 and then run the flink streaming job under flink 1.12 cluster ? Pls check you flink-runtime jar version and flink cluster version.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org
[GitHub] [iceberg] ashwini-tgam commented on issue #2455: Class not found error when use sink
Posted by GitBox <gi...@apache.org>.
ashwini-tgam commented on issue #2455:
URL: https://github.com/apache/iceberg/issues/2455#issuecomment-845938873
> @ashwini-tgam The `RowDataTypeInfo` is a class that comes from flink 1.11, in flink 1.12 the class was refactored to `InternalTypeInfo` (See https://github.com/apache/iceberg/pull/1956/files#diff-752b41f006e879a05750f3723df689214cdd629d8d9f48af76ed9f99c38d49b2R38). So I think you are using flink-runtime jar that was compiled from flink 1.11 and then run the flink streaming job under flink 1.12 cluster ? Pls check you flink-runtime jar version and flink cluster version.
I am using flink 1.11 in production which did not solve my issue
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org
[GitHub] [iceberg] ashwini-tgam commented on issue #2455: Class not found error when use sink
Posted by GitBox <gi...@apache.org>.
ashwini-tgam commented on issue #2455:
URL: https://github.com/apache/iceberg/issues/2455#issuecomment-845939222
> hi, i've met the same problem with flink 1.12 when trying sink data to iceberg, have you already solve the problem?
No I am not able to solve it but in production server it worked but never worked on my local
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org
[GitHub] [iceberg] xianhaohihi commented on issue #2455: Class not found error when use sink
Posted by GitBox <gi...@apache.org>.
xianhaohihi commented on issue #2455:
URL: https://github.com/apache/iceberg/issues/2455#issuecomment-845734575
hi, i've met the same problem with flink 1.12 when trying sink data to iceberg, have you already solve the problem?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@iceberg.apache.org
For additional commands, e-mail: issues-help@iceberg.apache.org