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.
