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-2582][Connector] Add Hashes && Lists in Redis Sink #2587

Closed
wants to merge 4 commits into from
Closed

[Feature-2582][Connector] Add Hashes && Lists in Redis Sink #2587

wants to merge 4 commits into from

Conversation

shangeyao
Copy link
Contributor

Purpose of this pull request

close #2582

@CalvinKirs CalvinKirs added connectors-v2 connectors-v1 SeaTunnel connectors, include sink, source 2.1.x and removed connectors-v2 labels Sep 1, 2022
Copy link
Member

@hailin0 hailin0 left a comment

Choose a reason for hiding this comment

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

Can you add e2e-testcase & update docs?

@shangeyao
Copy link
Contributor Author

Can you add e2e-testcase & update docs?

I will complete it.

@hailin0
Copy link
Member

hailin0 commented Sep 1, 2022

Can you add e2e-testcase & update docs?

Testcase reference #2429

@shangeyao
Copy link
Contributor Author

Can you add e2e-testcase & update docs?

Testcase reference #2429

I tried it, please review again.


@Test
public void testFakeSourceToRedisSink() throws IOException, InterruptedException {
Container.ExecResult execResult = executeSeaTunnelSparkJob("/jdbc/fakesource_to_redis.conf");
Copy link
Member

Choose a reason for hiding this comment

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


sink {
redis {
host = "localhost"
Copy link
Member

Choose a reason for hiding this comment

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

Connect to redis-server you started in testcase?

Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
host = "localhost"
host = "spark_e2e_redis"

Copy link
Member

@wuchunfu wuchunfu left a comment

Choose a reason for hiding this comment

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

@shangeyao Please fix codestyle problem, thx

@Hisoka-X Hisoka-X requested review from hailin0 and wuchunfu and removed request for hailin0 September 17, 2022 11:25

sink {
redis {
host = "localhost"
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
host = "localhost"
host = "spark_e2e_redis"

@EricJoy2048
Copy link
Member

Since this pr has not been updated for too long, I will close it. If necessary, please reopen it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
connectors-v1 SeaTunnel connectors, include sink, source
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Feature][Connector] Add Hashes && Lists in Redis Sink
5 participants