drill-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Carlos Manuel Fernandes (DSI)" <carlos.antonio.fernan...@cgd.pt>
Subject Netezza jdbc error
Date Thu, 17 Nov 2016 17:22:30 GMT
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.


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message