removed logs

yugabyte · Apr 24, 2023 · 6b9dce2 · 6b9dce2
1 parent 5fd76c1
commit 6b9dce2
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 459 deletions.
diff --git a/src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java b/src/main/java/io/aiven/kafka/connect/transforms/ExtractTopic.java
@@ -62,7 +62,6 @@ public void configure(final Map<String, ?> settings) {
     @Override
     public R apply(final R record) {
         final SchemaAndValue schemaAndValue = getSchemaAndValue(record);
-        log.info("Picking record " + record);
         if (schemaAndValue.schema() == null) {
             throw new DataException(dataPlace() + " schema can't be null: " + record);
         }

diff --git a/src/main/java/io/debezium/connector/yugabytedb/YugabyteDBConsistentStreamingSource.java b/src/main/java/io/debezium/connector/yugabytedb/YugabyteDBConsistentStreamingSource.java
@@ -93,8 +93,6 @@ protected void getChanges2(ChangeEventSourceContext context,
                 opId = YugabyteDBOffsetContext.streamingStartLsn();
             }
 
-            LOGGER.info("Tablet {} belongs to table {}", entry.getValue(), tableIdToTable.get(entry.getKey()).getName());
-
             YBPartition partition = new YBPartition(entry.getKey(), entry.getValue(), false);
             offsetContext.initSourceInfo(partition, this.connectorConfig, opId);
             schemaNeeded.put(partition.getId(), Boolean.TRUE);
@@ -209,7 +207,6 @@ protected void getChanges2(ChangeEventSourceContext context,
                                     .getResp()
                                     .getCdcSdkProtoRecordsList()) {
                                 CdcService.RowMessage.Op op = record.getRowMessage().getOp();
-                                LOGGER.info("Record seen: {}", record.getRowMessage());
 
                                 if (record.getRowMessage().getOp() == CdcService.RowMessage.Op.DDL) {
                                     YbProtoReplicationMessage ybMessage = new YbProtoReplicationMessage(record.getRowMessage(), this.yugabyteDBTypeRegistry);
@@ -233,8 +230,6 @@ protected void getChanges2(ChangeEventSourceContext context,
                                 offsetContext.getSourceInfo(part).updateLastCommit(finalOpid);
                                 LOGGER.debug("The final opid is " + finalOpid);
                             }
-                        } else {
-                            LOGGER.info("Merge slot not empty for {}", tabletId);
                         }
 
                         probeConnectionIfNeeded();
@@ -255,7 +250,6 @@ protected void getChanges2(ChangeEventSourceContext context,
                         CdcService.RowMessage m = message.record.getRowMessage();
                         YbProtoReplicationMessage ybMessage = new YbProtoReplicationMessage(
                                 m, this.yugabyteDBTypeRegistry);
-                        LOGGER.info("Dispatching record: {}", message.record.getRowMessage());
                         dispatchMessage(offsetContext, schemaNeeded, recordsInTransactionalBlock,
                                 beginCountForTablet, message.tablet, new YBPartition(message.tableId, message.tablet, false),
                                 message.snapShotTime.longValue(), message.record, m, ybMessage);

diff --git a/src/main/java/io/debezium/connector/yugabytedb/consistent/Merger.java b/src/main/java/io/debezium/connector/yugabytedb/consistent/Merger.java
@@ -21,9 +21,6 @@ public class Merger {
     private final Map<String, List<Message>> mergeSlots = new HashMap<>();
     private final Map<String, BigInteger> tabletSafeTime = new HashMap<>();
 
-    // This is a workaround to store the last record for the tablet.
-    private final Map<String, Message> lastRecord = new HashMap<>();
-
     public Merger(List<String> tabletList) {
         tabletList.forEach(tabletId -> {
             mergeSlots.put(tabletId, new ArrayList<>());
@@ -42,7 +39,6 @@ public synchronized void addMessage(Message message) {
         assert message.record.getRowMessage().getOp() != CdcService.RowMessage.Op.DDL;
 
         setTabletSafeTime(message.tablet, message.commitTime, message);
-        lastRecord.put(message.tablet, message);
         if (message.record.getRowMessage().getOp() == CdcService.RowMessage.Op.SAFEPOINT) {
             LOGGER.debug("Received safe point message {}", message);
             return;
@@ -80,8 +76,7 @@ public void setTabletSafeTime(String tabletId, BigInteger safeTime, Message m) {
                                         + tabletId + " Current safetime value: "
                                         + this.tabletSafeTime.get(tabletId).toString()
                                         + " Attempted set value: " + safeTime.toString();
-            LOGGER.error("VKVK record which attempted to set the value {}", m);
-            LOGGER.error("VKVK last record: {}", lastRecord.get(tabletId));
+            LOGGER.error("Record which attempted to set the value {}", m);
             throw new AssertionError(errorMessage);
         }
         LOGGER.info("Updating safetime for tablet {}:{}, verifying {}", tabletId, safeTime, this.tabletSafeTime.get(tabletId));