Roger Gabarit
01/09/2023, 12:45 PMOlivier JOUSSET
01/10/2023, 4:17 PMRyan Plessner
01/10/2023, 5:59 PMRishi Rana
01/10/2023, 7:50 PMjava.lang.AssertionError: not a literal: LOOKUP(CONCAT($81, ''), 'TestTimeZone')
does that mean we can not pass a function
SELECT
TIME_FORMAT(__time,'YYYY_MM_dd', LOOKUP(CONCAT(somecolumname,''), 'TestTimeZone')),
column2
FROM sometable
Rishi Rana
01/10/2023, 7:51 PMSergio Ferragut
01/11/2023, 12:44 AMMichael Tsibelman
01/11/2023, 6:36 AMPeter Marshall
01/11/2023, 12:23 PMPramod Immaneni
01/12/2023, 10:25 PMWilliam Kennedy
01/12/2023, 10:36 PMswetha
01/13/2023, 4:16 PMSergio Ferragut
01/13/2023, 4:42 PMAgam Jain
01/14/2023, 12:01 PMIgor Berman
01/15/2023, 3:13 PMswetha
01/16/2023, 8:40 AM2023-01-16T08:38:21,728 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-kafka-supervisor-hjelfmnc-1, groupId=kafka-supervisor-hjelfmnc] Fetch position FetchPosition{offset=144333390, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-1.kafka-headless.druid.svc.cluster.local:9092 (id: 1 rack: null)], epoch=0}} is out of range for partition druid-0, raising error to the application since no reset policy is configured
2023-01-16T08:38:21,728 WARN [task-runner-0-priority-0] org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner - OffsetOutOfRangeException with message [Fetch position FetchPosition{offset=144333390, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-1.kafka-headless.druid.svc.cluster.local:9092 (id: 1 rack: null)], epoch=0}} is out of range for partition druid-0]
2023-01-16T08:38:21,728 WARN [task-runner-0-priority-0] org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner - Retrying in 30000ms
2023-01-16T08:38:51,733 INFO [task-runner-0-priority-0] org.apache.kafka.clients.consumer.internals.Fetcher - [Consumer clientId=consumer-kafka-supervisor-hjelfmnc-1, groupId=kafka-supervisor-hjelfmnc] Fetch position FetchPosition{offset=144333390, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-1.kafka-headless.druid.svc.cluster.local:9092 (id: 1 rack: null)], epoch=0}} is out of range for partition druid-0, raising error to the application since no reset policy is configured
2023-01-16T08:38:51,734 WARN [task-runner-0-priority-0] org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner - OffsetOutOfRangeException with message [Fetch position FetchPosition{offset=144333390, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[kafka-1.kafka-headless.druid.svc.cluster.local:9092 (id: 1 rack: null)], epoch=0}} is out of range for partition druid-0]
2023-01-16T08:38:51,734 WARN [task-runner-0-priority-0] org.apache.druid.indexing.kafka.IncrementalPublishingKafkaIndexTaskRunner - Retrying in 30000ms
swetha
01/16/2023, 8:40 AMVijay Narayanan
01/16/2023, 8:48 AMBoxiang Lin
01/16/2023, 10:18 PMBoxiang Lin
01/17/2023, 1:46 AM추호관
01/17/2023, 7:15 AMJoshua Liguid
01/17/2023, 6:15 PMSELECT * FROM
(SELECT *
FROM (SELECT aa.*,
RANK () OVER (PARTITION BY column1,column2,count1,count2
ORDER BY count1 DESC) rnk
FROM (SELECT
column1,
column2,
SUM (column1) count1,
SUM (column2) count2
FROM
tablename aa
GROUP BY
column 1,
column2) aa)
WHERE
rnk < 11
UNION ALL
SELECT *
FROM (SELECT aa.*,
RANK () OVER (PARTITION BY column1,column2,count1,count2
ORDER BY count2 DESC) rnk
FROM (SELECT
column1,
column2,
SUM (column1) count1,
SUM (column2) count2
FROM
tablename aa
GROUP BY
column 1,
column2) aa)
WHERE
rnk < 11)
Cory Johannsen
01/17/2023, 10:11 PMorg.apache.druid.java.util.common.logger.Logger.debug(Logger.java:91)
Not the actual line of code that logged the output. Is it possible to expose the actual location?Simple Poll
01/17/2023, 11:43 PMVijay Narayanan
01/18/2023, 4:51 AMTomer Ben David
01/18/2023, 7:59 AMAPPROX_COUNT_DISTINCT_DS_THETA
to approximate count distinct in druid SQL.
Is there a similar function for approximating variance in druid SQL?
(Looking for usage of https://druid.apache.org/docs/latest/development/extensions-core/datasketches-tuple.html#variance-values-for-each-column in my sql query)
ThanksGrandhi Venkata Manideep
01/18/2023, 10:28 AMSaydul Bashar
01/18/2023, 11:59 AMIgor Berman
01/18/2023, 5:27 PMWARN [Coordinator-Exec--0] org.apache.druid.server.coordinator.rules.LoadRule - No available [_default_tier] servers or node capacity to assign primary segment
Is there any metrics that can help to automate catching such situation? How to count available historicals from coordinator perspective?
Currently we are using rate over assigned segments, but this might be caused due to different reasons as well.Krzysztof Klimonda
01/19/2023, 12:31 PMVijay Narayanan
01/19/2023, 12:59 PM