search

iannamkr / TIL

Today I Learn
4 stars 0 forks source link

[Airflow] ImportError: cannot import name '_Union' from 'typing' #9

Open iannamkr opened 3 years ago

iannamkr commented 3 years ago

happened

low_offset, high_offset = consumer.get_watermark_offsets(partition)

impl.KafkaException: KafkaError{code=_UNKNOWN_PARTITION,val=-190,
str="Failed to get watermark offsets: Local: Unknown partition"}

solution

upgrade to v1.7.0