[#2284] ClassCastException with MapsId, EmbeddedId, and many-to-one

Author: dreab8

hibernate-reactive-core/src/main/java/org/hibernate/reactive/sql/results/graph/embeddable/internal/ReactiveEmbeddableFetchImpl.java

@@ -57,6 +57,9 @@ public Fetch findFetch(Fetchable fetchable) {
 		if ( fetch instanceof EntityFetchSelectImpl entityFetchSelect ) {
 			return new ReactiveEntityFetchSelectImpl( entityFetchSelect );
 		}
+		else if ( fetch instanceof EmbeddableFetchImpl embeddableFetch ) {
+			return new ReactiveEmbeddableFetchImpl( embeddableFetch );
+		}
 		return fetch;
 	}
 }

hibernate-reactive-core/src/main/java/org/hibernate/reactive/sql/results/graph/embeddable/internal/ReactiveEmbeddableInitializerImpl.java

@@ -214,16 +214,21 @@ public CompletionStage<Void> forEachReactiveSubInitializer(
 		final ReactiveEmbeddableInitializerData embeddableInitializerData = (ReactiveEmbeddableInitializerData) data;
 		final RowProcessingState rowProcessingState = embeddableInitializerData.getRowProcessingState();
 		if ( embeddableInitializerData.getConcreteEmbeddableType() == null ) {
-			return loop( subInitializers, subInitializer -> loop( subInitializer, initializer -> consumer
-					.apply( (ReactiveInitializer<?>) initializer, rowProcessingState )
-			) );
+			return loop( subInitializers, subInitializer ->
+					loop( subInitializer, initializer ->
+							initializer != null
+									? consumer.apply( (ReactiveInitializer<?>) initializer, rowProcessingState )
+									: voidFuture()
+					)
+			);
 		}
 		else {
 			Initializer<InitializerData>[] initializers = subInitializers[embeddableInitializerData.getSubclassId()];
-			return loop( 0, initializers.length, i -> {
-				ReactiveInitializer<?> reactiveInitializer = (ReactiveInitializer<?>) initializers[i];
-				return consumer.apply( reactiveInitializer, rowProcessingState );
-			} );
+			return loop(0, initializers.length, i ->
+					initializers[i] != null
+							? consumer.apply( (ReactiveInitializer<?>) initializers[i], rowProcessingState )
+							: voidFuture()
+			);
 		}
 	}