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

[FLINK-30702] Add Elasticsearch dialect #136

Open
wants to merge 3 commits into
base: main
Choose a base branch
from

Conversation

grzegorz8
Copy link

The PR adds Elasticsearch dialect.

Important facts:

  • x-pack-sql-jdbc dependency is on Elastic license which is not compatible with Apache license. Therefore:
    • x-pack-sql-jdbc has provided scope.
    • appropriate note is added in the documentation.
    • added an enforcer rule to make sure that it's never bundled.
  • Elastic jdbc driver is read-only.
    • In integration tests the test indices and test data are created via Elastic REST API.

This PR replaces #67. Due to recent refactoring it was easier to create a new PR.

@grzegorz8 grzegorz8 changed the title Add Elasticsearch dialect [FLINK-30702] Add Elasticsearch dialect Aug 6, 2024
Copy link
Member

@eskabetxe eskabetxe left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Overall, everything seems to be fine.
However, I suggest changing the module name to "flink-connector-jdbc-elasticsearch."

I still have some doubts about:

The recent refactor makes this feasible, as you only need to import jdbc-core.

@1996fanrui, what do you think?
@RocMarshal, could you take a look as well?

@grzegorz8
Copy link
Author

I still have some doubts about:

@1996fanrui, what do you think? @RocMarshal, could you take a look as well?

Hi! @1996fanrui @RocMarshal Any thoughts?

@1996fanrui
Copy link
Member

Sorry, I'm not familiar with jdbc and elasticserarch connector.

Comment on lines +68 to +73
<dependency>
<groupId>org.elasticsearch.plugin</groupId>
<artifactId>x-pack-sql-jdbc</artifactId>
<version>${elasticsearch.version}</version>
<scope>provided</scope>
</dependency>
Copy link
Member

@linghengqian linghengqian Jan 10, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I don't understand. The plugin runs inside Elasticsearch so it uses the JVM provided by Elasticsearch.
It's not meant to be reused anywhere else.

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No sorry. I was wrong for this jar.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

5 participants