Hello Team, I have enabled the kerberos authentication & ranger authorization to Druid, but getting this error from router logs.

==> /var/log/druid/router.log <==
2023-11-28T06:13:35,037 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - ==> PolicyRefresher(serviceName=druiddev).loadPolicy()
2023-11-28T06:13:35,037 DEBUG [Thread-12] org.apache.ranger.perf.policyengine.init - In-Use memory: 105841104, Free memory:938016304
2023-11-28T06:13:35,037 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - ==> PolicyRefresher(serviceName=druiddev).loadPolicyfromPolicyAdmin()
2023-11-28T06:13:35,037 DEBUG [Thread-12] org.apache.ranger.admin.client.RangerAdminRESTClient - ==> RangerAdminRESTClient.getServicePoliciesIfUpdated(-1, 0)
2023-11-28T06:13:35,037 DEBUG [Thread-12] org.apache.ranger.admin.client.RangerAdminRESTClient - Checking Service policy if updated as user : druid (auth:SIMPLE)
2023-11-28T06:13:35,037 DEBUG [Thread-12] org.apache.hadoop.security.UserGroupInformation - PrivilegedAction [as: druid (auth:SIMPLE)][action: org.apache.ranger.admin.client.RangerAdminRESTClient$3@28722562]
java.lang.Exception: null
	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1873) ~[?:?]
	at org.apache.ranger.admin.client.RangerAdminRESTClient.getServicePoliciesIfUpdated(RangerAdminRESTClient.java:137) ~[?:?]
	at org.apache.ranger.plugin.util.PolicyRefresher.loadPolicyfromPolicyAdmin(PolicyRefresher.java:251) ~[?:?]
	at org.apache.ranger.plugin.util.PolicyRefresher.loadPolicy(PolicyRefresher.java:191) ~[?:?]
	at org.apache.ranger.plugin.util.PolicyRefresher.run(PolicyRefresher.java:161) ~[?:?]
