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

Add spark applicationId #1778

Merged
merged 13 commits into from
Jul 5, 2023
Merged

Conversation

rupal-bq
Copy link
Contributor

Description

  • Added applicationId

Issues Resolved

#1722

  • applicationId will be used instead of stepId for non-emr spark setup

Check List

  • New functionality includes testing.
    • All tests pass, including unit test, integration test and doctest
  • New functionality has been documented.
    • New functionality has javadoc added
    • New functionality has user manual doc added
  • Commits are signed per the DCO using --signoff

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.
For more information on following Developer Certificate of Origin and signing off your commits, please check here.

rupal-bq added 13 commits June 8, 2023 06:11
Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Rupal Mahajan <[email protected]>
@rupal-bq rupal-bq requested a review from GumpacG as a code owner June 26, 2023 16:07
@Yury-Fridlyand
Copy link
Collaborator

Is it possible to do an IT for that?

@rupal-bq
Copy link
Contributor Author

Is it possible to do an IT for that?

Need to check. will address that in follow up PR.

@dai-chen
Copy link
Collaborator

Could you elaborate a little what's the difference and why this change?

@rupal-bq
Copy link
Contributor Author

Could you elaborate a little what's the difference and why this change?

In spark connector, we will be able to use different spark clients. In case of EMR client, stepId can be used to fetch the result from opensearch index but stepId concept is specific to EMR.

So when we will use another client e.g. Livy client then we can use spark applicationId to get results from opensearch index because Livy response includes appId.
ref: https://livy.incubator.apache.org/docs/latest/rest-api.html

This is basically just for adding alternate option to stepId if it's not emr in design of #1722

@rupal-bq rupal-bq merged commit 4d6ac79 into opensearch-project:main Jul 5, 2023
matthewryanwells pushed a commit to Bit-Quill/opensearch-project-sql that referenced this pull request Jul 7, 2023
* Initial spark application draft

Signed-off-by: Rupal Mahajan <[email protected]>

* Remove temp table

Signed-off-by: Rupal Mahajan <[email protected]>

* Add license header

Signed-off-by: Rupal Mahajan <[email protected]>

* Add scalastyle-config and update readme

Signed-off-by: Rupal Mahajan <[email protected]>

* Fix datatype for result and schema

Signed-off-by: Rupal Mahajan <[email protected]>

* Add test

Signed-off-by: Rupal Mahajan <[email protected]>

* Simplify code using toJSON.collect.toList

Signed-off-by: Rupal Mahajan <[email protected]>

* Add example in readme

Signed-off-by: Rupal Mahajan <[email protected]>

* Fix triple quotes issue

Signed-off-by: Rupal Mahajan <[email protected]>

* Update method name and description

Signed-off-by: Rupal Mahajan <[email protected]>

* Add applicationId

Signed-off-by: Rupal Mahajan <[email protected]>

---------

Signed-off-by: Rupal Mahajan <[email protected]>
matthewryanwells pushed a commit to Bit-Quill/opensearch-project-sql that referenced this pull request Jul 7, 2023
* Initial spark application draft

Signed-off-by: Rupal Mahajan <[email protected]>

* Remove temp table

Signed-off-by: Rupal Mahajan <[email protected]>

* Add license header

Signed-off-by: Rupal Mahajan <[email protected]>

* Add scalastyle-config and update readme

Signed-off-by: Rupal Mahajan <[email protected]>

* Fix datatype for result and schema

Signed-off-by: Rupal Mahajan <[email protected]>

* Add test

Signed-off-by: Rupal Mahajan <[email protected]>

* Simplify code using toJSON.collect.toList

Signed-off-by: Rupal Mahajan <[email protected]>

* Add example in readme

Signed-off-by: Rupal Mahajan <[email protected]>

* Fix triple quotes issue

Signed-off-by: Rupal Mahajan <[email protected]>

* Update method name and description

Signed-off-by: Rupal Mahajan <[email protected]>

* Add applicationId

Signed-off-by: Rupal Mahajan <[email protected]>

---------

Signed-off-by: Rupal Mahajan <[email protected]>
Signed-off-by: Matthew Wells <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants