Skip to content

[Fix][Connector-V2][Postgres-CDC] Fix PostgreSQL GEOMETRY handling with JDBC sink #10186

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.

Sign up for GitHub

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

Merged
Carl-Zhou-CN merged 6 commits into from
Jan 1, 2026
Merged

[Fix][Connector-V2][Postgres-CDC] Fix PostgreSQL GEOMETRY handling with JDBC sink #10186

Changes from 1 commit
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
9c61fdd
[Fix][Connector-V2][Postgres-CDC] Fix PostgreSQL GEOMETRY type error …
Dec 11, 2025
dd08fc3
[Fix][Connector-V2][Postgres-CDC] mvn
Dec 11, 2025
304f807
[Fix][Connector-V2][Postgres-CDC] fix ci bug
Dec 12, 2025
8ff571b
[Fix][Connector-V2][Postgres-CDC] fix ci bug 1212
Dec 12, 2025
b06d374
[Fix][Connector-V2][Postgres-CDC] Fix PostgreSQL geometry/geography h…
Dec 14, 2025
0450c22
[Fix][Connector-V2][Postgres-CDC] Use sink sourceType in PostgresJdbc…
Dec 16, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
[Fix][Connector-V2][Postgres-CDC] fix ci bug
  • Loading branch information
zengyi committed Dec 12, 2025
commit 304f807fa5902c46ae64847d0b46ca14cbca78d0
16 changes: 12 additions & 4 deletions ...eatunnel-connector-v2-e2e/connector-cdc-postgres-e2e/src/test/resources/ddl/inventory.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,9 @@ CREATE TABLE full_types_no_primary_key
f_time TIME(0),
f_default_numeric NUMERIC,
f_numeric_no_scale NUMERIC(24),
f_inet INET
f_inet INET,
f_geometry geometry(POINT, 4326),
f_geography geography(POINT, 4326)
);

CREATE TABLE full_types_no_primary_key_with_debezium
Expand All @@ -181,7 +183,9 @@ CREATE TABLE full_types_no_primary_key_with_debezium
f_time TIME(0),
f_default_numeric NUMERIC,
f_numeric_no_scale NUMERIC(24),
f_inet INET
f_inet INET,
f_geometry geometry(POINT, 4326),
f_geography geography(POINT, 4326)
);

CREATE TABLE postgres_cdc_table_3
Expand Down Expand Up @@ -297,9 +301,13 @@ VALUES (1, '2', 32767, INTERVAL '1 day 2 hours', '192.168.1.100', '192.168.1.0/2
INSERT INTO full_types_no_primary_key
VALUES (1, '2', 32767, 65535, 2147483647, 5.5, 6.6, 123.12345, 404.4443, true,
'Hello World', 'a', 'abc', 'abcd..xyz', '2020-07-17 18:00:22.123', '2020-07-17 18:00:22.123456',
'2020-07-17', '18:00:22', 500, 88,'192.168.1.1');
'2020-07-17', '18:00:22', 500, 88,'192.168.1.1',
ST_GeomFromText('POINT(-122.3452 47.5925)', 4326),
ST_GeographyFromText('POINT(-122.3452 47.5925)'));

INSERT INTO full_types_no_primary_key_with_debezium
VALUES (1, '2', 32767, 65535, 2147483647, 5.5, 6.6, 123.12345, 404.4443, true,
'Hello World', 'a', 'abc', 'abcd..xyz', '2020-07-17 18:00:22.123', '2020-07-17 18:00:22.123456',
'2020-07-17', '18:00:22', 500, 88,'192.168.1.1');
'2020-07-17', '18:00:22', 500, 88,'192.168.1.1',
ST_GeomFromText('POINT(-122.3452 47.5925)', 4326),
ST_GeographyFromText('POINT(-122.3452 47.5925)'));