resolves issue: ClassNotFoundException thrown during SeriazliationCodec.decode #2136

redisson/src/main/java/org/redisson/codec/SerializationCodec.java

@@ -39,15 +39,23 @@ public class SerializationCodec extends BaseCodec {
     private final Decoder<Object> decoder = new Decoder<Object>() {
         @Override
         public Object decode(ByteBuf buf, State state) throws IOException {
+            try {
+                //set thread context class loader to be the classLoader variable as there could be reflection
+                //done while reading from input stream which reflection will use thread class loader to load classes on demand
+                ClassLoader currentThreadClassLoader = Thread.currentThread().getContextClassLoader();
                 try {
                     ByteBufInputStream in = new ByteBufInputStream(buf);
                     ObjectInputStream inputStream;
                     if (classLoader != null) {
+                        Thread.currentThread().setContextClassLoader(classLoader);
                         inputStream = new CustomObjectInputStream(classLoader, in);
                     } else {
                         inputStream = new ObjectInputStream(in);
                     }
                     return inputStream.readObject();
+                } finally {
+                    Thread.currentThread().setContextClassLoader(currentThreadClassLoader);
+                }
             } catch (IOException e) {
                 throw e;
             } catch (Exception e) {

redisson/src/main/java/org/redisson/executor/TasksRunnerService.java

@@ -275,9 +275,18 @@ public class TasksRunnerService implements RemoteExecutorService {
             T task;
             if (params.getLambdaBody() != null) {
                 ByteArrayInputStream is = new ByteArrayInputStream(params.getLambdaBody());
+                
+                //set thread context class loader to be the classLoaderCodec.getClassLoader() variable as there could be reflection
+                //done while reading from input stream which reflection will use thread class loader to load classes on demand
+                ClassLoader currentThreadClassLoader = Thread.currentThread().getContextClassLoader();                
+                try {
+                    Thread.currentThread().setContextClassLoader(classLoaderCodec.getClassLoader());
                     ObjectInput oo = new CustomObjectInputStream(classLoaderCodec.getClassLoader(), is);
                     task = (T) oo.readObject();
                     oo.close();
+                } finally {
+                    Thread.currentThread().setContextClassLoader(currentThreadClassLoader);
+                }
             } else {
                 task = (T) classLoaderCodec.getValueDecoder().decode(stateBuf, null);
             }