Eugeny
Eugeny
+1 Same error
use 'dynamodb-streams-kinesis-adapter', '1.0.2' and and Worker constructor with AmazonDynamoDBStreamsAdapterClient
I temporarily fixed this problem in my pyspark script by writing the following code: ``` def modifySchema(df): props = sc._jvm.java.util.Properties() jdbcUtils = sc._jvm.org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils rsmd = jdbcUtils.createConnectionFactory(jdbcURL, props) \ .apply() \...