Skip to content

Commit 4e49bf1

Browse files
CONN-10463 Leftovers after abandoning Jackson serialization (#1142)
1 parent 85be471 commit 4e49bf1

File tree

2 files changed

+0
-7
lines changed

2 files changed

+0
-7
lines changed

src/main/java/com/snowflake/kafka/connector/internal/streaming/v2/SnowpipeStreamingV2PartitionChannel.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -256,8 +256,6 @@ private void transformAndSend(SinkRecord kafkaSinkRecord) {
256256

257257
private Optional<RowSchema.Error> validateRecord(Map<String, Object> transformedRecord) {
258258
Map<String, Object> fieldsToValidate = new HashMap<>(transformedRecord);
259-
// skip RECORD_METADATA cause SSv1 validations don't accept POJOs
260-
fieldsToValidate.remove("RECORD_METADATA");
261259
return Optional.ofNullable(
262260
rowSchemaManager.get(tableName, connectorConfig).validate(fieldsToValidate));
263261
}

src/test/java/com/snowflake/kafka/connector/streaming/iceberg/sql/MetadataRecord.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -58,27 +58,22 @@ public String getKey() {
5858
return key;
5959
}
6060

61-
@JsonProperty("schema_id")
6261
public Integer getSchemaId() {
6362
return schemaId;
6463
}
6564

66-
@JsonProperty("key_schema_id")
6765
public Integer getKeySchemaId() {
6866
return keySchemaId;
6967
}
7068

71-
@JsonProperty("CreateTime")
7269
public Long getCreateTime() {
7370
return createTime;
7471
}
7572

76-
@JsonProperty("LogAppendTime")
7773
public Long getLogAppendTime() {
7874
return logAppendTime;
7975
}
8076

81-
@JsonProperty("SnowflakeConnectorPushTime")
8277
public Long getSnowflakeConnectorPushTime() {
8378
return snowflakeConnectorPushTime;
8479
}

0 commit comments

Comments
 (0)