Remove extra bracket from shouldWriteAvroAsBytes method
This commit is contained in:
Родитель
64578e2226
Коммит
9e5f495748
|
@ -263,8 +263,8 @@ public class FileWriter implements Closeable {
|
|||
}
|
||||
|
||||
private boolean shouldWriteAvroAsBytes(SinkRecord record) {
|
||||
return ((record.valueSchema().type() == Schema.Type.BYTES) &&
|
||||
(ingestionProps.getDataFormat().equals(IngestionProperties.DATA_FORMAT.avro.toString())));
|
||||
return (record.valueSchema().type() == Schema.Type.BYTES) &&
|
||||
(ingestionProps.getDataFormat().equals(IngestionProperties.DATA_FORMAT.avro.toString()));
|
||||
}
|
||||
|
||||
public void initializeRecordWriter(SinkRecord record) {
|
||||
|
|
Загрузка…
Ссылка в новой задаче