Error encountered while normalizing MySQL

Summary

Encountered an error while normalizing MySQL in Airbyte connector. The error message indicates a failure in the normalization process.


Question

hi team please help me

Encountered an error while normalizing MySQL.

2023-12-25 13:12:16 normalization > from normalization.transform_config.transform import main
2023-12-25 13:12:16 INFO i.a.w.t.TemporalAttemptExecution(lambda$getWorkerThread$2):162 - Completing future exceptionally…
io.airbyte.workers.exception.WorkerException: Normalization Failed.
at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:92) ~[io.airbyte-airbyte-workers-0.40.6.jar:?]
at io.airbyte.workers.general.DefaultNormalizationWorker.run(DefaultNormalizationWorker.java:27) ~[io.airbyte-airbyte-workers-0.40.6.jar:?]
at io.airbyte.workers.temporal.TemporalAttemptExecution.lambda$getWorkerThread$2(TemporalAttemptExecution.java:159) ~[io.airbyte-airbyte-workers-0.40.6.jar:?]
at java.lang.Thread.run(Thread.java:1589) [?:?]

2023-12-25 13:12:16 normalization > File “/usr/local/lib/python3.9/site-packages/airbyte_cdk/connector.py”, line 14, in <module>
2023-12-25 13:12:16 WARN i.t.i.a.POJOActivityTaskHandler(activityFailureToResult):307 - Activity failure. ActivityId=1817b4e2-ed0c-3c57-95aa-e95875ac9509, activityType=Normalize, attempt=1
java.lang.RuntimeException: io.temporal.serviceclient.CheckedExceptionWrapper: java.util.concurrent.ExecutionException: io.airbyte.workers.exception.WorkerException: Normalization Failed.
at io.airbyte.workers.temporal.TemporalUtils.withBackgroundHeartbeat(TemporalUtils.java:310) ~[io.airbyte-airbyte-workers-0.40.6.jar:?]
at io.airbyte.workers.temporal.sync.NormalizationActivityImpl.normalize(NormalizationActivityImpl.java:80) ~[io.airbyte-airbyte-workers-0.40.6.jar:?]
at jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104) ~[?:?]
at java.lang.reflect.Method.invoke(Method.java:578) ~[?:?]


2023-12-25 13:12:16 normalization > File “pydantic/init.py”, line 2, in init pydantic.init
2023-12-25 13:12:16 normalization > File “pydantic/dataclasses.py”, line 41, in init pydantic.dataclasses
2023-12-25 13:12:16 normalization > # | <blank> | No action: no method is added. |
2023-12-25 13:12:16 normalization > ImportError: cannot import name dataclass_transform
2023-12-25 13:12:16 ERROR i.t.i.s.WorkflowExecuteRunnable(logWorkflowExecutionException):125 - Workflow execution failure WorkflowId=sync_944, RunId=9e19d2f8-4087-40f3-af4b-ee2e0fbc62ce, WorkflowType=SyncWorkflow
io.temporal.failure.ActivityFailure: scheduledEventId=24, startedEventId=25, activityType=‘Normalize’, activityId=‘1817b4e2-ed0c-3c57-95aa-e95875ac9509’, identity=‘1@19936f29535b’, retryState=RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED
at java.lang.Thread.getStackTrace(Thread.java:2550) ~[?:?]
at io.temporal.internal.sync.ActivityStubBase.execute(ActivityStubBase.java:48) ~[temporal-sdk-1.8.1.jar:?]
at io.temporal.internal.sync.ActivityInvocationHandler.lambda$getActivityFunc$0(ActivityInvocationHandler.java:77) ~[temporal-sdk-1.8.1.jar:?]
at io.temporal.internal.sync.ActivityInvocationHandlerBase.invoke(ActivityInvocationHandlerBase.java:70) ~[temporal-sdk-1.8.1.jar:?]
at jdk.proxy2.$Proxy69.normalize(Unknown Source) ~[?:?]



This topic has been created from a Slack thread to give it more visibility.
It will be on Read-Only mode here. Click here if you want to access the original thread.

Join the conversation on Slack

["error", "normalizing", "mysql", "airbyte-connector", "workerexception"]