2023-11-28T06:13:35,040 WARN [Thread-12] org.apache.ranger.admin.client.RangerAdminRESTClient - Error getting policies. secureMode=true, user=druid (auth:SIMPLE), response={"httpStatusCode":401,"statusCode":0}, serviceName=druiddev
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.admin.client.RangerAdminRESTClient - <== RangerAdminRESTClient.getServicePoliciesIfUpdated(-1, 0): null
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - PolicyRefresher(serviceName=druiddev).run(): no update found. lastKnownVersion=-1
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.perf.policyengine.init - [PERF] PolicyRefresher.loadPolicyFromPolicyAdmin(serviceName=druiddev): 3
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - <== PolicyRefresher(serviceName=druiddev).loadPolicyfromPolicyAdmin()
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - ==> PolicyRefresher(serviceName=druiddev).loadFromCache()
2023-11-28T06:13:35,040 WARN [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - cache file does not exist or not readable '/etc/ranger/druid/policycache/druid_druiddev.json'
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - <== PolicyRefresher(serviceName=druiddev).loadFromCache()
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.perf.policyengine.init - In-Use memory: 106420200, Free memory:937437208
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.perf.policyengine.init - [PERF] PolicyRefresher.loadPolicy(serviceName=druiddev): 3
2023-11-28T06:13:35,040 DEBUG [Thread-12] org.apache.ranger.plugin.util.PolicyRefresher - <== PolicyRefresher(serviceName=druiddev).loadPolicy()

What could be the issue.? any help would be appreciated.

Hi, I am getting below error in async queries after completion. query_worker and query_controller both task type are successful.

{
  "error": "druidException",
  "errorCode": "notFound",
  "persona": "USER",
  "category": "NOT_FOUND",
  "errorMessage": "Query [query-7a1493c9-8b80-4f67-babd-39f5b314f8888] was not found. The query details are no longer present or might not be of the type [query_controller]. Verify that the id is correct.",
  "context": {}
}

Hi Team, We have a use case where we are dealing with Data at scale say, 100K Req/Min. The Data will be further processed and each data point will go through multiple status changes. Owing to the fact that the Data Point is going to go through multiple status cycles, there will be duplicate entries in the Druid System (Data is flowing via Kakfa Stream). We are still wondering, if Druid is the real candidate for such use case? If yes, What is the best way to configure it.

We are encountering an issue in a specific scenario where some of our query results contain emojis. The API server connects to Druid via a router to execute the query, but the results do not display the emojis as expected. However, when we connect to Druid using the broker's endpoint, we receive the desired results. Our Druid cluster is deployed on Kubernetes 1.25, with Druid Operator version 1.1.1 and Druid version 27.0.0. After going through the Druid documentation, it appears that the broker's endpoint is the recommended JDBC endpoint. Nevertheless, we came across a document stating that the router provides connection stickiness to brokers, especially when there are multiple brokers. In our environment, we have 2 brokers and utilize a Cluster IP service to expose the endpoints. Could the absence of connection stickiness become an issue in the future? Is it advisable to configure session affinity in the ClusterIP service to ensure connection stickiness? Here is the document that I was referring to: https://druid.apache.org/docs/latest/api-reference/sql-jdbc/ Any assistance or suggestions would be greatly appreciated.

Trying to enable TLS , below are the router and coordinator logs. Anyone can help me in knowing where to check for this error

ERROR [CoordinatorRuleManager-Exec--0] org.apache.druid.server.router.CoordinatorRuleManager - Exception while polling for rules

org.apache.druid.java.util.common.IOE: A leader node could not be found for [COORDINATOR] service. Check logs of service [COORDINATOR] to confirm it is healthy.

Hey guys, we're trying to use pac-4j auth with google to authenticate console open and use basicMetaDataAuth for API And internal process communication. We have using druid helm chart to build druid. We have added MyBasicMetadataAuthenticator to our general config 1. When adding druid_auth_authenticatorChain: '["pac4j","MyBasicMetadataAuthenticator"]' to router config a. We are seeing oAuth redirection happen correctly b. But Druid status is resulting in 403 : {"Access-Check-Result":"Allowed:false, Message:"} c. Have tried adding an escalator to each of the nodes but no avail 2. When adding druid_auth_authenticatorChain: '["MyBasicMetadataAuthenticator", "pac4j"]' to router config: a. We are seeing oAuth redirection happen correctly b. We are being prompted to re enter credentials when successfull redirection happening c. Druid status is resulting correctly d. This is happening probably because google oAuth flow gets hit first and the basic auth flow happens after 3. When adding druid_auth_authenticatorChain: '["pac4j"]' to router config: a. We are seeing oAuth redirection happen correctly b. We are being prompted to re enter credentials when successfull redirection happening c. Druid status is resulting correctly d. Same result as above I wanted to ask if both these authenticators can be used together or not? If not what should I be doing. If they can be used together, how is that to be achieved? @Hemant Had a similar use case earlier to if this can be helped with it would be awesome. There is very little documentation on this integration.

Since Druid 28 switched the default for null handling, I need to revisit how to handle that. Questions unanswered after reading documentation: • What happens if

useDefaultValueForNull=true

and a query against a segment build with

useDefaultValueForNull=false

is executed? Will the result be defaulted where null is stored? • Is it possible to have

useDefaultValueForNull=true

in query but

useDefaultValueForNull=false

in intake? (I.e. prepare the migration and start created new-style segments as early as possible)

Hello, I'm having an issue with druid-broker instances. Pods are being restarted with liveness probe (

/status/health

) returning 429 error (too many queries). In my broker config I set:

druid.broker.http.numConnections=10
druid.server.http.numThreads=41
druid.query.scheduler.numThreads=39

I thought that reserving 2 threads (difference between

druid.server.http.numThreads

and

druid.query.scheduler.numThreads

would suffice to ensure healtchecks to pass. I think I might misunderstand this. Anyone could explain?

Quick Question - Can I define the time_zone property within the timestampSpec of ingestion spec?

"timestampSpec": {
  "column": "timestamp",
  "format": "auto"
}

just linking this here in case anyone has any idea https://apachedruidworkspace.slack.com/archives/C0303FDCZEZ/p1701350556885339

Hi all, Any pointers where to check how the Auto limit works when running the query from Druid console on .22 version. issue 1)when we run the query with Autolimit off it always returns 50 rows (Actual count) but when we do Autolmit turn on it always returning random number(more than 50) tried with disabling all options but still same behavior. Issue 2 )Also when we have derived column (decimal value*100) with autolimit on it (disable all options) it always returns zero. With autolimit off it results correct value.

Hi team, can you help take a look one issue: https://github.com/apache/druid/issues/15468

Quick Question - Can I define the time_zone property within the timestampSpec of ingestion spec? other than defining within the JVM configurations?

"timestampSpec": {
  "column": "timestamp",
  "format": "auto"
}

