https://linen.dev logo
Join Slack
Powered by
# general
  • s
    This message was deleted.
    r
    • 2
    • 1
  • s
    This message was deleted.
    r
    o
    a
    • 4
    • 6
  • s
    This message was deleted.
    r
    r
    c
    • 4
    • 10
  • r
    Is there anyway to pass a Lookup function to TIME_FORMAT, something like below. gives error 
    java.lang.AssertionError: not a literal: LOOKUP(CONCAT($81, ''), 'TestTimeZone')
    does that mean we can not pass a function
    Copy code
    SELECT
  TIME_FORMAT(__time,'YYYY_MM_dd', LOOKUP(CONCAT(somecolumname,''), 'TestTimeZone')),
  column2
FROM sometable
  • s
    This message was deleted.
    b
    r
    • 3
    • 2
  • s
    This message was deleted.
    d
    s
    • 3
    • 2
  • s
    This message was deleted.
    b
    m
    +5
    • 8
    • 20
  • p
    I’m hosting a Drop-in in about 45 mins for an hour for coffee and Druid chat if anyone would like to come along! https://www.meetup.com/apache-druid-london/events/290038185/
    🎉 1
  • s
    This message was deleted.
    b
    k
    • 3
    • 2
  • s
    This message was deleted.
    b
    k
    • 3
    • 2
  • s
    I am willing to help for druid integration
  • s
    Office Hours today at 10AM PST- join us for this informal session where we talk about Druid, answer questions, discuss use cases, and talk about your experiences with Druid. https://www.meetup.com/druidio/events/290102051/
    🎉 3
  • s
    This message was deleted.
    b
    • 2
    • 1
  • s
    This message was deleted.
    b
    i
    • 3
    • 4
  • s
    Copy code
    2023-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
  • s
    This message was deleted.
    b
    • 2
    • 1
  • v
    Reset the supervisor. There is a mismatch in the current offset in kafka and what druid is tracking. Resetting the supervisor will reset the offset in druid
  • s
    This message was deleted.
    b
    b
    • 3
    • 2
  • b
    Hi There, how to run the program after the maven build?
  • s
    This message was deleted.
    v
    a
    +2
    • 5
    • 14
  • s
    This message was deleted.
    j
    j
    +2
    • 5
    • 15
  • c
    When I config the log output of the druid servers to display location information for debugging purposes (class, method, line) I only see the
    Copy code
    org.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?
  • s
    This message was deleted.
    😁 2
    v
    s
    • 3
    • 5
  • v
    I am back with another edition of Apache Druid Drop-in with an exciting Menu of topics to discuss 1) What makes Druid so special 2) Latest and greatest - MSQ and Nested columns 3) Druid as a feature store - speeding up model training 4) An analytic application with Nifi, Kafka and Druid. https://www.meetup.com/delhi-apache-druid-meetup-group/events/290191736
    🚀 2
  • s
    This message was deleted.
    p
    t
    b
    • 4
    • 7
  • g
    Do the pydruid support tls or ssl certificate for verification to connect to druid ?
  • s
    This message was deleted.
    🔥 1
    p
    s
    p
    • 4
    • 4
  • s
    This message was deleted.
    👀 1
    c
    i
    • 3
    • 2
  • s
    This message was deleted.
    k
    k
    +2
    • 5
    • 4
  • s
    This message was deleted.
    b
    • 2
    • 1
1...8910...35Latest