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.

Sign up for GitHub

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

Jump to bottom

[Bug]: JmsIO create connection based on the number of threads #27312

Open
2 of 15 tasks
Amraneze opened this issue Jun 30, 2023 · 0 comments
Open
2 of 15 tasks

[Bug]: JmsIO create connection based on the number of threads #27312

Amraneze opened this issue Jun 30, 2023 · 0 comments
Labels
bug io java jms P2

Comments

@Amraneze
Copy link
Contributor

Amraneze commented Jun 30, 2023 •
edited by aromanenko-dev

What happened?

JmsIO doesn't support for now connection pooling and retrying the publishing messages in case of a failure. It would be nice to have a connection pool so that the user can decide how many connections can be used for each worker.

Issue Priority

Priority: 2

Issue Components

  • Component: Python SDK
  • Component: Java SDK
  • Component: Go SDK
  • Component: Typescript SDK
  • Component: IO connector
  • Component: Beam examples
  • Component: Beam playground
  • Component: Beam katas
  • Component: Website
  • Component: Spark Runner
  • Component: Flink Runner
  • Component: Samza Runner
  • Component: Twister2 Runner
  • Component: Hazelcast Jet Runner
  • Component: Google Cloud Dataflow Runner
Amraneze added a commit to Amraneze/beam that referenced this issue Jun 30, 2023
@Amraneze @amranezeRenault
[apache#27312] fix(JmsIO): create a session pool for JmsIO apache#27312
2500096 
[apache#26203] fix(JmsIO): use a unused port for tests in JmsIO apache#26203
Fixes apache#27312, apache#26203

Co-Authored-By: Amrane Ait Zeouay <122456352+amranezeRenault@users.noreply.github.com>
Amraneze added a commit to Amraneze/beam that referenced this issue Jun 30, 2023
@Amraneze @amranezeRenault
[apache#27312] fix(JmsIO): create a session pool for JmsIO apache#27312
55cb703 
[apache#26203] fix(JmsIO): use a unused port for tests in JmsIO apache#26203
Fixes apache#27312, apache#26203

Co-Authored-By: Amrane Ait Zeouay <122456352+amranezeRenault@users.noreply.github.com>
@Amraneze Amraneze mentioned this issue Jun 30, 2023
Closed
3 tasks
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
bug io java jms P2
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

[#27312] fix(JmsIO): create a session pool for JmsIO #27312 Amraneze/beam
2 participants
@Amraneze @aromanenko-dev