(camel) branch main updated: CAMEL-22448: Better error message

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 9fd198f0e2a CAMEL-22448: Better error message
9fd198f0e2a is described below

commit 9fd198f0e2a38a8b3fd7b34a662b767987db25e4
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Sep 25 10:20:07 2025 +0200

    CAMEL-22448: Better error message
---
 .../main/java/org/apache/camel/component/flink/FlinkComponent.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/components/camel-flink/src/main/java/org/apache/camel/component/flink/FlinkComponent.java
 
b/components/camel-flink/src/main/java/org/apache/camel/component/flink/FlinkComponent.java
index fea4ea32dcd..c90abf7d14c 100644
--- 
a/components/camel-flink/src/main/java/org/apache/camel/component/flink/FlinkComponent.java
+++ 
b/components/camel-flink/src/main/java/org/apache/camel/component/flink/FlinkComponent.java
@@ -22,6 +22,7 @@ import org.apache.camel.Endpoint;
 import org.apache.camel.spi.Metadata;
 import org.apache.camel.spi.annotations.Component;
 import org.apache.camel.support.DefaultComponent;
+import org.apache.camel.support.ObjectHelper;
 import org.apache.flink.api.java.DataSet;
 import org.apache.flink.streaming.api.datastream.DataStream;
 
@@ -45,6 +46,9 @@ public class FlinkComponent extends DefaultComponent {
 
     @Override
     protected Endpoint createEndpoint(String uri, String remaining, 
Map<String, Object> parameters) throws Exception {
+        if (remaining == null) {
+            throw new IllegalArgumentException("The endpointType must be 
configured in endpoint uri: " + uri);
+        }
         EndpointType type = 
getCamelContext().getTypeConverter().mandatoryConvertTo(EndpointType.class, 
remaining);
         return new FlinkEndpoint(uri, this, type);
     }