Hello, I am getting below error after trying to hit the UI with https (TLS enabled). I can see this is a known issue -issue Tried workaround too but didn't work. Suggestions please?

ERROR [Master-PeonExec--0] org.apache.druid.server.coordinator.loading.HttpLoadQueuePeon - Request[<https://10.240.0.7:8283/druid-internal/v1/segments/changeRequests?timeout=300000>] Failed with status[0]. Reason[null].

org.jboss.netty.channel.ChannelException: Faulty channel in resource pool

at org.apache.druid.java.util.http.client.NettyHttpClient.go(NettyHttpClient.java:134) ~[druid-processing-28.0.0.jar:28.0.0]

at org.apache.druid.server.coordinator.loading.HttpLoadQueuePeon.doSegmentManagement(HttpLoadQueuePeon.java:206) ~[druid-server-28.0.0.jar:28.0.0]

at org.apache.druid.server.coordinator.loading.HttpLoadQueuePeon.lambda$start$0(HttpLoadQueuePeon.java:351) ~[druid-server-28.0.0.jar:28.0.0]

at org.apache.druid.java.util.common.concurrent.ScheduledExecutors$4.run(ScheduledExecutors.java:163) ~[druid-processing-28.0.0.jar:28.0.0]

at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_392]

at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_392]

at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) ~[?:1.8.0_392]

at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) ~[?:1.8.0_392]

at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_392]

at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_392]

at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_392]

Hey , what can be done to solve “queryType”:“segmentMetadata”, timeout , on , saw timeout for the query on broker / and historical .. where I can change the query timeout for segmentMetadata query type ?

After restarting the druid, datasources are not loaded. however, supervisor, tasks are running as expected How to troubleshoot the issue?

Hi , while running daily rollup msq job for a week data i am getting below error

"errorMsg": "CannotParseExternalData: Unable to add the row to the frame. Type conversion might be required."

Can we run multiple msq jobs for a datasource parallel with different time interval ?

Hey folks! Has anybody integrated both pac4j and jwt authentication together? pac4j is allowing me to protect the console with authentication but I am having trouble authenticating requests being sent via apis to druid. I am trying to authenticate those using jwt and there am facing some issues. If someone has done this integration, kindly help out!

Hi team, I am able to access UI/console (https) for druid on port 9088. You can see in the below screen-shots. But in the browser its says NOT SECURE (Pls refer to 1st screenshot). Let me know if this issue is because of self-signed certificate or if I can get any article wherein they have mentioned with self signed certificates it will show not secure. You can check 2 screenshot for all TLS enabled ports. Thanks in advance!

help me! status 404, when i load data from hdfs.

Hello here, I had a question. So if during the ingestion task if I have the same intervals for 2 different datasource. Why its causing issues to fail one of them and the other succeeds? Does it because of same dimension spec or something else? Here i have a task like this one which was successful

Task: index_parallel_dispatchernginxlogs_pfhjhmif_2023-12-06T11:01:54.608Z

Then i had another task which throws error like this.

