Fabrício Dutra
03/04/2021, 3:03 PM{
"code": 400,
"error": "Schema should not be null for REALTIME table"
}
I'm using this spec:
curl -X POST "<http://localhost:9000/tables>" -H "accept: application/json" -H "Content-Type: application/json" -d "{ \"tableName\": \"realtime_strimzi_dev_acks\", \"tableType\": \"REALTIME\", \"segmentsConfig\": { \"segmentPushType\": \"REFRESH\", \"schemaName\": \"sch_strimzi_acks\", \"replication\": \"1\", \"replicasPerPartition\": \"1\" }, \"tenants\": {}, \"tableIndexConfig\": { \"loadMode\": \"MMAP\", \"invertedIndexColumns\": [ \"column1\" ], \"streamConfigs\": { \"streamType\": \"kafka\", \"stream.kafka.consumer.type\": \"lowlevel\", \"stream.kafka.topic.name\": \"producer-test-strimzi-dev-acks-0\", \"stream.kafka.decoder.class.name\": \"org.apache.pinot.plugin.stream.kafka.KafkaJSONMessageDecoder\", \"stream.kafka.consumer.factory.class.name\": \"org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory\", \"stream.kafka.broker.list\": \"edh-kafka-brokers.ingestion.svc.Cluster.local:9092\", \"realtime.segment.flush.threshold.time\": \"3600000\", \"realtime.segment.flush.threshold.size\": \"50000\", \"stream.kafka.consumer.prop.auto.offset.reset\": \"smallest\" } }, \"metadata\": { \"customConfigs\": {} }}"
Is there a way to create a realtime table autofilling/creating a datetime column?Kishore G
Fabrício Dutra
03/04/2021, 3:39 PMNeha Pawar
Fabrício Dutra
03/04/2021, 3:54 PM{
"schemaName": "sch_strimzi_ack",
"dimensionFieldSpecs": [
{
"name": "column1",
"dataType": "STRING"
}
]
}
Chinmay Soman
03/04/2021, 4:00 PMKishore G
Fabrício Dutra
03/04/2021, 4:09 PMNeha Pawar
sch_strimzi_ack
vs
"schemaName\": \"sch_strimzi_acks\
pluralFabrício Dutra
03/04/2021, 6:58 PM{
"code": 400,
"error": "'timeColumnName' cannot be null in REALTIME table config"
}