Skip to content

Commit 3599eb2

Browse files
author
Akash Borkar
committed
removed logging from different writer providers
1 parent 9bade0b commit 3599eb2

File tree

4 files changed

+0
-4
lines changed

4 files changed

+0
-4
lines changed

src/main/java/io/confluent/connect/hdfs/avro/AvroRecordWriterProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,6 @@ public void write(SinkRecord record) {
7373
}
7474
}
7575

76-
log.trace("Sink record: {}", record);
7776
Object value = avroData.fromConnectData(schema, record.value());
7877
try {
7978
// AvroData wraps primitive types so their schema can be included. We need to unwrap

src/main/java/io/confluent/connect/hdfs/json/JsonRecordWriterProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,6 @@ public RecordWriter getRecordWriter(final HdfsSinkConnectorConfig conf, final St
7474

7575
@Override
7676
public void write(SinkRecord record) {
77-
log.trace("Sink record: {}", record.toString());
7877
try {
7978
Object value = record.value();
8079
if (value instanceof Struct) {

src/main/java/io/confluent/connect/hdfs/parquet/ParquetRecordWriterProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,6 @@ public void write(SinkRecord record) {
9595
}
9696
}
9797

98-
log.trace("Sink record: {}", record);
9998
Object value = avroData.fromConnectData(record.valueSchema(), record.value());
10099
try {
101100
writer.write((GenericRecord) value);

src/main/java/io/confluent/connect/hdfs/string/StringRecordWriterProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,6 @@ public RecordWriter getRecordWriter(final HdfsSinkConnectorConfig conf, final St
6363

6464
@Override
6565
public void write(SinkRecord record) {
66-
log.trace("Sink record: {}", record.toString());
6766
try {
6867
String value = (String) record.value();
6968
writer.write(value);

0 commit comments

Comments
 (0)