2023-12-06T11:08:12,130 WARN [main] org.apache.druid.indexing.common.config.TaskConfig - Batch processing mode argument value is null or not valid:[null], defaulting to[CLOSED_SEGMENTS] 
2023-12-06T11:08:12,678 INFO [main] org.apache.druid.segment.loading.SegmentLocalCacheManager - Using storage location strategy: [LeastBytesUsedStorageLocationSelectorStrategy]
2023-12-06T11:08:12,981 WARN [main] org.eclipse.jetty.server.handler.gzip.GzipHandler - minGzipSize of 0 is inefficient for short content, break even is size 23
2023-12-06T11:08:14,499 INFO [main] org.apache.druid.segment.loading.SegmentLocalCacheManager - Using storage location strategy: [LeastBytesUsedStorageLocationSelectorStrategy]
2023-12-06T11:08:14,508 WARN [task-runner-0-priority-0] org.apache.druid.indexing.common.task.batch.parallel.ParallelIndexSupervisorTask - maxNumConcurrentSubTasks[1] is less than or equal to 1. Running sequentially. Please set maxNumConcurrentSubTasks to something higher than 1 if you want to run in parallel ingestion mode.
2023-12-06T11:08:14,530 WARN [task-runner-0-priority-0] org.apache.druid.indexing.common.task.IndexTask - Chat handler is already registered. Skipping chat handler registration.
2023-12-06T11:08:20,663 ERROR [task-runner-0-priority-0] org.apache.druid.indexing.common.task.IndexTask - Encountered exception in BUILD_SEGMENTS.
java.io.UncheckedIOException: /druiddata/tmp
	at org.apache.commons.io.FileUtils.listFiles(FileUtils.java:2135) ~[commons-io-2.11.0.jar:2.11.0]
	at org.apache.commons.io.FileUtils.iterateFiles(FileUtils.java:1904) ~[commons-io-2.11.0.jar:2.11.0]
	at org.apache.druid.data.input.impl.LocalInputSource.getDirectoryListingIterator(LocalInputSource.java:155) ~[druid-core-24.0.2.jar:24.0.2]
	at org.apache.druid.data.input.impl.LocalInputSource.getFileIterator(LocalInputSource.java:132) ~[druid-core-24.0.2.jar:24.0.2]
	at org.apache.druid.data.input.impl.LocalInputSource.formattableReader(LocalInputSource.java:201) ~[druid-core-24.0.2.jar:24.0.2]
	at org.apache.druid.data.input.AbstractInputSource.reader(AbstractInputSource.java:42) ~[druid-core-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.AbstractBatchIndexTask.inputSourceReader(AbstractBatchIndexTask.java:216) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.InputSourceProcessor.process(InputSourceProcessor.java:82) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.IndexTask.generateAndPublishSegments(IndexTask.java:922) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.IndexTask.runTask(IndexTask.java:526) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.AbstractBatchIndexTask.run(AbstractBatchIndexTask.java:187) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.batch.parallel.ParallelIndexSupervisorTask.runSequential(ParallelIndexSupervisorTask.java:1199) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.batch.parallel.ParallelIndexSupervisorTask.runTask(ParallelIndexSupervisorTask.java:532) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.common.task.AbstractBatchIndexTask.run(AbstractBatchIndexTask.java:187) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:477) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at org.apache.druid.indexing.overlord.SingleTaskBackgroundRunner$SingleTaskBackgroundRunnerCallable.call(SingleTaskBackgroundRunner.java:449) ~[druid-indexing-service-24.0.2.jar:24.0.2]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_362]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_362]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_362]
	at java.lang.Thread.run(Thread.java:750) ~[?:1.8.0_362]
Caused by: java.nio.file.NoSuchFileException: /druiddata/tmp/task/index_parallel_dispatchernginxlogs_pfhjhmif_2023-12-06T11:01:54.608Z
	at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86) ~[?:1.8.0_362]
	at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102) ~[?:1.8.0_362]
	at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107) ~[?:1.8.0_362]
	at sun.nio.fs.UnixFileSystemProvider.newDirectoryStream(UnixFileSystemProvider.java:427) ~[?:1.8.0_362]
	at java.nio.file.Files.newDirectoryStream(Files.java:457) ~[?:1.8.0_362]
	at java.nio.file.FileTreeWalker.visit(FileTreeWalker.java:300) ~[?:1.8.0_362]
	at java.nio.file.FileTreeWalker.next(FileTreeWalker.java:372) ~[?:1.8.0_362]
	at java.nio.file.Files.walkFileTree(Files.java:2706) ~[?:1.8.0_362]
	at org.apache.commons.io.FileUtils.listAccumulate(FileUtils.java:2076) ~[commons-io-2.11.0.jar:2.11.0]
	at org.apache.commons.io.FileUtils.listFiles(FileUtils.java:2132) ~[commons-io-2.11.0.jar:2.11.0]
	... 19 more
2023-12-06T11:08:20,688 WARN [task-runner-0-priority-0] org.apache.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider - handler[index_parallel_adservernginxlogs_dcfgiepc_2023-12-06T11:08:08.093Z] not currently registered, ignoring.
Finished peon task

the error is it could not find the file for the other datasource task

Caused by: java.nio.file.NoSuchFileException: /druiddata/tmp/task/index_parallel_dispatchernginxlogs_pfhjhmif_2023-12-06T11:01:54.608Z

Can someone happen to have this kind of issues?

Window function help. Does something like

SELECT FLOOR(__time TO DAY) AS event_time,
    channel,
    SUM(delta) AS change,
    RANK() OVER w AS rank_value
FROM wikipedia
WHERE '2016-06-28' > FLOOR(__time TO DAY) > '2016-06-26'
GROUP BY channel, __time
WINDOW w AS (PARTITION BY channel ORDER BY SUM(delta) ASC)

suppose to work? (getting java.lang.NullPointerException)

