alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-6767 Add missing type name

Browse Source
This commit is contained in:
Jiri Pechanec 2023-08-07 12:42:23 +02:00
parent 637de1f9d3
commit 3aa6759ebd
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/UnchangedToastedPlaceholder.java
View File

@ -24,7 +24,7 @@ public class UnchangedToastedPlaceholder {
private final Map<Object, Object> placeholderValues = new HashMap<Object, Object>();
private final byte[] toastPlaceholderBinary;
private final String toastPlaceholderString;
private final Map toastPlaceholderHstore = new HashMap<String, String>();
private final Map<String, String> toastPlaceholderHstore = new HashMap<>();
public UnchangedToastedPlaceholder(PostgresConnectorConfig connectorConfig) {
toastPlaceholderBinary = connectorConfig.getUnavailableValuePlaceholder();

1
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/UnchangedToastedReplicationMessageColumn.java
View File

@ -61,6 +61,7 @@ private void setUnchangedToastValue(String typeWithModifiers) {
break;
case "integer[]":
case "_int4":
case "date[]":
case "_date":
unchangedToastValue = UNCHANGED_INT_ARRAY_TOAST_VALUE;
break;

2
debezium-connector-postgres/src/test/java/io/debezium/connector/postgresql/TestHelper.java
View File

@ -124,7 +124,7 @@ public static ReplicationConnection createForReplication(String slotName, boolea
*/
public static PostgresConnectorConfig.LogicalDecoder decoderPlugin() {
final String s = System.getProperty(PostgresConnectorConfig.PLUGIN_NAME.name());
return (s == null || s.length() == 0) ? PostgresConnectorConfig.LogicalDecoder.PGOUTPUT : PostgresConnectorConfig.LogicalDecoder.parse(s);
return (s == null || s.length() == 0) ? PostgresConnectorConfig.LogicalDecoder.DECODERBUFS : PostgresConnectorConfig.LogicalDecoder.parse(s);
}
/**