You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "jason810496 (via GitHub)" <gi...@apache.org> on 2026/06/12 07:24:37 UTC
[PR] Fix Java-SDK connection port casting [airflow]
jason810496 opened a new pull request, #68433:
URL: https://github.com/apache/airflow/pull/68433
## Why
@vatsrahul1001 ran into this error when setting up connection with port in Java-SDK. For example setting `AIRFLOW_CONN_TEST_HTTP='{"conn_type": "http", "login": "user", "password": "pass", "host": "example.com", "port": 1234, "extra": {"param1": "val1", "param2": "val2"}}'` in breeze we will get:
```
[2026-06-11 14:44:12] DEBUG - Connected logs addr=/127.0.0.1:56941
[2026-06-11 14:44:12] DEBUG - Connected comm addr=/127.0.0.1:40867
[2026-06-11 14:44:13] DEBUG - Handling id=0
[2026-06-11 14:44:13] ERROR - [main] INFO org.apache.airflow.example.AnnotationExample - Hello from task
[2026-06-11 14:44:13] DEBUG - Sending id=0 body=org.apache.airflow.sdk.execution.comm.GetXCom@72ea6193[key=return_value,dagId=java_annotation_example,runId=manual__2026-06-11T09:14:11.101516+00:00,taskId=python_task_1,mapIndex=<null>,includePriorDates=false,type=GetXCom]
[2026-06-11 14:44:13] DEBUG - Handling id=0
[2026-06-11 14:44:13] ERROR - [main] INFO org.apache.airflow.example.AnnotationExample - Got XCom from Python Task 'python_task_1' value_from_python_task_1
[2026-06-11 14:44:13] DEBUG - Sending id=1 body=org.apache.airflow.sdk.execution.comm.GetConnection@698122b2[connId=test_http,type=GetConnection]
[2026-06-11 14:44:13] DEBUG - Handling id=1
[2026-06-11 14:44:13] ERROR - Error executing task ti=org.apache.airflow.sdk.execution.comm.TaskInstanceDTO@13cf7d52[id=019eb5f5-e328-7e25-8784-591f08ba329a,dagVersionId=019eb5d5-63b2-7d13-b8d9-b088827410a0,taskId=extract,dagId=java_annotation_example,runId=manual__2026-06-11T09:14:11.101516+00:00,tryNumber=1,mapIndex=-1,poolSlots=1,queue=java,priorityWeight=3,parentContextCarrier=<null>,contextCarrier={traceparent=00-236f21095f7ed4196bdb938d71f41dac-812162b32d6c7f78-01}] error=java.lang.ClassCastException: class java.lang.Long cannot be cast to class java.lang.Integer (java.lang.Long and java.lang.Integer are in module java.base of loader 'bootstrap') trace=java.lang.ClassCastException: class java.lang.Long cannot be cast to class java.lang.Integer (java.lang.Long and java.lang.Integer are in module java.base of loader 'bootstrap')
at org.apache.airflow.sdk.Client.getConnection(Client.kt:82)
at org.apache.airflow.example.AnnotationExample.extractValue(AnnotationExample.java:39)
at org.apache.airflow.example.AnnotationExampleBuilder$ExtractValue.execute(AnnotationExampleBuilder.java:23)
at org.apache.airflow.sdk.execution.TaskRunner.runTask$sdk(Task.kt:66)
at org.apache.airflow.sdk.execution.TaskKt.runTask(Task.kt:80)
at org.apache.airflow.sdk.execution.CoordinatorComm.handleIncoming(Comm.kt:105)
at org.apache.airflow.sdk.execution.CoordinatorComm$startProcessing$2.invoke(Comm.kt:62)
at org.apache.airflow.sdk.execution.CoordinatorComm$startProcessing$2.invoke(Comm.kt:62)
at org.apache.airflow.sdk.execution.CoordinatorComm.processOnce(Comm.kt:87)
at org.apache.airflow.sdk.execution.CoordinatorComm.startProcessing(Comm.kt:62)
at org.apache.airflow.sdk.Server$serveAsync$2$1.invokeSuspend(Server.kt:149)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:34)
at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100)
at kotlinx.coroutines.EventLoopImplBase.processNextEvent(EventLoop.common.kt:263)
at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:94)
at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:70)
at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source)
at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:48)
at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source)
at org.apache.airflow.sdk.execution.LogSender.sendTo(Logger.kt:112)
at org.apache.airflow.sdk.execution.LogSender.configure(Logger.kt:88)
at org.apache.airflow.sdk.Server$serveAsync$2$2.invokeSuspend(Server.kt:155)
at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:34)
at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:100)
at kotlinx.coroutines.EventLoopImplBase.processNextEvent(EventLoop.common.kt:263)
at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:94)
at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:70)
at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source)
at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:48)
at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source)
at org.apache.airflow.sdk.Server.serve(Server.kt:121)
at org.apache.airflow.example.ExampleBundleBuilder.main(ExampleBundleBuilder.java:35)
[2026-06-11 14:44:13] ERROR - java.lang.ClassCastException: class java.lang.Long cannot be cast to class java.lang.Integer (java.lang.Long and java.lang.Integer are in module java.base of loader 'bootstrap')
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.Client.getConnection(Client.kt:82)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.example.AnnotationExample.extractValue(AnnotationExample.java:39)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.example.AnnotationExampleBuilder$ExtractValue.execute(AnnotationExampleBuilder.java:23)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.execution.TaskRunner.runTask$sdk(Task.kt:66)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.execution.TaskKt.runTask(Task.kt:80)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.execution.CoordinatorComm.handleIncoming(Comm.kt:105)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.execution.CoordinatorComm$startProcessing$2.invoke(Comm.kt:62)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.execution.CoordinatorComm$startProcessing$2.invoke(Comm.kt:62)
[2026-06-11 14:44:13] ERROR - at org.apache.airflow.sdk.execution.CoordinatorComm.processOnce(Comm.kt:87)
```
## What
- Fix the `Long` to `Int` casting error at Java-SDK connection client side
- Fill the Java-SDK e2e test gap by using connection with all the available fields (`port`, `extra`, `conn_type`) etc.
---
##### Was generative AI tooling used to co-author this PR?
- [x] Yes, with help of Claude Code (Opus 4.8) following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] Fix Java-SDK connection port casting [airflow]
Posted by "jason810496 (via GitHub)" <gi...@apache.org>.
jason810496 merged PR #68433:
URL: https://github.com/apache/airflow/pull/68433
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] Fix Java-SDK connection port casting [airflow]
Posted by "jason810496 (via GitHub)" <gi...@apache.org>.
jason810496 commented on PR #68433:
URL: https://github.com/apache/airflow/pull/68433#issuecomment-4689066831
The CI failure was caused by edge worker static error (and it was just merged a few minutes ago). Merging this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org