[Feature] refactor generate seatunnel config file with SeatunnelNativeFlinkPlugin #99
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
|
Click here to review and test in web IDE: |
|
Click here to review and test in web IDE: |
|
Click here to review and test in web IDE: |
|
Click here to review and test in web IDE: |
|
Click here to review and test in web IDE: |
|
SonarCloud Quality Gate failed.
|
kalencaya
added a commit
that referenced
this pull request
Jun 26, 2022
* feature: flink-artifact jobs. * feature: flink-artifact jobs. * fix: datasource plugin construct jdbcurl error. * fix: seatunnel and flink docker image build args. * feature: change seatunnel base image to ghcr.io/flowerfine/scaleph_flink:1.13.6_2.11 * feature: flink cluster instance dao entity, mapper, xml * feature: flink cluster instance dto and convert. * feature: flink cluster instance service. * feature: flink cluster instance web * feature: flink cluster instance manage service. * feature: flink cluster instance manage service. * feature: flink release upload web. * feature: flink release batch delete web. * feature: flink release download web. * feature: remove unused imports. * feature: adjust name. * feature: adjust name. * feature: flink deploy-config web. * feature: flink deploy-config web. * feature: flink deploy-config upload web. * feature: flink deploy-config new web. * feature: add flink deploy-config param * feature: flink deploy-config batch delete. * feature: flink deploy-config batch delete. * feature: flink deploy-config list icon. * feature: flink deploy-config update web. * feature: flink deploy-config update web. * feature: flink deploy-config delete web. * feature: flink release web replace version input by select form. * feature: flink deploy config web replace configType input by select form. * feature: flink deploy config web replace configType input by select form. * feature: flink deploy config web replace configType input by select form. * [Feature]add flink cluster config service (#79) * feature: flink cluster config table schema. * feature: flink cluster config mybatis entity, mapper, xml * feature: flink cluster config service. * [Feature]refactor flink release service (#80) * feature: flink release table schema. * feature: flink release service * feature: flink release service * [Feature]upgrade seatunnel version to 2.1.2 (#81) * feature: flink cluster instance table schema * feature: upgrade seatunnel version to 2.1.2 * [Feature]docker deploy locally (#82) * feature: flink cluster instance table schema * feature: upgrade seatunnel version to 2.1.2 * feature: local bootstrap by docker compose * feature: local bootstrap by docker compose * feature: local bootstrap by docker compose * feature: local bootstrap by docker compose * feature: local bootstrap by docker compose * feature: local bootstrap by docker compose * feature: local bootstrap by docker compose * feature: docker build trigger event add pull request. * [Feature][docs]upgrade build and docker docs * [Feature][docs]upgrade build and docker docs * [Fix][docker]add file-system param to scaleph-api image (#83) feature: add file system param in scaleph-api Dockerfile * [Feature][docs]upgrade build and docker docs * [Feature] refactor dataSource manager with plugin (#84) * datasource plugin manager * datasource plugin manager * datasource plugin manager * [Fix][docker]docker image error (#86) * feature: add file system param in scaleph-api Dockerfile * fix: minio network error on docker deploy. * fix: scaleph-ui image error on docker build. * fix: minio network error on docker build. * fix: scaleph-api image bootstrap error caused by httpclient. * [Feature] delete table meta_datasoruce2 (#87) remove meta_datasource2 * fix: datasource plugin construct jdbcurl error. * [Fix][docker]minio endpoint resolves incorrectly by hadoop on s3 in container environment (#89) * fix: datasource plugin construct jdbcurl error. * fix: scaleph.minio url for s3 in container environment. * feature: add local release link through comments * feature: curl download from remote report when error * [Feature] init sample data in standard data mdoule (#90) * remove meta_datasource2 * remove meta_datasource2 * remove meta_datasource2 * remove unused table * init sample data in standard data module * [Fix][scaleph-engine-seatunnel]flinkful overwrite PackagedProgram does't work (#91) * fix: datasource plugin construct jdbcurl error. * feature: upgrade docker-build workflow. * fix: PipelineOptions.JARS not included in JobGraph. * fix: update docker build workflow. * [Feature][docs]local deploy * [Feature][docs]docker deploy * [Feature][docker]publish base flink and seatunnel image (#92) * fix: datasource plugin construct jdbcurl error. * feature: upgrade docker-build workflow. * fix: PipelineOptions.JARS not included in JobGraph. * fix: update docker build workflow. * feature: file system add local file system cache. * feature: flink and seatunnel base image publish. * fix: docker file error. * fix: docker seatunnel workflow name. * fix: seatunnel and flink docker image build args. * feature: change seatunnel base image to ghcr.io/flowerfine/scaleph_flink:1.13.6_2.11 * feature: flink cluster instance dao entity, mapper, xml * [Feature][docker]change scaleph-api base image to ghcr.io/flowerfine/scaleph_seatunnel:2.1.2 (#96) * fix: datasource plugin construct jdbcurl error. * fix: seatunnel and flink docker image build args. * feature: change seatunnel base image to ghcr.io/flowerfine/scaleph_flink:1.13.6_2.11 * feature: change seatunnel base image to ghcr.io/flowerfine/scaleph_seatunnel:2.1.2 * fix: Dockerfile and context relative path. * feature: flink cluster instance dto and convert. * feature: flink cluster instance service. * feature: flink cluster instance web * feature: flink cluster instance manage service. * feature: flink cluster instance manage service. * feature: flink release upload web. * feature: flink release batch delete web. * feature: flink release download web. * feature: remove unused imports. * feature: adjust name. * feature: adjust name. * feature: flink deploy-config web. * feature: flink deploy-config web. * feature: flink deploy-config upload web. * feature: flink deploy-config new web. * feature: add flink deploy-config param * feature: flink deploy-config batch delete. * feature: flink deploy-config batch delete. * feature: flink deploy-config list icon. * feature: flink deploy-config update web. * feature: flink deploy-config update web. * feature: flink deploy-config delete web. * feature: flink release web replace version input by select form. * feature: flink deploy config web replace configType input by select form. * feature: flink deploy config web replace configType input by select form. * feature: flink deploy config web replace configType input by select form. * [Feature] refactor generate seatunnel config file with SeatunnelNativeFlinkPlugin (#99) * refactor generate seatunnel config file with SeatunnelNativeFlinkPlugin * remove duplications code * delete jobConfigHelper * change ObjectNode to ArrayNode * add seatunnel plugin jar mapping * feature: flink deploy config file web. * feature: flink deploy config file web. * feature: flink deploy config file web. * feature: flink deploy config file upload web. * feature: flink deploy config file upload web. * feature: flink deploy config file download web. * feature: flink deploy config file delete web. * feature: flink deploy config file delete web. * fix: refactor flink web. Co-authored-by: gleiyu <gleiyu@sina.cn>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Purpose of this pull request
refactor generate seatunnel config file with SeatunnelNativeFlinkPlugin
Brief change log
(for example:)
Check list