Hi, Could you provide the exception stack trace?
Regards, Roman On Mon, Feb 8, 2021 at 3:46 PM joris.vanagtmaal < [email protected]> wrote: > I'm trying to read data from my eventhub in Azure, but i end up with the > Flink error message 'findAndCreateTableSource failed' > > using Flink 1.13-Snapshot > > source_ddl = f"""CREATE TABLE dms_source( > x_value VARCHAR > ) WITH ( > 'connector.type' = 'Kafka', > 'connector.version' = 'universal', > 'connector.partition' = '0', > 'connector.sasl.jaas.config'= > 'org.apache.kafka.common.security.plain.PlainLoginModule required > username="$ConnectionString" > password="Endpoint=sb://**EVEN_HUB_NAME**. > servicebus.windows.net/;SharedAccessKeyName=**KEY_ > > NAME**;SharedAccessKey=***PRIMARY_KEY***;EntityPath=**EVENT_HUB_INSTANCE_NAME**";', > 'connector.sasl.mechanism' = 'PLAIN', > 'connector.security.protocol' = 'SASL_SSL', > 'connector.properties.bootstrap.servers' = > '**EVEN_HUB_NAME**.servicebus.windows.net:9093', > 'connector.properties.group.id' = '$Default', > 'connector.startup-mode' = 'latest-offset', > 'format.type' = 'json') > """ > > Any tips on how to debug this? > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
