confluentinc / confluentinc/cli-plugins
Flink quickstart plugin fails during creation of create_cluster_with_schema_registry
- Dominant language
- Python
- Stars
- 3
- Forks
- 2
- PR merge metrics
- No merged PRs in 30d
Description
Error:
When i run the confluent flink quickstart plugin i get the following error:
```
(venv) koushiks@KJY6YKCQPF confluent-flink-quickstart % confluent flink quickstart --name quickstart --max-cfu 10 --region us-east-1 --cloud aws --datagen-quickstarts shoe_orders shoes --debug
Creating new environment quickstart_environment
DEBUG:root:CMD args ['confluent', 'environment', 'create', 'quickstart_environment', '-o', 'json']
DEBUG:root:Debug: {'is_current': False, 'id': 'env-6wmv9q', 'name': 'quickstart_environment', 'stream_governance_package': ''}
Setting the active environment to quickstart_environment
DEBUG:root:CMD args ['confluent', 'environment', 'use', 'env-6wmv9q']
Using environment env-6wmv9q.
Searching for existing databases (Kafka clusters)
DEBUG:root:CMD args ['confluent', 'kafka', 'cluster', 'list', '-o', 'json']
DEBUG:root:Debug: []
No existing database found, will create one in us-east-1
DEBUG:root:Creating the database (Kafka cluster)
DEBUG:root:CMD args ['confluent', 'kafka', 'cluster', 'create', 'quickstart_kafka-cluster', '-o', 'json', '--cloud', 'aws', '--region', 'us-east-1']
DEBUG:root:Debug: {'is_current': False, 'id': 'lkc-q677rm', 'name': 'quickstart_kafka-cluster', 'type': 'BASIC', 'ingress_limit': 250, 'egress_limit': 750, 'storage': '5 TB', 'cloud': 'aws', 'region': 'us-east-1', 'availability': 'single-zone', 'status': 'PROVISIONING', 'endpoint': 'SASL_SSL://pkc-p11xm.us-east-1.aws.confluent.cloud:9092', 'rest_endpoint': 'https://pkc-p11xm.us-east-1.aws.confluent.cloud:443'}
DEBUG:root:Kafka cluster created {'is_current': False, 'id': 'lkc-q677rm', 'name': 'quickstart_kafka-cluster', 'type': 'BASIC', 'ingress_limit': 250, 'egress_limit': 750, 'storage': '5 TB', 'cloud': 'aws', 'region': 'us-east-1', 'availability': 'single-zone', 'status': 'PROVISIONING', 'endpoint': 'SASL_SSL://pkc-p11xm.us-east-1.aws.confluent.cloud:9092', 'rest_endpoint': 'https://pkc-p11xm.us-east-1.aws.confluent.cloud:443'}
DEBUG:root:Enabling Schema Registry in geo us
Traceback (most recent call last):
File "/Users/koushiks/.confluent/plugins/confluent-flink-quickstart.py", line 267, in
cluster_id = get_cluster_id_for_flink_pool(candidate_clusters, args.name, args.region, args.cloud)
File "/Users/koushiks/.confluent/plugins/confluent-flink-quickstart.py", line 100, in get_cluster_id_for_flink_pool
_cluster_id = create_cluster_with_schema_registry(name, region, cloud)
File "/Users/koushiks/.confluent/plugins/confluent-flink-quickstart.py", line 57, in create_cluster_with_schema_registry
cluster_json['provider'], "--geo", geo, "-o", "json"])
KeyError: 'provider'
```
How to reproduce:
Follow the document : https://developer.confluent.io/quickstart/flink-on-confluent-cloud/?build=apps and run the
`confluent flink quickstart \
--name quickstart \
--max-cfu 10 \
--region us-east-1 \
--cloud aws \
--datagen-quickstarts shoe_orders shoes`
Workarounds: None
Contributor guide
Assessment
This issue has not been assessed yet.