jmilagroso
jmilagroso
Hi @iamwithnail. I am using 2.7 version. I ended up using the nodejs version of this. (1 problem though, it doesn't seem to import the partitions on tables) Thanks!
> Found the solution to this is to pin the SQLAlchemy==1.3.15 from [apache/airflow#8211](https://github.com/apache/airflow/issues/8211) > This is recent issue, and I'll keep this issue open for users who might find it....
Tried `master` branch. Experiencing same issue. OS: **centos-release-7-7.1908.0.el7.centos.x86_64** Go: **go version go1.12 linux/amd64** Kafka: **2.2.1** Encountered the same issue. **Steps to replicate:** 1. Create kafka topic 2. Delete kafka topic...
Thanks @zhigang, was able to get it running on local with 1 zk and 2 kafka brokers. Zookeeper 3.4.13 Kafka 2.2.1 CMAK 3.0.0.5
> > I ran into the same issue. As a workaround, I had to create /kafka-manager/mutex/locks and /kafka-manager/mutex/leases nodes manually. After that, I am able to add clusters. > >...
> When I try the same with a date type column using **pyspark**, > > ``` > [{ > "expectation_type": "expect_column_min_to_be_between", > "kwargs": { > "column": "started", > "min_value": "2020-12-13"...