[Feature][Connector] Add druid sink connector #6346

TaoZex · 2024-02-10T16:17:28Z

Purpose of this pull request

#3018

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

If any new Jar binary package adding in your PR, please add License Notice according
New License Guide
If necessary, please update the documentation to describe the new feature. https://github.com/apache/seatunnel/tree/dev/docs
If you are contributing the connector code, please check that the following files are updated:
1. Update change log that in connector document. For more details you can refer to connector-v2
2. Update plugin-mapping.properties and add new connector information in it
3. Update the pom file of seatunnel-dist
Update the release-note.

hailin0

Please add docs
Please fix ci error

...-e2e/connector-druid-e2e/src/test/java/org/apache/seatunnel/e2e/connector/druid/DruidIT.java

TaoZex · 2024-04-11T02:16:33Z

PTAL @Hisoka-X @EricJoy2048

...s-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java

...e/seatunnel-connector-v2-e2e/connector-druid-e2e/src/test/resources/fakesource_to_druid.conf

...-e2e/connector-druid-e2e/src/test/java/org/apache/seatunnel/e2e/connector/druid/DruidIT.java

docs/en/connector-v2/sink/Druid.md

hailin0 · 2024-04-18T08:31:21Z

@TaoZex

Hisoka-X · 2024-06-04T12:47:01Z

Please fix CI. Thanks

...e/seatunnel-connector-v2-e2e/connector-druid-e2e/src/test/resources/fakesource_to_druid.conf

docs/en/connector-v2/sink/Druid.md

…into druid

hailin0 · 2024-06-17T13:35:46Z

Do you have plans to support cdc/savemode/multi-table?

TaoZex · 2024-06-17T13:42:17Z

Do you have plans to support cdc/savemode/multi-table?

Of course. Please assign to me.

hailin0 · 2024-06-17T13:52:35Z

...e/seatunnel-connector-v2-e2e/connector-druid-e2e/src/test/resources/fakesource_to_druid.conf

+    rows = [
+      {
+        kind = INSERT
+        fields = [true, "2020-02-02T02:02:02", "NEW", 1, 2, 3, 4, 4.3, 5.3, 6.3]


add mores test data

hailin0

LGTM

Hisoka-X

These synchronized keywords give the impression that these methods will be called concurrently, but in fact they will not.

...v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidWriter.java

Hisoka-X

LGTM if ci passed.

TaoZex added 5 commits February 10, 2024 22:48

[Connector]Add druid sink connector

c6b2d2f

fix

68419ff

fix

498decf

success for environment

261708e

fix

a134479

TaoZex marked this pull request as ready for review February 11, 2024 11:00

TaoZex added 4 commits February 11, 2024 20:06

fix

4ef2bff

fix

4f91b75

fix

6765601

fix

d20f534

hailin0 reviewed Feb 18, 2024

View reviewed changes

...-e2e/connector-druid-e2e/src/test/java/org/apache/seatunnel/e2e/connector/druid/DruidIT.java Outdated Show resolved Hide resolved

hailin0 added druid feature New feature connectors-v2 labels Feb 18, 2024

TaoZex added 5 commits April 10, 2024 17:25

Merge branch 'dev' into druid

038a6ef

fix

e99c78d

fix port

aa8f742

add doc

13fc563

fix

c38750a

Hisoka-X reviewed Apr 11, 2024

View reviewed changes

...s-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java Outdated Show resolved Hide resolved

TaoZex added 2 commits April 11, 2024 14:54

remove SPI

e8f26df

Merge branch 'apache:dev' into druid

2804bce

TaoZex requested a review from Hisoka-X April 12, 2024 06:15

hailin0 reviewed Apr 18, 2024

View reviewed changes

TaoZex added 2 commits May 21, 2024 12:30

Merge branch 'apache:dev' into druid

99d1e7b

fix

ccda35a

Merge branch 'apache:dev' into druid

c891be6

Merge branch 'apache:dev' into druid

b615e9c

hailin0 reviewed Jun 17, 2024

View reviewed changes

...e/seatunnel-connector-v2-e2e/connector-druid-e2e/src/test/resources/fakesource_to_druid.conf Show resolved Hide resolved

TaoZex requested a review from hailin0 June 17, 2024 04:32

hailin0 reviewed Jun 17, 2024

View reviewed changes

docs/en/connector-v2/sink/Druid.md Outdated Show resolved Hide resolved

TaoZex added 2 commits June 17, 2024 16:18

fix doc

4fa9560

Merge branch 'druid' of https://github.com/TaoZex/incubator-seatunnel …

13ec4de

…into druid

TaoZex requested a review from hailin0 June 17, 2024 11:23

TaoZex mentioned this pull request Jun 17, 2024

[Feature][Druid] Druid sink connector support multi table and cdc #7002

Closed

3 tasks

hailin0 reviewed Jun 17, 2024

View reviewed changes

hailin0 changed the title ~~[Connector]Add druid sink connector~~ [Feature][Connector] Add druid sink connector Jun 17, 2024

add more test data

948ee40

TaoZex requested a review from hailin0 June 18, 2024 07:40

hailin0 previously approved these changes Jun 19, 2024

View reviewed changes

github-actions bot added approved reviewed labels Jun 19, 2024

Hisoka-X reviewed Jun 19, 2024

View reviewed changes

Hisoka-X added this to the 2.3.6 milestone Jun 19, 2024

fix

3e7b2b0

TaoZex dismissed hailin0’s stale review via 3e7b2b0 June 19, 2024 03:17

github-actions bot removed approved reviewed labels Jun 19, 2024

Hisoka-X approved these changes Jun 19, 2024

View reviewed changes

github-actions bot added approved reviewed labels Jun 19, 2024

TaoZex requested a review from hailin0 June 19, 2024 05:43

hailin0 approved these changes Jun 19, 2024

View reviewed changes

hailin0 merged commit d7fa9af into apache:dev Jun 19, 2024
8 checks passed

chaorongzhi pushed a commit to chaorongzhi/seatunnel that referenced this pull request Aug 21, 2024

[Feature][Connector] Add druid sink connector (apache#6346)

85627d9

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[Feature][Connector] Add druid sink connector #6346

[Feature][Connector] Add druid sink connector #6346

TaoZex commented Feb 10, 2024 •

edited

Loading

hailin0 left a comment

TaoZex commented Apr 11, 2024

hailin0 commented Apr 18, 2024

Hisoka-X commented Jun 4, 2024

hailin0 commented Jun 17, 2024

TaoZex commented Jun 17, 2024

hailin0 Jun 17, 2024

TaoZex Jun 18, 2024

hailin0 left a comment

Hisoka-X left a comment

Hisoka-X left a comment

[Feature][Connector] Add druid sink connector #6346

[Feature][Connector] Add druid sink connector #6346

Conversation

TaoZex commented Feb 10, 2024 • edited Loading

Purpose of this pull request

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

hailin0 left a comment

Choose a reason for hiding this comment

TaoZex commented Apr 11, 2024

hailin0 commented Apr 18, 2024

Hisoka-X commented Jun 4, 2024

hailin0 commented Jun 17, 2024

TaoZex commented Jun 17, 2024

hailin0 Jun 17, 2024

Choose a reason for hiding this comment

TaoZex Jun 18, 2024

Choose a reason for hiding this comment

hailin0 left a comment

Choose a reason for hiding this comment

Hisoka-X left a comment

Choose a reason for hiding this comment

Hisoka-X left a comment

Choose a reason for hiding this comment

TaoZex commented Feb 10, 2024 •

edited

Loading