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

[Feature]support latest version of Spark 3.2.0 #875

Open
Tracked by #720 ...
RickyHuo opened this issue Dec 27, 2021 · 12 comments
Open
Tracked by #720 ...

[Feature]support latest version of Spark 3.2.0 #875

RickyHuo opened this issue Dec 27, 2021 · 12 comments
Assignees
Labels
core SeaTunnel core module
Projects

Comments

@RickyHuo
Copy link
Contributor

No description provided.

@RickyHuo
Copy link
Contributor Author

@RickyHuo RickyHuo changed the title support latest version of Spark 3.2.0 [Feature]support latest version of Spark 3.2.0 Dec 31, 2021
@ashmeet-kandhari
Copy link

Hi @RickyHuo,
I would like to volunteer for this

ashmeet-kandhari pushed a commit to ashmeet-kandhari/incubator-seatunnel that referenced this issue Jan 4, 2022
@ashmeet-kandhari
Copy link

ashmeet-kandhari commented Jan 4, 2022

Hi @RickyHuo,
Please have a look at the PR when possible and let me know if anything else is required.

Thanks

@RickyHuo
Copy link
Contributor Author

RickyHuo commented Jan 5, 2022

@ashmeet-kandhari Thanks for your contribution.

I want to know the version compatibility with Spark lower version or Scala because I know Spark 3.X built with Scala 2.12.

If we can use spark 2.4 local with seatunnel built on Spark 3.2 or not?

@ashmeet-kandhari
Copy link

@RickyHuo From what I see, there are API changes due to which this is not possible without adding some logic to look at the api
(Issue comes with JDBCUtils.scala file)

@CalvinKirs CalvinKirs added this to doing in 2.0 RoadMap Jan 6, 2022
@garyelephant garyelephant added the core SeaTunnel core module label Jan 8, 2022
@simon824
Copy link
Member

How is it going ,in my opinion it's better to be compatible with both spark2 and spark3,spark version can be passed in maven as a parameter,and I can take some help if needed.

@zhaomin1423
Copy link
Member

@RickyHuo From what I see, there are API changes due to which this is not possible without adding some logic to look at the api (Issue comes with JDBCUtils.scala file)

Some connectors or class may need have different implement for spark2 and spark3.

@Hisoka-X
Copy link
Member

How is it going ,in my opinion it's better to be compatible with both spark2 and spark3,spark version can be passed in maven as a parameter,and I can take some help if needed.

This method can‘t come true, because spark api have change between 2.x and 3.x. We can‘t maintain two version api in one project

@Hisoka-X
Copy link
Member

How is it going? @ashmeet-kandhari If you don't have enough time, I will do this recently.

@ashmeet-kandhari
Copy link

Hi @benjfan,

I missed the updates recently.
Yes, please can you look into it, as am currently pre-occupied.

Thanks for offering :)

@Hisoka-X
Copy link
Member

@CalvinKirs Please assgin me

@nishuihanqiu
Copy link

nishuihanqiu commented Nov 13, 2022

support spark3.2.0, spark3.1.2 and spark2.4.7, please see https://github.com/nishuihanqiu/incubator-seatunnel with branch 2.1.3-spark3, that is 2.1.3-spark3

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
core SeaTunnel core module
Projects
No open projects
Development

Successfully merging a pull request may close this issue.

7 participants