This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 0600214baa [Fix][Zeta] Compare basic auth credentials without a timing
discrepancy (#12595)
add 662fbf70d0 [Feature][STIP-41][Zeta] Add Native Zeta Application Mode
on Kubernetes (#12460)
No new revisions were added by this update.
Summary of changes:
.github/workflows/backend.yml | 38 +
.github/workflows/labeler/label-scope-conf.yml | 9 +
config/v1.kubernetes.conf.template | 74 +
docs/en/getting-started/application/cli.md | 125 ++
.../application/kubernetes/architecture.md | 100 ++
.../application/kubernetes/checkpoint-recovery.md | 98 ++
.../application/kubernetes/commands.md | 78 +
.../application/kubernetes/configuration.md | 517 ++++++
.../getting-started/application/kubernetes/faq.md | 75 +
.../application/kubernetes/overview.md | 71 +
.../application/kubernetes/quick-start.md | 209 +++
docs/en/getting-started/application/overview.md | 81 +
docs/en/getting-started/overview.md | 8 +
.../introduction/concepts/incompatible-changes.md | 24 +
docs/sidebars.js | 24 +
docs/zh/getting-started/application/cli.md | 121 ++
.../application/kubernetes/architecture.md | 97 ++
.../application/kubernetes/checkpoint-recovery.md | 97 ++
.../application/kubernetes/commands.md | 70 +
.../application/kubernetes/configuration.md | 492 ++++++
.../getting-started/application/kubernetes/faq.md | 75 +
.../application/kubernetes/overview.md | 71 +
.../application/kubernetes/quick-start.md | 203 +++
docs/zh/getting-started/application/overview.md | 70 +
docs/zh/getting-started/overview.md | 8 +
.../introduction/concepts/incompatible-changes.md | 19 +
pom.xml | 1 +
.../api/configuration/util/OptionUtil.java | 33 +
.../api/configuration/util/OptionUtilTest.java | 23 +
.../common/constants/ApplicationOperation.java | 22 +-
.../seatunnel/common/constants/EngineType.java | 3 +-
.../seatunnel/common/utils/ExceptionUtils.java | 70 +
.../seatunnel/common/utils/ExceptionUtilsTest.java | 27 +
.../src/main/bin/seatunnel-application.sh | 136 ++
.../starter/seatunnel/SeaTunnelApplication.java | 44 +
.../seatunnel/args/ApplicationCommandArgs.java | 206 +++
.../command/ApplicationExecuteCommand.java | 176 ++
.../seatunnel/SeaTunnelClusterScriptTest.java | 67 +
.../command/ApplicationExecuteCommandTest.java | 478 +++++
seatunnel-dist/pom.xml | 9 +
seatunnel-dist/release-docs/LICENSE | 58 +
seatunnel-dist/release-docs/NOTICE | 36 +
.../licenses/LICENSE-bouncycastle-1.76.txt | 17 +
.../licenses/LICENSE-protobuf-java-3.24.3.txt | 32 +
.../licenses/LICENSE-public-suffix-list.txt | 373 ++++
.../main/assembly/assembly-seatunnel-bin-ci.xml | 11 +
.../src/main/assembly/assembly-seatunnel-bin.xml | 11 +
seatunnel-e2e/pom.xml | 2 +
.../seatunnel-resource-managers-e2e/pom.xml | 207 +++
.../AbstractKubernetesApplicationIT.java | 796 +++++++++
.../kubernetes/KubernetesApplicationBatchIT.java | 160 ++
.../KubernetesApplicationConfigurationIT.java | 340 ++++
.../KubernetesApplicationLifecycleIT.java | 268 +++
.../KubernetesApplicationRecoveryIT.java | 205 +++
.../src/test/resources/kubernetes/Dockerfile | 21 +
.../resources/kubernetes/batch/application.config | 39 +
.../src/test/resources/kubernetes/batch/job.conf | 70 +
.../checkpoint-restore/application.config | 42 +
.../kubernetes/checkpoint-restore/job.conf | 46 +
.../kubernetes/checkpoint/application.config | 41 +
.../test/resources/kubernetes/checkpoint/job.conf | 46 +
.../test/resources/kubernetes/checkpoints-pvc.yaml | 26 +
.../application.config | 117 ++
.../configuration-job-conf-configmap/job.conf | 40 +
.../application.config | 110 ++
.../configuration-job-conf-secret/job.conf | 40 +
.../configuration-ref/application.config | 52 +
.../kubernetes/configuration-ref/job.conf | 59 +
.../kubernetes/configuration/application.config | 91 +
.../resources/kubernetes/configuration/job.conf | 73 +
.../kubernetes/invalid-job/application.config | 39 +
.../test/resources/kubernetes/invalid-job/job.conf | 44 +
.../kubernetes/isolation/application.config | 39 +
.../test/resources/kubernetes/isolation/job.conf | 44 +
.../resources/kubernetes/quota/application.config | 39 +
.../src/test/resources/kubernetes/quota/job.conf | 44 +
.../test/resources/kubernetes/role-binding.yaml | 29 +
.../src/test/resources/kubernetes/role.yaml | 28 +
.../src/test/resources/kubernetes/seatunnel.yaml | 43 +
.../test/resources/kubernetes/service-account.yaml | 21 +
.../src/test/resources/kubernetes/suite.config | 30 +
.../kubernetes/worker-loss/application.config | 39 +
.../test/resources/kubernetes/worker-loss/job.conf | 44 +
.../test/resources/kubernetes/worker-quota.yaml | 25 +
.../deployment/ApplicationClusterDeployer.java | 75 +
.../ApplicationClusterDescriptorFactory.java | 50 +
.../deployment/ClusterClientServiceLoader.java | 56 +
.../client/deployment/ClusterDescriptor.java | 55 +
.../deployment/SeatunnelClientProvider.java} | 15 +-
.../engine/client/SeaTunnelClientTest.java | 10 +
.../common/config/SeatunnelApplicationConfig.java | 352 ++++
.../common/config/server/ApplicationOptions.java | 95 +
.../config/spec/ApplicationSpecification.java | 107 ++
.../common/config/spec/WorkerSpecification.java | 50 +
.../engine/common/runtime/ApplicationStatus.java | 46 +
.../engine/common/runtime/DeployType.java | 1 -
.../seatunnel/engine/common/utils/UUIDUtil.java} | 14 +-
.../config/SeatunnelApplicationConfigTest.java | 209 +++
.../common/spec/ApplicationSpecificationTest.java | 214 +++
.../classloader/DefaultClassLoaderService.java | 6 +
.../core/classloader/ClassLoaderServiceTest.java | 34 +
.../engine/server/CoordinatorService.java | 43 +-
.../seatunnel/engine/server/NodeExtension.java | 16 +-
.../engine/server/SeaTunnelNodeContext.java | 23 +-
.../seatunnel/engine/server/SeaTunnelServer.java | 93 +-
.../engine/server/SeaTunnelServerStarter.java | 27 +-
.../ApplicationJobExecutionEnvironment.java | 157 ++
.../server/application/ApplicationJobRunner.java | 266 +++
.../resourcemanager/AbstractResourceManager.java | 34 +-
.../ApplicationResourceManager.java | 340 ++++
...ourceManager.java => ResourceEventHandler.java} | 24 +-
.../server/resourcemanager/ResourceManager.java | 144 +-
.../resourcemanager/ResourceManagerDriver.java | 127 ++
.../resourcemanager/ResourceManagerFactory.java | 58 +-
.../resourcemanager/StandaloneResourceManager.java | 20 +
.../ResourceID.java} | 32 +-
.../resource/ResourceIDRetrievable.java} | 11 +-
.../kubernetes/KubernetesResourceManager.java | 45 -
.../thirdparty/yarn/YarnResourceManager.java | 44 -
.../application/ApplicationLifecycleTest.java | 810 +++++++++
...akeResourceManagerForExternalExceptionTest.java | 9 +-
.../resourcemanager/ResourceManagerTest.java | 264 +++
...pplication_lifecycle_batch_fake_to_console.conf | 36 +
...cation_lifecycle_streaming_fake_to_console.conf | 38 +
seatunnel-resource-managers/README.md | 52 +
seatunnel-resource-managers/kubernetes/pom.xml | 184 ++
.../KubernetesApplicationClusterDescriptor.java | 460 +++++
...ernetesApplicationClusterDescriptorFactory.java | 60 +
.../KubernetesResourceManagerDriver.java | 420 +++++
.../resource/kubernetes/KubernetesWorkerNode.java | 19 +-
.../cli/SeatunnelKubernetesApplicationCli.java | 273 +++
.../client/KubernetesApplicationClient.java | 109 ++
.../config/KubernetesApplicationConfig.java | 1134 ++++++++++++
.../config/KubernetesConfigMapEntry.java | 92 +
.../config/KubernetesEnvFromReference.java | 54 +
.../config/KubernetesEnvironmentVariable.java | 118 ++
.../kubernetes/config/KubernetesOptions.java | 245 +++
.../kubernetes/config/KubernetesToleration.java | 164 ++
.../exception/KubernetesClientException.java | 55 +
.../kubeclient/DefaultKubernetesClient.java | 403 +++++
.../kubernetes/kubeclient/InformerPodWatch.java | 418 +++++
.../kubernetes/kubeclient/KubernetesClient.java | 134 ++
.../kubeclient/KubernetesClientFactory.java | 100 ++
.../kubernetes/kubeclient/KubernetesConstants.java | 207 +++
.../kubeclient/KubernetesResourceIdentity.java | 161 ++
.../kubernetes/kubeclient/PodWatchCallback.java | 48 +
.../AbstractKubernetesStepDecorator.java | 24 +-
.../kubeclient/decorators/ConfigMapDecorator.java | 113 ++
.../decorators/EnvironmentDecorator.java | 91 +
.../decorators/HeadlessServiceDecorator.java | 76 +
.../decorators/KubernetesStepDecorator.java | 58 +
.../kubeclient/decorators/SecretDecorator.java | 108 ++
.../decorators/SpecificationEnvDecorator.java | 81 +
.../factory/AbstractWorkloadFactory.java | 185 ++
.../kubeclient/factory/ApplicationJobFactory.java | 182 ++
.../kubeclient/factory/WorkerPodFactory.java | 88 +
.../kubeclient/resources/KubernetesConfigMap.java | 19 +-
.../kubeclient/resources/KubernetesJob.java | 82 +
.../kubeclient/resources/KubernetesPod.java | 70 +
.../kubeclient/resources/KubernetesResource.java | 52 +
.../kubeclient/resources/KubernetesSecret.java | 19 +-
.../kubeclient/resources/KubernetesService.java | 19 +-
.../kubeclient/resources/KubernetesWatch.java | 16 +-
.../SeatunnelKubernetesApplicationWorker.java | 78 +
.../KubernetesApplicationResourcesTest.java | 1817 ++++++++++++++++++++
.../kubernetes/KubernetesApplicationTest.java | 693 ++++++++
.../KubernetesResourceManagerDriverTest.java | 570 ++++++
.../kubeclient/DefaultKubernetesClientTest.java | 412 +++++
.../kubeclient/InformerPodWatchTest.java | 110 ++
seatunnel-resource-managers/pom.xml | 32 +
tools/dependencies/known-dependencies.txt | 22 +
.../test_update_modules_check.py | 2 +-
tools/update_modules_check/update_modules_check.py | 2 +
173 files changed, 21798 insertions(+), 269 deletions(-)
create mode 100644 config/v1.kubernetes.conf.template
create mode 100644 docs/en/getting-started/application/cli.md
create mode 100644
docs/en/getting-started/application/kubernetes/architecture.md
create mode 100644
docs/en/getting-started/application/kubernetes/checkpoint-recovery.md
create mode 100644 docs/en/getting-started/application/kubernetes/commands.md
create mode 100644
docs/en/getting-started/application/kubernetes/configuration.md
create mode 100644 docs/en/getting-started/application/kubernetes/faq.md
create mode 100644 docs/en/getting-started/application/kubernetes/overview.md
create mode 100644
docs/en/getting-started/application/kubernetes/quick-start.md
create mode 100644 docs/en/getting-started/application/overview.md
create mode 100644 docs/zh/getting-started/application/cli.md
create mode 100644
docs/zh/getting-started/application/kubernetes/architecture.md
create mode 100644
docs/zh/getting-started/application/kubernetes/checkpoint-recovery.md
create mode 100644 docs/zh/getting-started/application/kubernetes/commands.md
create mode 100644
docs/zh/getting-started/application/kubernetes/configuration.md
create mode 100644 docs/zh/getting-started/application/kubernetes/faq.md
create mode 100644 docs/zh/getting-started/application/kubernetes/overview.md
create mode 100644
docs/zh/getting-started/application/kubernetes/quick-start.md
create mode 100644 docs/zh/getting-started/application/overview.md
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/StandaloneResourceManager.java
=>
seatunnel-common/src/main/java/org/apache/seatunnel/common/constants/ApplicationOperation.java
(64%)
create mode 100644
seatunnel-core/seatunnel-starter/src/main/bin/seatunnel-application.sh
create mode 100644
seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/SeaTunnelApplication.java
create mode 100644
seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/args/ApplicationCommandArgs.java
create mode 100644
seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ApplicationExecuteCommand.java
create mode 100644
seatunnel-core/seatunnel-starter/src/test/java/org/apache/seatunnel/core/starter/seatunnel/command/ApplicationExecuteCommandTest.java
create mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-bouncycastle-1.76.txt
create mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-protobuf-java-3.24.3.txt
create mode 100644
seatunnel-dist/release-docs/licenses/LICENSE-public-suffix-list.txt
create mode 100644 seatunnel-e2e/seatunnel-resource-managers-e2e/pom.xml
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/java/org/apache/seatunnel/resource/e2e/kubernetes/AbstractKubernetesApplicationIT.java
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/java/org/apache/seatunnel/resource/e2e/kubernetes/KubernetesApplicationBatchIT.java
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/java/org/apache/seatunnel/resource/e2e/kubernetes/KubernetesApplicationConfigurationIT.java
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/java/org/apache/seatunnel/resource/e2e/kubernetes/KubernetesApplicationLifecycleIT.java
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/java/org/apache/seatunnel/resource/e2e/kubernetes/KubernetesApplicationRecoveryIT.java
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/Dockerfile
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/batch/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/batch/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/checkpoint-restore/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/checkpoint-restore/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/checkpoint/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/checkpoint/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/checkpoints-pvc.yaml
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration-job-conf-configmap/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration-job-conf-configmap/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration-job-conf-secret/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration-job-conf-secret/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration-ref/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration-ref/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/configuration/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/invalid-job/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/invalid-job/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/isolation/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/isolation/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/quota/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/quota/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/role-binding.yaml
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/role.yaml
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/seatunnel.yaml
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/service-account.yaml
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/suite.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/worker-loss/application.config
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/worker-loss/job.conf
create mode 100644
seatunnel-e2e/seatunnel-resource-managers-e2e/src/test/resources/kubernetes/worker-quota.yaml
create mode 100644
seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/deployment/ApplicationClusterDeployer.java
create mode 100644
seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/deployment/ApplicationClusterDescriptorFactory.java
create mode 100644
seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/deployment/ClusterClientServiceLoader.java
create mode 100644
seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/deployment/ClusterDescriptor.java
copy
seatunnel-engine/{seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/StandaloneResourceManager.java
=>
seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/deployment/SeatunnelClientProvider.java}
(67%)
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/SeatunnelApplicationConfig.java
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ApplicationOptions.java
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/spec/ApplicationSpecification.java
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/spec/WorkerSpecification.java
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/runtime/ApplicationStatus.java
copy
seatunnel-engine/{seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/thirdparty/CreateWorkerResult.java
=>
seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/utils/UUIDUtil.java}
(73%)
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/test/java/org/apache/seatunnel/engine/common/config/SeatunnelApplicationConfigTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-common/src/test/java/org/apache/seatunnel/engine/common/spec/ApplicationSpecificationTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/application/ApplicationJobExecutionEnvironment.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/application/ApplicationJobRunner.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/ApplicationResourceManager.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/{thirdparty/ThirdPartyResourceManager.java
=> ResourceEventHandler.java} (51%)
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/ResourceManagerDriver.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/{StandaloneResourceManager.java
=> resource/ResourceID.java} (52%)
copy
seatunnel-engine/{seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/runtime/DeployType.java
=>
seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/resource/ResourceIDRetrievable.java}
(76%)
delete mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/thirdparty/kubernetes/KubernetesResourceManager.java
delete mode 100644
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/thirdparty/yarn/YarnResourceManager.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/application/ApplicationLifecycleTest.java
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/resources/application_lifecycle_batch_fake_to_console.conf
create mode 100644
seatunnel-engine/seatunnel-engine-server/src/test/resources/application_lifecycle_streaming_fake_to_console.conf
create mode 100644 seatunnel-resource-managers/README.md
create mode 100644 seatunnel-resource-managers/kubernetes/pom.xml
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/KubernetesApplicationClusterDescriptor.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/KubernetesApplicationClusterDescriptorFactory.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/KubernetesResourceManagerDriver.java
rename
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/thirdparty/ThirdPartyResourceManager.java
=>
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/KubernetesWorkerNode.java
(65%)
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/cli/SeatunnelKubernetesApplicationCli.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/client/KubernetesApplicationClient.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/config/KubernetesApplicationConfig.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/config/KubernetesConfigMapEntry.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/config/KubernetesEnvFromReference.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/config/KubernetesEnvironmentVariable.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/config/KubernetesOptions.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/config/KubernetesToleration.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/exception/KubernetesClientException.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/DefaultKubernetesClient.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/InformerPodWatch.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/KubernetesClient.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/KubernetesClientFactory.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/KubernetesConstants.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/KubernetesResourceIdentity.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/PodWatchCallback.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/StandaloneResourceManager.java
=>
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/AbstractKubernetesStepDecorator.java
(52%)
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/ConfigMapDecorator.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/EnvironmentDecorator.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/HeadlessServiceDecorator.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/KubernetesStepDecorator.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/SecretDecorator.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/decorators/SpecificationEnvDecorator.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/factory/AbstractWorkloadFactory.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/factory/ApplicationJobFactory.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/factory/WorkerPodFactory.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/StandaloneResourceManager.java
=>
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesConfigMap.java
(58%)
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesJob.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesPod.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesResource.java
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/StandaloneResourceManager.java
=>
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesSecret.java
(60%)
copy
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/StandaloneResourceManager.java
=>
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesService.java
(61%)
rename
seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/thirdparty/CreateWorkerResult.java
=>
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/kubeclient/resources/KubernetesWatch.java
(71%)
create mode 100644
seatunnel-resource-managers/kubernetes/src/main/java/org/apache/seatunnel/resource/kubernetes/worker/SeatunnelKubernetesApplicationWorker.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/test/java/org/apache/seatunnel/resource/kubernetes/KubernetesApplicationResourcesTest.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/test/java/org/apache/seatunnel/resource/kubernetes/KubernetesApplicationTest.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/test/java/org/apache/seatunnel/resource/kubernetes/KubernetesResourceManagerDriverTest.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/test/java/org/apache/seatunnel/resource/kubernetes/kubeclient/DefaultKubernetesClientTest.java
create mode 100644
seatunnel-resource-managers/kubernetes/src/test/java/org/apache/seatunnel/resource/kubernetes/kubeclient/InformerPodWatchTest.java
create mode 100644 seatunnel-resource-managers/pom.xml
