Hi Dremio,
I am trying to build a quick AWS Athena Connector using dremio-sqllite-connector and dremio-snowflake-connector and i think i am able to query AWS Metadata ( Tables & Databases). Whenever i try to run SELECT Query, i am getting following exception.
I have built the connector in Windows 8 Laptop
com.fasterxml.jackson.core.JsonParseException: Illegal unquoted character ((CTRL-CHAR, code 13)): has to be escaped using backslash to be included in string value
at [Source: (String)"{
"“00-00"”: {
““op””: “com.dremio.exec.planner.physical.ScreenPrel”,
““values””: {},
““inputs””: [
“00-01”
],
““rowType””: “RecordType(VARCHAR(65536) Fragment, BIGINT Records, VARCHAR(65536) Path, VARBINARY(65536) Metadata, INTEGER Partition, BIGINT FileSize)”,
““rowCount””: 2000.0,
““cumulativeCost””: “{2508643.0 rows, 9.009123824683481E8 cpu, 8.9871912E8 io, 8.9871912E8 network, 0.0 memory}”
},
"“00-01"”: {
““op””: “com.dremio.exec”[truncated 7474 chars]; line: 76, column: 28]
at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1804) ~[jackson-core-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:693) ~[jackson-core-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.core.base.ParserMinimalBase._throwUnquotedSpace(ParserMinimalBase.java:657) ~[jackson-core-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.core.json.ReaderBasedJsonParser._finishString2(ReaderBasedJsonParser.java:2053) ~[jackson-core-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.core.json.ReaderBasedJsonParser._finishString(ReaderBasedJsonParser.java:2024) ~[jackson-core-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.core.json.ReaderBasedJsonParser.getText(ReaderBasedJsonParser.java:278) ~[jackson-core-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.UntypedObjectDeserializer$Vanilla.deserialize(UntypedObjectDeserializer.java:672) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.UntypedObjectDeserializer$Vanilla.mapObject(UntypedObjectDeserializer.java:871) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.UntypedObjectDeserializer$Vanilla.deserialize(UntypedObjectDeserializer.java:654) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.UntypedObjectDeserializer$Vanilla.mapObject(UntypedObjectDeserializer.java:880) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.UntypedObjectDeserializer$Vanilla.deserialize(UntypedObjectDeserializer.java:654) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.MapDeserializer._readAndBindStringKeyMap(MapDeserializer.java:527) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:364) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.deser.std.MapDeserializer.deserialize(MapDeserializer.java:29) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4013) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3004) ~[jackson-databind-2.9.9.jar:2.9.9]
at com.dremio.service.jobs.QueryProfileParser.parsePhysicalPlan(QueryProfileParser.java:312) [dremio-services-jobs-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at com.dremio.service.jobs.QueryProfileParser.parse(QueryProfileParser.java:343) [dremio-services-jobs-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at com.dremio.service.jobs.QueryProfileParser.(QueryProfileParser.java:98) [dremio-services-jobs-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at com.dremio.service.jobs.LocalJobsService.addAttemptToJob(LocalJobsService.java:1566) [dremio-services-jobs-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at com.dremio.service.jobs.LocalJobsService.access$1200(LocalJobsService.java:199) [dremio-services-jobs-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at com.dremio.service.jobs.LocalJobsService$QueryListener.execCompletion(LocalJobsService.java:1055) [dremio-services-jobs-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756
]
at com.dremio.exec.planner.observer.OutOfBandQueryObserver$1.run(OutOfBandQueryObserver.java:50) [dremio-sabot-kernel-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at com.dremio.common.SerializedExecutor$RunnableProcessor.run(SerializedExecutor.java:96) [dremio-services-base-rpc-3.3.1-201907291852280797-df23756.jar:3.3.1-201907291852280797-df23756]
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [na:1.8.0_201]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [na:1.8.0_201]
at java.lang.Thread.run(Unknown Source) [na:1.8.0_201]
Please let me know how to address the above exception… .I feel i am very close to building Connector for AWS Athena ( A massive thanks to Snowflake connector as it has the extensive datatype and function mapping, without that example, it would be very time consuming)