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

K8s data pipeline using the geode starter required an undocumented property #4596

Closed
wlund-pivotal opened this issue Jun 23, 2021 · 1 comment
Labels
status/need-triage Team needs to triage and take a first look

Comments

@wlund-pivotal
Copy link

Description:
I was unable to get a simple data pipeline http | geode to work without adding a custom geode property. My platform is minikube.

Release versions:
Version is 2.7.2

Custom apps:
If your Stream or Task data pipeline includes custom apps and there is a problem associated with it, please share the sample-app (add a link to the GitHub repo) and the release versions in use. Also, please be sure to share the register, create, and deploy/launch DSL commands for completeness.

Steps to reproduce:

The example was taken from Http to Gemfire Demo. I ran the app using the list of properties provided by stream app stocks info and added --host-addresses in the creation of the steam because the app was not connecting to the service.
stream create --name stocks --definition "http --port=8080 | geode stream create --name stocks --definition "http --port=8080 | geode --host-addresses=gemfire-cluster-locator:10334 --json=true --regionName=Stocks --keyExpression=payload.getField('symbol') **--spring.data.gemfire.pool.locators=gemfire-cluster-locator[10334]"** --deploy --json=true --regionName=Stocks --keyExpression=payload.getField('symbol')\ --deploy

This didn't work so we added a geode specific property as listed below:

stream create --name stocks --definition "http --port=8080 | geode --host-addresses=gemfire-cluster-locator:10334 --json=true --regionName=Stocks --keyExpression=payload.getField('symbol') --spring.data.gemfire.pool.locators=gemfire-cluster-locator[10334]" --deploy

Screenshots:

Additional context:
It might just be an update to the app-starter docs but would probably be exposed as an app-starter property through something like "gemfire-pool-locators".

@sabbyanandan
Copy link
Contributor

Issue moved to spring-cloud/stream-applications #176 via ZenHub

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
status/need-triage Team needs to triage and take a first look
Projects
None yet
Development

No branches or pull requests

2 participants