Error after install and unistall connect-transforms

[diegoot-dev]

Hi

I had no problems connecting to Hadoop, but after installing confluentinc/connect-transforms:1.4.3 I get the error below.

I uninstalled the library and the error continues.

Any suggestion what could be the problem?

I currently have this version kafka-connect-hdfs:10.1.9

org.apache.kafka.connect.errors.ConnectException: java.lang.reflect.InvocationTargetException at io.confluent.connect.storage.StorageFactory.createStorage(StorageFactory.java:55) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:151) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:99) at io.confluent.connect.hdfs.HdfsSinkTask.start(HdfsSinkTask.java:91) at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:313) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:198) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:255) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: java.lang.reflect.InvocationTargetException at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490) at io.confluent.connect.storage.StorageFactory.createStorage(StorageFactory.java:50) ... 11 more Caused by: org.apache.hadoop.security.KerberosAuthException: failure to login: javax.security.auth.login.LoginException: java.lang.NullPointerException: invalid null input: name at jdk.security.auth/com.sun.security.auth.UnixPrincipal.<init>(UnixPrincipal.java:67) at jdk.security.auth/com.sun.security.auth.module.UnixLoginModule.login(UnixLoginModule.java:129) at java.base/javax.security.auth.login.LoginContext.invoke(LoginContext.java:747) at java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:672) at java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:670) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:670) at java.base/javax.security.auth.login.LoginContext.login(LoginContext.java:581) at org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:871) at org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:833) at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:702) at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:3431) at org.apache.hadoop.fs.FileSystem$Cache.getUnique(FileSystem.java:3269) at org.apache.hadoop.fs.FileSystem.newInstance(FileSystem.java:528) at io.confluent.connect.hdfs.storage.HdfsStorage.<init>(HdfsStorage.java:60) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490) at io.confluent.connect.storage.StorageFactory.createStorage(StorageFactory.java:50) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:151) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:99) at io.confluent.connect.hdfs.HdfsSinkTask.start(HdfsSinkTask.java:91) at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:313) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:198) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:255) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) at org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:928) at org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:833) at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:702) at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:3431) at org.apache.hadoop.fs.FileSystem$Cache.getUnique(FileSystem.java:3269) at org.apache.hadoop.fs.FileSystem.newInstance(FileSystem.java:528) at io.confluent.connect.hdfs.storage.HdfsStorage.<init>(HdfsStorage.java:60) ... 16 more Caused by: javax.security.auth.login.LoginException: java.lang.NullPointerException: invalid null input: name at jdk.security.auth/com.sun.security.auth.UnixPrincipal.<init>(UnixPrincipal.java:67) at jdk.security.auth/com.sun.security.auth.module.UnixLoginModule.login(UnixLoginModule.java:129) at java.base/javax.security.auth.login.LoginContext.invoke(LoginContext.java:747) at java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:672) at java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:670) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:670) at java.base/javax.security.auth.login.LoginContext.login(LoginContext.java:581) at org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:871) at org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:833) at org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:702) at org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:3431) at org.apache.hadoop.fs.FileSystem$Cache.getUnique(FileSystem.java:3269) at org.apache.hadoop.fs.FileSystem.newInstance(FileSystem.java:528) at io.confluent.connect.hdfs.storage.HdfsStorage.<init>(HdfsStorage.java:60) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490) at io.confluent.connect.storage.StorageFactory.createStorage(StorageFactory.java:50) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:151) at io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:99) at io.confluent.connect.hdfs.HdfsSinkTask.start(HdfsSinkTask.java:91) at org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:313) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:198) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:255) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:829) at java.base/javax.security.auth.login.LoginContext.invoke(LoginContext.java:842) at java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:672) at java.base/javax.security.auth.login.LoginContext$4.run(LoginContext.java:670) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/javax.security.auth.login.LoginContext.invokePriv(LoginContext.java:670) at java.base/javax.security.auth.login.LoginContext.login(LoginContext.java:581) at org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:871) ... 22 more