You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Emmerson (Jira)" <ji...@apache.org> on 2020/09/10 10:57:00 UTC
[jira] [Created] (CAMEL-15519) kubernetes-pods consumer raise a No
type converter available exception
Emmerson created CAMEL-15519:
--------------------------------
Summary: kubernetes-pods consumer raise a No type converter available exception
Key: CAMEL-15519
URL: https://issues.apache.org/jira/browse/CAMEL-15519
Project: Camel
Issue Type: Wish
Components: camel-kubernetes
Affects Versions: 3.4.2
Reporter: Emmerson
Hello,
I am testing kubernetes-pods consumer and in the first test it works fine, then I run a kubernetes job (this create internally a Pod) and I get a "_No type converter available_" exception in the console.
The pod consumer source code is here: [https://github.com/Emmerson-Miranda/camel/blob/master/camel3-cdi/cdi-k8s-pocs/src/main/java/edu/emmerson/camel/k8s/jobs/camel_k8s_jobs/KubernetesRouteConsumerPods.java]
The pod creation source code is here [https://github.com/Emmerson-Miranda/camel/blob/master/camel3-cdi/cdi-k8s-pocs/src/main/java/edu/emmerson/camel/k8s/jobs/camel_k8s_jobs/KubernetesCreateJob.java]
*Bellow the stacktrace*
[ https://192.168.64.3:8443/...] KubernetesRouteConsumerPods INFO KEEPING pod name: job-1599734811571-rls7l
[ XNIO-1 task-1] UndertowConsumer WARN Caused by: [org.apache.camel.NoTypeConversionAvailableException - No type converter available to convert from type: io.fabric8.kubernetes.api.model.batch.Job to the required type: java.nio.ByteBuffer with value Job(apiVersion=batch/v1, kind=Job, metadata=ObjectMeta(annotations=null, clusterName=null, creationTimestamp=2020-09-10T10:46:51Z, deletionGracePeriodSeconds=null, deletionTimestamp=null, finalizers=[], generateName=null, generation=null, labels=\{app=jobFromCamelApp, jobLabelKey1=value1, jobLabelKey2=value2}, managedFields=[ManagedFieldsEntry(apiVersion=batch/v1, fieldsType=FieldsV1, fieldsV1=FieldsV1(additionalProperties=\{f:metadata={f:labels={.={}, f:app={}, f:jobLabelKey1={}, f:jobLabelKey2={}}}, f:spec=\{f:activeDeadlineSeconds={}, f:backoffLimit={}, f:completions={}, f:parallelism={}, f:template=\{f:metadata={f:annotations={.={}, f:jobMetadataAnnotation1={}}, f:labels=\{.={}, f:app={}, f:orderId={}, f:podLabelKey1={}, f:podLabelKey2={}}}, f:spec=\{f:containers={k:{"name":"pi"}=\{.={}, f:command={}, f:image={}, f:imagePullPolicy={}, f:name={}, f:resources={}, f:terminationMessagePath={}, f:terminationMessagePolicy={}}}, f:dnsPolicy={}, f:restartPolicy={}, f:schedulerName={}, f:securityContext={}, f:terminationGracePeriodSeconds={}}}, f:ttlSecondsAfterFinished={}}}), manager=okhttp, operation=Update, time=2020-09-10T10:46:51Z, additionalProperties={})], name=job-1599734811571, namespace=default, ownerReferences=[], resourceVersion=1688691, selfLink=/apis/batch/v1/namespaces/default/jobs/job-1599734811571, uid=df5c8ed7-1436-4c57-854a-5703fa3baed8, additionalProperties={}), spec=JobSpec(activeDeadlineSeconds=7200, backoffLimit=6, completions=1, manualSelector=null, parallelism=1, selector=LabelSelector(matchExpressions=[], matchLabels=\{controller-uid=df5c8ed7-1436-4c57-854a-5703fa3baed8}, additionalProperties={}), template=PodTemplateSpec(metadata=ObjectMeta(annotations=\{jobMetadataAnnotation1=random value}, clusterName=null, creationTimestamp=null, deletionGracePeriodSeconds=null, deletionTimestamp=null, finalizers=[], generateName=null, generation=null, labels=\{app=podFromCamelApp, controller-uid=df5c8ed7-1436-4c57-854a-5703fa3baed8, job-name=job-1599734811571, orderId=54702d2c-554b-4fa8-91ef-9e4e7abfe055, podLabelKey1=value1, podLabelKey2=value2}, managedFields=[], name=null, namespace=null, ownerReferences=[], resourceVersion=null, selfLink=null, uid=null, additionalProperties={}), spec=PodSpec(activeDeadlineSeconds=null, affinity=null, automountServiceAccountToken=null, containers=[Container(args=[], command=[echo, Job created from Apache Camel code at Thu Sep 10 11:46:51 BST 2020], env=[], envFrom=[], image=perl, imagePullPolicy=Always, lifecycle=null, livenessProbe=null, name=pi, ports=[], readinessProbe=null, resources=ResourceRequirements(limits=null, requests=null, additionalProperties={}), securityContext=null, startupProbe=null, stdin=null, stdinOnce=null, terminationMessagePath=/dev/termination-log, terminationMessagePolicy=File, tty=null, volumeDevices=[], volumeMounts=[], workingDir=null, additionalProperties={})], dnsConfig=null, dnsPolicy=ClusterFirst, enableServiceLinks=null, ephemeralContainers=[], hostAliases=[], hostIPC=null, hostNetwork=null, hostPID=null, hostname=null, imagePullSecrets=[], initContainers=[], nodeName=null, nodeSelector=null, overhead=null, preemptionPolicy=null, priority=null, priorityClassName=null, readinessGates=[], restartPolicy=OnFailure, runtimeClassName=null, schedulerName=default-scheduler, securityContext=PodSecurityContext(fsGroup=null, fsGroupChangePolicy=null, runAsGroup=null, runAsNonRoot=null, runAsUser=null, seLinuxOptions=null, supplementalGroups=[], sysctls=[], windowsOptions=null, additionalProperties={}), serviceAccount=null, serviceAccountName=null, shareProcessNamespace=null, subdomain=null, terminationGracePeriodSeconds=30, tolerations=[], topologySpreadConstraints=[], volumes=[], additionalProperties={}), additionalProperties={}), ttlSecondsAfterFinished=null, additionalProperties={}), status=JobStatus(active=null, completionTime=null, conditions=[], failed=null, startTime=null, succeeded=null, additionalProperties={}), additionalProperties={})]
org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: io.fabric8.kubernetes.api.model.batch.Job to the required type: java.nio.ByteBuffer with value Job(apiVersion=batch/v1, kind=Job, metadata=ObjectMeta(annotations=null, clusterName=null, creationTimestamp=2020-09-10T10:46:51Z, deletionGracePeriodSeconds=null, deletionTimestamp=null, finalizers=[], generateName=null, generation=null, labels=\{app=jobFromCamelApp, jobLabelKey1=value1, jobLabelKey2=value2}, managedFields=[ManagedFieldsEntry(apiVersion=batch/v1, fieldsType=FieldsV1, fieldsV1=FieldsV1(additionalProperties=\{f:metadata={f:labels={.={}, f:app={}, f:jobLabelKey1={}, f:jobLabelKey2={}}}, f:spec=\{f:activeDeadlineSeconds={}, f:backoffLimit={}, f:completions={}, f:parallelism={}, f:template=\{f:metadata={f:annotations={.={}, f:jobMetadataAnnotation1={}}, f:labels=\{.={}, f:app={}, f:orderId={}, f:podLabelKey1={}, f:podLabelKey2={}}}, f:spec=\{f:containers={k:{"name":"pi"}=\{.={}, f:command={}, f:image={}, f:imagePullPolicy={}, f:name={}, f:resources={}, f:terminationMessagePath={}, f:terminationMessagePolicy={}}}, f:dnsPolicy={}, f:restartPolicy={}, f:schedulerName={}, f:securityContext={}, f:terminationGracePeriodSeconds={}}}, f:ttlSecondsAfterFinished={}}}), manager=okhttp, operation=Update, time=2020-09-10T10:46:51Z, additionalProperties={})], name=job-1599734811571, namespace=default, ownerReferences=[], resourceVersion=1688691, selfLink=/apis/batch/v1/namespaces/default/jobs/job-1599734811571, uid=df5c8ed7-1436-4c57-854a-5703fa3baed8, additionalProperties={}), spec=JobSpec(activeDeadlineSeconds=7200, backoffLimit=6, completions=1, manualSelector=null, parallelism=1, selector=LabelSelector(matchExpressions=[], matchLabels=\{controller-uid=df5c8ed7-1436-4c57-854a-5703fa3baed8}, additionalProperties={}), template=PodTemplateSpec(metadata=ObjectMeta(annotations=\{jobMetadataAnnotation1=random value}, clusterName=null, creationTimestamp=null, deletionGracePeriodSeconds=null, deletionTimestamp=null, finalizers=[], generateName=null, generation=null, labels=\{app=podFromCamelApp, controller-uid=df5c8ed7-1436-4c57-854a-5703fa3baed8, job-name=job-1599734811571, orderId=54702d2c-554b-4fa8-91ef-9e4e7abfe055, podLabelKey1=value1, podLabelKey2=value2}, managedFields=[], name=null, namespace=null, ownerReferences=[], resourceVersion=null, selfLink=null, uid=null, additionalProperties={}), spec=PodSpec(activeDeadlineSeconds=null, affinity=null, automountServiceAccountToken=null, containers=[Container(args=[], command=[echo, Job created from Apache Camel code at Thu Sep 10 11:46:51 BST 2020], env=[], envFrom=[], image=perl, imagePullPolicy=Always, lifecycle=null, livenessProbe=null, name=pi, ports=[], readinessProbe=null, resources=ResourceRequirements(limits=null, requests=null, additionalProperties={}), securityContext=null, startupProbe=null, stdin=null, stdinOnce=null, terminationMessagePath=/dev/termination-log, terminationMessagePolicy=File, tty=null, volumeDevices=[], volumeMounts=[], workingDir=null, additionalProperties={})], dnsConfig=null, dnsPolicy=ClusterFirst, enableServiceLinks=null, ephemeralContainers=[], hostAliases=[], hostIPC=null, hostNetwork=null, hostPID=null, hostname=null, imagePullSecrets=[], initContainers=[], nodeName=null, nodeSelector=null, overhead=null, preemptionPolicy=null, priority=null, priorityClassName=null, readinessGates=[], restartPolicy=OnFailure, runtimeClassName=null, schedulerName=default-scheduler, securityContext=PodSecurityContext(fsGroup=null, fsGroupChangePolicy=null, runAsGroup=null, runAsNonRoot=null, runAsUser=null, seLinuxOptions=null, supplementalGroups=[], sysctls=[], windowsOptions=null, additionalProperties={}), serviceAccount=null, serviceAccountName=null, shareProcessNamespace=null, subdomain=null, terminationGracePeriodSeconds=30, tolerations=[], topologySpreadConstraints=[], volumes=[], additionalProperties={}), additionalProperties={}), ttlSecondsAfterFinished=null, additionalProperties={}), status=JobStatus(active=null, completionTime=null, conditions=[], failed=null, startTime=null, succeeded=null, additionalProperties={}), additionalProperties={})
at org.apache.camel.impl.converter.CoreTypeConverterRegistry.mandatoryConvertTo(CoreTypeConverterRegistry.java:216) ~[camel-base-3.4.2.jar:3.4.2]
at org.apache.camel.impl.converter.CoreTypeConverterRegistry.mandatoryConvertTo(CoreTypeConverterRegistry.java:168) ~[camel-base-3.4.2.jar:3.4.2]
at org.apache.camel.component.undertow.UndertowConsumer.sendResponse(UndertowConsumer.java:259) ~[camel-undertow-3.4.2.jar:3.4.2]
at org.apache.camel.component.undertow.UndertowConsumer.handleRequest(UndertowConsumer.java:231) [camel-undertow-3.4.2.jar:3.4.2]
at io.undertow.server.Connectors.executeRootHandler(Connectors.java:370) [undertow-core-2.1.2.Final.jar:2.1.2.Final]
at io.undertow.server.HttpServerExchange$1.run(HttpServerExchange.java:830) [undertow-core-2.1.2.Final.jar:2.1.2.Final]
at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35) [jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:2019) [jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1558) [jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1423) [jboss-threads-3.1.0.Final.jar:3.1.0.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_252]
[ https://192.168.64.3:8443/...] KubernetesRouteConsumerPods INFO Got event from Pod: job-1599734811571-rls7l, action: MODIFIED Phase: Pending
--
This message was sent by Atlassian Jira
(v8.3.4#803005)