fix: set errorType for UnsupportedOperationException to INVALID_MESSAGE_ERROR (#46)

sumitaich1998 · web-flow · commit f971af108c4a · 2022-09-29T15:29:25.000+08:00
diff --git a/src/main/java/io/odpf/depot/redis/parsers/RedisParser.java b/src/main/java/io/odpf/depot/redis/parsers/RedisParser.java
@@ -40,6 +40,8 @@ public List<RedisRecord> convert(List<OdpfMessage> messages) {
                 for (RedisEntry redisEntry : redisDataEntries) {
                     records.add(new RedisRecord(redisEntry, (long) index, null, messages.get(index).getMetadataString(), true));
                 }
+            } catch (UnsupportedOperationException e) {
+                records.add(createAndLogErrorRecord(e, ErrorType.INVALID_MESSAGE_ERROR, index, messages));
             } catch (ConfigurationException e) {
                 records.add(createAndLogErrorRecord(e, ErrorType.UNKNOWN_FIELDS_ERROR, index, messages));
             } catch (IllegalArgumentException e) {

Original file line number	Diff line number	Diff line change
`@@ -40,6 +40,8 @@ public List<RedisRecord> convert(List<OdpfMessage> messages) {`
`40`	`40`	`for (RedisEntry redisEntry : redisDataEntries) {`
`41`	`41`	`records.add(new RedisRecord(redisEntry, (long) index, null, messages.get(index).getMetadataString(), true));`
`42`	`42`	`}`
	`43`	`+ } catch (UnsupportedOperationException e) {`
	`44`	`+ records.add(createAndLogErrorRecord(e, ErrorType.INVALID_MESSAGE_ERROR, index, messages));`
`43`	`45`	`} catch (ConfigurationException e) {`
`44`	`46`	`records.add(createAndLogErrorRecord(e, ErrorType.UNKNOWN_FIELDS_ERROR, index, messages));`
`45`	`47`	`} catch (IllegalArgumentException e) {`