!/bin/bash
# First find the Imply init script 
RUNDRUID=$(find /opt/grove -name run-druid | grep -v dist)
# and add the desired environment variable before starting the Imply processes
sed -i '/^exec.*/i export\ KAFKA_JAAS_CONFIG="org.apache.kafka.common.security.plain.PlainLoginModule  required username='\'123434\'' password='\'123\+abcdee\'';"' ${RUNDRUID}

#!/bin/bash

RUNDRUID=$(find /opt/grove -name run-druid | grep -v dist | head -n 1)
if [ -z "$RUNDRUID" ]; then
  echo "run-druid script not found."
  exit 1
fi


sed -i "/^exec.*/i export KAFKA_JAAS_CONFIG=\"org.apache.kafka.common.security.plain.PlainLoginModule required username='${USERNAME}' password='${PASSWORD}';\"" "$RUNDRUID"

sudo -u grove cat /proc/71938/environ | tr '\0' '\n' | grep KAFKA_JAAS_CONFIG
KAFKA_JAAS_CONFIG=org.apache.kafka.common.security.plain.PlainLoginModule required username='' password='';

“The input format to parse the Kafka key only processes the first entry of the

inputFormat

field. If your key values are simple strings, you can use the

tsv

format to parse them. Note that for

tsv

,

csv

, and

regex

formats, you need to provide a

columns

array to make a valid input format. Only the first one is used, and its name will be ignored in favor of

keyColumnName

.”

34.0.0

Not enough memory

sortMergeJoin

org.apache.druid.server.metrics.QueryCountStatsMonitor

REPLACE INTO "test-ds" OVERWRITE WHERE __time >= CURRENT_TIMESTAMP - INTERVAL '1' DAY

Invalid OVERWRITE WHERE clause [`__time` >= CURRENT_TIMESTAMP - INTERVAL '1' DAY]: Cannot get a timestamp from sql expression [CURRENT_TIMESTAMP - INTERVAL '1' DAY]

Cannot construct instance of `org.apache.druid.data.input.protobuf.SchemaRegistryBasedProtobufBytesDecoder`, problem: io/confluent/kafka/schemaregistry/protobuf/ProtobufSchemaProvider

extensions/protobuf-extensions

extensions/druid-protobuf-extensions

exportResults

druid.extensions.loadList:  '["/opt/druid/extensions/maha-druid-lookups","/opt/druid/extensions/druid-datasketches", "/opt/druid/extensions/druid-avro-extensions","/opt/druid/extensions/druid-s3-extensions", "/opt/druid/extensions/mysql-metadata-storage", "/opt/druid/extensions/druid-kafka-indexing-service","/opt/druid/extensions/druid-orc-extensions","/opt/druid/extensions/druid-multi-stage-query","/opt/druid/extensions/statsd-emitter"]'
  "druid.msq.intermediate.storage.enable": "true",
  "druid.msq.intermediate.storage.type": "s3",
  "druid.msq.intermediate.storage.bucket": "{{aws_account_id}}-demand-reporting-druid-prod-{{ aws_region}}",
  "druid.msq.intermediate.storage.prefix": "reports",
  druid.msq.intermediate.storage.tempDir: '/data/msq'
  druid.export.storage.s3.tempLocalDir: '/tmp/msq'
  druid.export.storage.s3.allowedExportPaths: '["<s3://demand-reporting-asyncreports-druid-prod/export/>"]'
  druid.export.storage.s3.chunkSize: 500MiB

ORDER BY

GROUP BY

ORDER BY

SELECT
  question_id AS QUESTION_ID,
  COUNT(*) count_row,
  SUM(count_responses) AS TOTAL_RESPONSES,
  SUM(
    CASE
      WHEN option_id IS NULL OR option_id = '' THEN count_responses
      ELSE 0
    END
  ) AS SKIPPED,
  SUM(
    CASE
      WHEN option_id IS NOT NULL AND option_id != '' THEN count_responses
      ELSE 0
    END
  ) AS RESPONDED
FROM daily_ceu_question_response
WHERE
  account_id = 'dffdc481-a01f-4051-8d3b-971a925bae14'
  AND event_date >= '2025-09-01'
  AND event_date <= '2025-09-30'
GROUP BY
  question_id

question_id

ORDER BY

ORDER BY SKIPPED DESC

question_id

-- Same query as above, with this line added at the end:
ORDER BY SKIPPED DESC

question_id

066a8c94-...-bac7d1

ORDER BY

tieredReplicants

tieredReplicants: 5