Hi asaxena,
Thank you for your reply.
Unfortunately the error is thrown both in TOS and when running as a standalone job.
I went ahead and built a schema from the studio supplied information and provide that for the RecordBuilder, but it didn't help either.
Gabor
Here is how the record is built :
------------
private Record buildRecord(Map<String, Object> source){
if (source == null) return null;
System.out.println("Building record");
buildSchema();
if (this.schema == null) System.out.println("There is NO schema defined");
else System.out.println("Schema is defined");
Record.Builder rb = this.schema == null ? builderFactory.newRecordBuilder() : builderFactory.newRecordBuilder(schema);
for (String s : source.keySet()){
Object value = source.get(s);
if (value == null) continue;
if (value instanceof String) rb.withString(s, (String)value);
else if (value instanceof Boolean) rb.withBoolean(s, (boolean)value);
else if (value instanceof Date) rb.withDateTime(s, (Date)value);
else if (value instanceof Long) rb.withLong(s, (long) value);
else if (value instanceof Float) rb.withFloat(s, (long) value);
}
return rb.build();
}
--------------------
Here is the whole output for the job:
.\connectorTest_run.ps1
outgoing schema is defined
SchemaInfo(label=__replayid__, key=true, talendType=id_Long, nullable=false, pattern=)
SchemaInfo(label=CreatedById, key=false, talendType=id_String, nullable=true, pattern=)
SchemaInfo(label=CreatedDate, key=false, talendType=id_String, nullable=true, pattern=)
SchemaInfo(label=Location__c, key=false, talendType=id_String, nullable=true, pattern=)
SchemaInfo(label=Urgent__c, key=false, talendType=id_Boolean, nullable=false, pattern=)
Handshake message
{ext={replay=true, payload.format=true}, minimumVersion=1.0, clientId=9ie1tc6txy2vktgullgebxs4j4zs, supportedConnectionTypes=[Ljava.lang.Object;@7cdb56b5, channel=/meta/handshake, id=1, version=1.0, successful=true}
Building record
Schema is defined
[statistics] disconnected
Exception in thread "main" java.lang.NoClassDefFoundError: routines/system/DynamicMetadata
at java.base/java.lang.Class.getDeclaredMethods0(Native Method)
at java.base/java.lang.Class.privateGetDeclaredMethods(Class.java:3402)
at java.base/java.lang.Class.getDeclaredMethod(Class.java:2673)
at org.talend.sdk.component.runtime.record.RecordConverters$MappingMeta.newInstance(RecordConverters.java:479)
at org.talend.sdk.component.runtime.record.RecordConverters.toType(RecordConverters.java:268)
at platformevent.connectortest_0_1.connectorTest.SfPlatformEventPlatformEventInput_1Process(connectorTest.java:838)
at platformevent.connectortest_0_1.connectorTest.runJobInTOS(connectorTest.java:1496)
at platformevent.connectortest_0_1.connectorTest.main(connectorTest.java:1327)
Caused by: java.lang.ClassNotFoundException: routines.system.DynamicMetadata
at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641)
at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:520)
... 8 more
