https://pinot.apache.org/ logo
Join SlackCommunities
Powered by
Hi, We are using pinot latest version, we are tryi...
# troubleshooting
m
Hi, We are using pinot latest version, we are trying to run query using V2 Engine. Getting following error [ { "message": "SQLParsingError\njava.lang.RuntimeException Error composing query plan for: select catalog_id from catalog_views_test\n\tat org.apache.pinot.query.QueryEnvironment.planQuery(QueryEnvironment.java:131)\n\tat org.apache.pinot.broker.requesthandler.MultiStageBrokerRequestHandler.handleRequest(MultiStageBrokerRequestHandler.java:147)\n\tat org.apache.pinot.broker.requesthandler.MultiStageBrokerRequestHandler.handleRequest(MultiStageBrokerRequestHandler.java:125)\n\tat org.apache.pinot.broker.requesthandler.BrokerRequestHandler.handleRequest(BrokerRequestHandler.java:47)\n...\nCaused by: java.lang.NumberFormatException: null\n\tat java.base/java.lang.Integer.parseInt(Integer.java:614)\n\tat java.base/java.lang.Integer.parseInt(Integer.java:770)\n\tat org.apache.pinot.core.transport.ServerInstance.<init>(ServerInstance.java:63)\n\tat org.apache.pinot.query.routing.WorkerInstance.<init>(WorkerInstance.java:40)", "errorCode": 150 } ] Please help for the same. We are exploring join feature of pinot Thanks
r
Can you share your table config and schema plz
m
sure let me share
r
Thx will take a look later
No rush
m
Schema:
Copy code
{
  "schemaName": "pinot_01_test",
  "dimensionFieldSpecs": [
    {
      "name": "email",
      "dataType": "STRING"
    },
    {
      "name": "user_id",
      "dataType": "STRING"
    },
    {
      "name": "event_time_iso",
      "dataType": "STRING"
    },
    {
      "name": "ingestion_time",
      "dataType": "STRING"
    }
  ],
  "dateTimeFieldSpecs": [
    {
      "name": "mp_processing_time_ms",
      "dataType": "LONG",
      "format": "1:MILLISECONDS:EPOCH",
      "granularity": "1:SECONDS"
    },
    {
      "name": "dateTime",
      "dataType": "STRING",
      "format": "1:MILLISECONDS:SIMPLE_DATE_FORMAT:yyyy-MM-dd'T'HH:mm:ss.SSS'Z'",
      "granularity": "1:SECONDS"
    }
  ]
}
Table:
Copy code
{
  "tableName": "pinot_01_test",
  "tableType": "REALTIME",
  "tenants": {
    "broker": "DefaultTenant",
    "server": "DefaultTenant",
    "tagOverrideConfig": {}
  },
  "segmentsConfig": {
    "schemaName": "pinot_01_test",
    "timeColumnName": "dateTime",
    "replication": "1",
    "replicasPerPartition": "1",
    "retentionTimeUnit": null,
    "retentionTimeValue": null,
    "completionConfig": null,
    "crypterClassName": null,
    "peerSegmentDownloadScheme": null
  },
  "tableIndexConfig": {
    "loadMode": "MMAP",
    "invertedIndexColumns": [],
    "createInvertedIndexDuringSegmentGeneration": false,
    "rangeIndexColumns": [],
    "sortedColumn": [],
    "bloomFilterColumns": [],
    "bloomFilterConfigs": null,
    "noDictionaryColumns": [],
    "onHeapDictionaryColumns": [],
    "varLengthDictionaryColumns": [],
    "enableDefaultStarTree": false,
    "starTreeIndexConfigs": null,
    "enableDynamicStarTreeCreation": false,
    "segmentPartitionConfig": null,
    "columnMinMaxValueGeneratorMode": null,
    "aggregateMetrics": false,
    "nullHandlingEnabled": false,
    "streamConfigs": {
      "streamType": "kafka",
      "stream.kafka.topic.name": "<topic_name>",
      "stream.kafka.broker.list": "<broker_list>",
      "stream.kafka.consumer.type": "lowlevel",
      "stream.kafka.consumer.prop.auto.offset.reset": "smallest",
      "stream.kafka.consumer.factory.class.name": "org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory",
      "stream.kafka.decoder.class.name": "org.apache.pinot.plugin.stream.kafka.KafkaJSONMessageDecoder",
      "realtime.segment.flush.threshold.rows": "0",
      "realtime.segment.flush.threshold.time": "24h",
      "realtime.segment.flush.segment.size": "100M"
    }
  },
  "metadata": {},
  "ingestionConfig": {
    "filterConfig": null,
    "transformConfigs": null
  },
  "quota": {
    "storage": null,
    "maxQueriesPerSecond": null
  },
  "task": null,
  "routing": {
    "segmentPrunerTypes": null,
    "instanceSelectorType": null
  },
  "query": {
    "timeoutMs": null
  },
  "fieldConfigList": null,
  "upsertConfig": null,
  "tierConfigs": null
}
@Rong R ^^
p
Schema of catalog_views_test table is also required I guess
r
i dont see catalog_id in the schema
Open in Slack
PreviousNext
Powered by