You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@drill.apache.org by "Carlos Manuel Fernandes (DSI)" <ca...@cgd.pt> on 2016/11/17 17:22:30 UTC
Netezza jdbc error
Hello, I'm new on Apache Drill, I just installed the embedded version and successful make queries on cvs file. Its great and revolutionary to make sql queries on text files or json files.
Now I'm trying to connect Drill with Jdbc sources: Netezza, Oracle and BD2.
I Successful create a connection for Db2 and Oracle but I Have problems with Netezza. Lets see Netezza:
My Storage setup:
{
"type": "jdbc",
"driver": "org.netezza.Driver",
"url": "jdbc:netezza://xpto.foo.com:5480/PARALELO",
"username": " testes",
"password": "testes",
"enabled": true
}
And I put Netezza driver on 3rdparty directory.
After that I make:
Use Netezza.PARALELO; successful
Show tables; trows the execption below. (if I make one select statement the error is the same)
I think the problem is related with the fact I have the view V_METRICA_1_903A_CLICOMENVOLVIM in two different schemas of database PARALELO. There are some configuration on storage setup to force the schema?
Thanks
Carlos
Exception:
2016-11-17 12:34:34,293 [27d25c24-f50f-c78e-c976-44f849c068b3:foreman] INFO o.a.drill.exec.work.foreman.Foreman - Query text for query id 27d25c24-f50f-c78e-c976-44f849c068b3: show tables
2016-11-17 12:34:35,139 [27d25c24-f50f-c78e-c976-44f849c068b3:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 27d25c24-f50f-c78e-c976-44f849c068b3:0:0: State change requested AWAITING_ALLOCATION --> FAILED
2016-11-17 12:34:35,139 [27d25c24-f50f-c78e-c976-44f849c068b3:frag:0:0] INFO o.a.d.e.w.fragment.FragmentExecutor - 27d25c24-f50f-c78e-c976-44f849c068b3:0:0: State change requested FAILED --> FINISHED
2016-11-17 12:34:35,140 [27d25c24-f50f-c78e-c976-44f849c068b3:frag:0:0] ERROR o.a.d.e.w.fragment.FragmentExecutor - SYSTEM ERROR: IllegalArgumentException: Multiple entries with same key: V_METRICA_1_903A_CLICOMENVOLVIM=JdbcTable {V_METRICA_1_903A_CLICOMENVOLVIM} and V_METRICA_1_903A_CLICOMENVOLVIM=JdbcTable {V_METRICA_1_903A_CLICOMENVOLVIM}
Fragment 0:0
[Error Id: 71a29ff7-fbea-4579-b0ad-f32099b29c19 on ltc6001dwh01.grupocgd.com:31010]
org.apache.drill.common.exceptions.UserException: SYSTEM ERROR: IllegalArgumentException: Multiple entries with same key: V_METRICA_1_903A_CLICOMENVOLVIM=JdbcTable {V_METRICA_1_903A_CLICOMENVOLVIM} and V_METRICA_1_903A_CLICOMENVOLVIM=JdbcTable {V_METRICA_1_903A_CLICOMENVOLVIM}
Fragment 0:0
[Error Id: 71a29ff7-fbea-4579-b0ad-f32099b29c19 on ltc6001dwh01.grupocgd.com:31010]
at org.apache.drill.common.exceptions.UserException$Builder.build(UserException.java:543) ~[drill-common-1.8.0.jar:1.8.0]
at org.apache.drill.exec.work.fragment.FragmentExecutor.sendFinalState(FragmentExecutor.java:293) [drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.work.fragment.FragmentExecutor.cleanup(FragmentExecutor.java:160) [drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:262) [drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.common.SelfCleaningRunnable.run(SelfCleaningRunnable.java:38) [drill-common-1.8.0.jar:1.8.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) [na:1.7.0_67]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) [na:1.7.0_67]
at java.lang.Thread.run(Unknown Source) [na:1.7.0_67]
Caused by: java.lang.IllegalArgumentException: Multiple entries with same key: V_METRICA_1_903A_CLICOMENVOLVIM=JdbcTable {V_METRICA_1_903A_CLICOMENVOLVIM} and V_METRICA_1_903A_CLICOMENVOLVIM=JdbcTable {V_METRICA_1_903A_CLICOMENVOLVIM}
at com.google.common.collect.ImmutableMap.checkNoConflict(ImmutableMap.java:150) ~[guava-18.0.jar:na]
at com.google.common.collect.RegularImmutableMap.checkNoConflictInBucket(RegularImmutableMap.java:104) ~[guava-18.0.jar:na]
at com.google.common.collect.RegularImmutableMap.<init>(RegularImmutableMap.java:70) ~[guava-18.0.jar:na]
at com.google.common.collect.ImmutableMap$Builder.build(ImmutableMap.java:254) ~[guava-18.0.jar:na]
at org.apache.calcite.adapter.jdbc.JdbcSchema.computeTables(JdbcSchema.java:218) ~[calcite-core-1.4.0-drill-r17.jar:1.4.0-drill-r17]
at org.apache.calcite.adapter.jdbc.JdbcSchema.getTableMap(JdbcSchema.java:234) ~[calcite-core-1.4.0-drill-r17.jar:1.4.0-drill-r17]
at org.apache.calcite.adapter.jdbc.JdbcSchema.getTableNames(JdbcSchema.java:359) ~[calcite-core-1.4.0-drill-r17.jar:1.4.0-drill-r17]
at org.apache.drill.exec.store.jdbc.JdbcStoragePlugin$CapitalizingJdbcSchema.getTableNames(JdbcStoragePlugin.java:282) ~[drill-jdbc-storage-1.8.0.jar:1.8.0]
at org.apache.calcite.jdbc.SimpleCalciteSchema.getTableNames(SimpleCalciteSchema.java:98) ~[calcite-core-1.4.0-drill-r17.jar:1.4.0-drill-r17]
at org.apache.calcite.jdbc.CalciteAbstractSchema$SchemaPlusImpl.getTableNames(CalciteAbstractSchema.java:182) ~[calcite-core-1.4.0-drill-r17.jar:1.4.0-drill-r17]
at org.apache.calcite.jdbc.CalciteAbstractSchema$SchemaPlusImpl.getTableNames(CalciteAbstractSchema.java:143) ~[calcite-core-1.4.0-drill-r17.jar:1.4.0-drill-r17]
at org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator$Tables.visitTables(InfoSchemaRecordGenerator.java:297) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator.scanSchema(InfoSchemaRecordGenerator.java:213) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator.scanSchema(InfoSchemaRecordGenerator.java:206) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator.scanSchema(InfoSchemaRecordGenerator.java:206) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator.scanSchema(InfoSchemaRecordGenerator.java:193) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaTableType.getRecordReader(InfoSchemaTableType.java:59) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaBatchCreator.getBatch(InfoSchemaBatchCreator.java:36) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.store.ischema.InfoSchemaBatchCreator.getBatch(InfoSchemaBatchCreator.java:30) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.physical.impl.ImplCreator.getRecordBatch(ImplCreator.java:148) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.physical.impl.ImplCreator.getChildren(ImplCreator.java:171) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.physical.impl.ImplCreator.getRecordBatch(ImplCreator.java:128) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.physical.impl.ImplCreator.getChildren(ImplCreator.java:171) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.physical.impl.ImplCreator.getRootExec(ImplCreator.java:101) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.physical.impl.ImplCreator.getExec(ImplCreator.java:79) ~[drill-java-exec-1.8.0.jar:1.8.0]
at org.apache.drill.exec.work.fragment.FragmentExecutor.run(FragmentExecutor.java:206) [drill-java-exec-1.8.0.jar:1.8.0]
... 4 common frames omitted
2016-11-17 12:34:35,188 [CONTROL-rpc-event-queue] WARN o.a.drill.exec.work.foreman.Foreman - Dropping request to move to COMPLETED state as query is already at FAILED state (which is terminal).
2016-11-17 12:34:35,194 [CONTROL-rpc-event-queue] WARN o.a.d.e.w.b.ControlMessageHandler - Dropping request to cancel fragment. 27d25c24-f50f-c78e-c976-44f849c068b3:0:0 does not exist.