Skip to content

Commit 2a5b522

Browse files
committed
Changed the contentType from text/plain to default content type in parquet and orc format
1 parent 3458ddb commit 2a5b522

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/io/cdap/plugin/gcp/gcs/sink/GCSBatchSink.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -430,15 +430,15 @@ public void validateContentType(FailureCollector failureCollector) {
430430
}
431431
break;
432432
case FORMAT_PARQUET:
433-
if (!contentType.equalsIgnoreCase(CONTENT_TYPE_TEXT_PLAIN)) {
433+
if (!contentType.equalsIgnoreCase(DEFAULT_CONTENT_TYPE)) {
434434
failureCollector.addFailure(String.format("Valid content type for parquet is %s",
435-
CONTENT_TYPE_TEXT_PLAIN),
435+
DEFAULT_CONTENT_TYPE),
436436
null).withConfigProperty(NAME_CONTENT_TYPE);
437437
}
438438
break;
439439
case FORMAT_ORC:
440-
if (!contentType.equalsIgnoreCase(CONTENT_TYPE_TEXT_PLAIN)) {
441-
failureCollector.addFailure(String.format("Valid content type for orc is %s", CONTENT_TYPE_TEXT_PLAIN),
440+
if (!contentType.equalsIgnoreCase(DEFAULT_CONTENT_TYPE)) {
441+
failureCollector.addFailure(String.format("Valid content type for orc is %s", DEFAULT_CONTENT_TYPE),
442442
null).withConfigProperty(NAME_CONTENT_TYPE);
443443
}
444444
break;

0 commit comments

Comments
 (0)