Hello everyone... We are running Druid in single server mode and evaluating it for our fintech use-case. What we have been observing is that sometimes druid crashes with nothing in the log but

[Thu Dec  7 06:16:02 2023] Sending signal[15] to command[middleManager] (timeout 10s).
[Thu Dec  7 06:16:07 2023] Command[middleManager] exited (pid = 898, exited = 143)
[Thu Dec  7 06:16:07 2023] Sending signal[15] to command[broker] (timeout 10s).
[Thu Dec  7 06:16:07 2023] Sending signal[15] to command[router] (timeout 10s).
[Thu Dec  7 06:16:07 2023] Sending signal[15] to command[coordinator-overlord] (timeout 10s).
[Thu Dec  7 06:16:07 2023] Sending signal[15] to command[historical] (timeout 10s).
[Thu Dec  7 06:16:08 2023] Command[router] exited (pid = 895, exited = 143)
[Thu Dec  7 06:16:08 2023] Command[broker] exited (pid = 894, exited = 143)
[Thu Dec  7 06:16:08 2023] Command[coordinator-overlord] exited (pid = 896, exited = 143)
[Thu Dec  7 06:16:08 2023] Command[historical] exited (pid = 897, exited = 143)
[Thu Dec  7 06:16:08 2023] Sending signal[15] to command[zk] (timeout 10s).
[Thu Dec  7 06:16:08 2023] Command[zk] exited (pid = 893, exited = 143)
[Thu Dec  7 06:16:08 2023] Exiting.

CPU and RAM on the machine never went above 80%

Hi all. I have some tasks status FAILED and while looking at the overlord logs, i found the following log and log's timestamp was right after task started 'Running shutdown hook'.

Task failed with status JobStatus(active=null, completedIndexes=null, completionTime=null, conditions=[JobCondition(lastProbeTime=2023-12-06T22:02:40Z, lastTransitionTime=2023-12-06T22:02:40Z, message=Job was active longer than specified deadline, reason=DeadlineExceeded, status=True, type=Failed, additionalProperties={})], failed=1, ready=1, startTime=2023-12-06T18:02:40Z, succeeded=null, uncountedTerminatedPods=UncountedTerminatedPods(failed=[], succeeded=[], additionalProperties={}), additionalProperties={})

anyone have idea?

Hi Team, I need to get the difference of first and last readings of a particular column from the data on hourly aggregation using SQL Query but not getting on how to proceed it...I had already implemented the sum, average, min and max but can someone help me out on the difference part.... Difference should be calculated as the last reading in an hour minus the first reading

SELECT FLOOR(__time to HOUR) AS ___time, Min("content.activeEnergyImportTotal"), Max("content.activeEnergyImportTotal")

, SUM("content.activeEnergyImportTotal"), AVG("content.activeEnergyImportTotal"), deviceID

from "EnergyMeterST501"

where "__time" > '2023-12-06T07:54:24.604Z' AND "deviceID"='2020070041'

GROUP BY 1, "deviceID"

I am attaching the output of rest just need to add the difference part here as well..

We have a 10 historical nodes using a local IBM COS install as S3 compatible deep storage. Segments are very slow to load from deep storage. It appears the historical nodes are only retrieving one segment at a time, even though there are hundreds needing to be loaded for the datasource to be available after ingestion. I see settings for adjusting throttling for balancing, but nothing seems to affect this initial load speed.

Hi team, We are ingesting data druid via external table with http request and we are getting 404 error. However task status is success and we can also read datasource. What can be the reason ? :

Happy to share that we didn’t observe any performance regression from Druid 25 -> 27 on our largest clusters.

Hi everyone, I require help with kafka ingestion in which I want to explode the kafka event to multiple rows based on the number of objects I receive in the kafka event as a list. Here is the sample event:

{
  "event": [
    {
      "id": 1,
      "name": "John",
      "value": 10,
      "timestamp": "2022-01-01T00:00:00Z"
    },
    {
      "id": 2,
      "name": "Jane",
      "value": 20,
      "timestamp": "2022-01-01T00:00:00Z"
    },
    {
      "id": 3,
      "name": "Bob",
      "value": 30,
      "timestamp": "2022-01-01T00:00:00Z"
    }
  ]
}

Here the desired rows in the druid data source will look like:

id	name	value	timestamp
1	John	10	    2022-01-01T00:00:00Z
2	Jane	20	    2022-01-01T00:00:00Z
3	Bob	    30	    2022-01-01T00:00:00Z