Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jdbc sink: cannot sink a DELETE event to downstream if primary key is in uuid type #16393

Closed
StrikeW opened this issue Apr 19, 2024 · 0 comments · Fixed by #16447
Closed

Jdbc sink: cannot sink a DELETE event to downstream if primary key is in uuid type #16393

StrikeW opened this issue Apr 19, 2024 · 0 comments · Fixed by #16447
Assignees
Labels
type/bug Something isn't working
Milestone

Comments

@StrikeW
Copy link
Contributor

StrikeW commented Apr 19, 2024

Describe the bug

Cannot sink a DELETE event to downstream if primary key is in uuid type.

Error message/log

postgres-1                | 2024-04-18 03:05:50.544 UTC [196] ERROR:  operator does not exist: uuid = character varying at character 79
postgres-1                | 2024-04-18 03:05:50.544 UTC [196] HINT:  No operator matches the given name and argument types. You might need to add explicit type casts.
postgres-1                | 2024-04-18 03:05:50.544 UTC [196] STATEMENT:  DELETE FROM "public"."table" WHERE "id" = $1
postgres-1                | 	RETURNING *
postgres-1                | 2024-04-18 03:05:50.549 UTC [196] ERROR:  current transaction is aborted, commands ignored until end of transaction block
postgres-1                | 2024-04-18 03:05:50.549 UTC [196] STATEMENT:  
risingwave-standalone     | 2024-04-18T03:05:50.548864925Z ERROR ThreadId(94) risingwave_connector_node: Failed to execute JDBC statements, retried 0 times thread="Thread-111" class="com.risingwave.connector.JDBCSink"
risingwave-standalone     | 2024-04-18T03:05:50.556135466Z ERROR ThreadId(94) risingwave_connector_node: sink writer error: : io.grpc.StatusRuntimeException: INTERNAL: Error when exec 42883, message Batch entry 0 DELETE FROM "public"."table" WHERE "id" = '018eef2a-dea2-7163-849e-4ab85ce2f39a'
risingwave-standalone     | RETURNING * was aborted: ERROR: operator does not exist: uuid = character varying
risingwave-standalone     |   Hint: No operator matches the given name and argument types. You might need to add explicit type casts.
risingwave-standalone     |   Position: 79  Call getNextException to see other errors in the batch.
risingwave-standalone     | 	at io.grpc.Status.asRuntimeException(Status.java:530)
risingwave-standalone     | 	at com.risingwave.connector.JDBCSink.write(JDBCSink.java:196)
risingwave-standalone     | 	at com.risingwave.connector.SinkWriterStreamObserver.onNext(SinkWriterStreamObserver.java:132)
risingwave-standalone     | 	at com.risingwave.connector.JniSinkWriterHandler.runJniSinkWriterThread(JniSinkWriterHandler.java:40)
risingwave-standalone     |  thread="Thread-111" class="com.risingwave.connector.SinkWriterStreamObserver"
sink writer error: : io.grpc.StatusRuntimeException: INTERNAL: Error when exec 42883, message Batch entry 0 DELETE FROM "public"."table" WHERE "id" = '018eef2a-dea2-7163-849e-4ab85ce2f39a'
risingwave-standalone     | RETURNING * was aborted: ERROR: operator does not exist: uuid = character varying

To Reproduce

No response

Expected behavior

No response

How did you deploy RisingWave?

No response

The version of RisingWave

No response

Additional context

No response

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type/bug Something isn't working
Projects
None yet
Development

Successfully merging a pull request may close this issue.

1 participant