Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Azure EventHub Consume and Trigger task: checkpointStoreProperties marked as not required, but the task fails if this attribute is not present #76

Open
shrutimantri opened this issue Mar 25, 2024 · 0 comments
Labels
area/plugin Plugin-related issue or feature request bug Something isn't working
Milestone

Comments

@shrutimantri
Copy link
Contributor

Expected Behavior

For Azure EventHub Consume and Trigger task, checkpointStoreProperties should either be a required field, OR if it marked not required, then the task should succeed when this property is absent.

Actual Behaviour

When checkpointStoreProperties is not provided, we get the following error:

2024-03-25 15:23:51.395 Invalid URL format. URL: null
2024-03-25 15:23:51.395 Cannot invoke "String.length()" because "<parameter2>" is null
Cannot invoke "String.length()" because "<parameter2>" is null
2024-03-25 15:23:51.395 java.lang.IllegalArgumentException: Invalid URL format. URL: null
	at com.azure.storage.blob.BlobUrlParts.parse(BlobUrlParts.java:349)
	at com.azure.storage.blob.implementation.util.BuilderHelper.httpsValidation(BuilderHelper.java:188)
	at com.azure.storage.blob.implementation.util.BuilderHelper.buildPipeline(BuilderHelper.java:119)
	at com.azure.storage.blob.BlobContainerClientBuilder.buildAsyncClient(BlobContainerClientBuilder.java:163)
	at io.kestra.plugin.azure.eventhubs.client.EventHubClientFactory.createBlobContainerAsyncClient(EventHubClientFactory.java:146)
	at io.kestra.plugin.azure.eventhubs.Consume.getBlobCheckpointStore(Consume.java:217)
	at io.kestra.plugin.azure.eventhubs.Consume.run(Consume.java:141)
	at io.kestra.plugin.azure.eventhubs.Consume.run(Consume.java:117)
	at io.kestra.plugin.azure.eventhubs.Consume.run(Consume.java:48)
	at io.kestra.core.runners.Worker$WorkerThread.run(Worker.java:710)
Caused by: java.net.MalformedURLException: Cannot invoke "String.length()" because "<parameter2>" is null
	at java.base/java.net.URL.<init>(Unknown Source)
	at java.base/java.net.URL.<init>(Unknown Source)
	at java.base/java.net.URL.<init>(Unknown Source)
	at com.azure.storage.blob.BlobUrlParts.parse(BlobUrlParts.java:347)
	... 9 more
Caused by: java.lang.NullPointerException: Cannot invoke "String.length()" because "<parameter2>" is null
	... 13 more

Steps To Reproduce

  1. Run the flow provided in the Example Flow. (Ensure you do not add checkpointStoreProperties property)
  2. Check the logs on executing this flow.

Environment Information

  • Kestra Version: 0.15.5
  • Plugin version: 0.15.5
  • Operating System (OS / Docker / Kubernetes): Docker
  • Java Version (If not docker):

Example flow

id: ConsumeDataEventsFromAzureEventHubs
namespace: company.team
tasks:
- id: consumeFromEventHubs
  type: io.kestra.plugin.azure.eventhubs.Consume
  eventHubName: <event-name>
  namespace: <eventhub-namespace>
  connectionString: "<connectionString>"
  bodyDeserializer: STRING
  consumerGroup: "$Default"
@shrutimantri shrutimantri added the bug Something isn't working label Mar 25, 2024
@anna-geller anna-geller added this to the v0.20.0 milestone May 8, 2024
@github-project-automation github-project-automation bot moved this to Backlog in Issues Jun 10, 2024
@Ben8t Ben8t added the area/plugin Plugin-related issue or feature request label Oct 2, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area/plugin Plugin-related issue or feature request bug Something isn't working
Projects
Status: Backlog
Development

No branches or pull requests

3 participants