[feat][all]All rename to 'chunjun'

.github/ISSUE_TEMPLATE/--ask-a-question.md

@@ -15,8 +15,8 @@ Before asking a question, make sure you have:
 
 - Searched existing Stack Overflow questions.
 - Googled your question.
-- Searched open and closed [GitHub issues](https://github.com/DTStack/flinkx/issues)
+- Searched open and closed [GitHub issues](https://github.com/DTStack/chunjun/issues)
 - Read the documentation:
- - [flinkx Doc](https://github.com/DTStack/flinkx/tree/1.10_release/docs)
+ - [start-chunjun Doc](https://github.com/DTStack/chunjun/tree/1.10_release/docs)
 
 -->

.github/ISSUE_TEMPLATE/--development-task.md

@@ -1,6 +1,6 @@
 ---
 name: "\U0001F680Development Task"
-about: As a flinkx developer, I want to record a development task.
+about: As a chunjun developer, I want to record a development task.
 title: ''
 labels: enhancement
 assignees: ''

.gitignore

@@ -1,16 +1,45 @@
-# Created by .ignore support plugin (hsz.mobi)
+# Compiled class file
+*.class
+
+# Log file
+*.log
+
+# BlueJ files
+*.ctxt
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.nar
+*.ear
+*.zip
+*.tar.gz
+*.rar
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+replay_pid*
+
+# build targets
+target/
+
+# Intellij Idea files
 .idea/
-plugins/
-syncplugins/
 *.iml
-target/
+
+# mac system
+.DS_Store
+
 lib/
-jobs/
+
+# out log.
 nohup.out
-flinkconf/
-hadoopconf/
-/default_task_id_output
-/syncplugins
-flinkxplugins
-flinkx-dist/
-flinkx-test/
+
+# auth
+*.keytab
+
+# chunjun plugins
+chunjun-dist/

bin/flinkx → bin/start-chunjun

@@ -19,7 +19,7 @@
 
 set -e
 
-export FLINKX_HOME="$(cd "`dirname "$0"`"/..; pwd)"
+export CHUNJUN_HOME="$(cd "`dirname "$0"`"/..; pwd)"
 
 # Find the java binary
 if [ -n "${JAVA_HOME}" ]; then
@@ -33,8 +33,8 @@ else
  fi
 fi
 
-JAR_DIR=$FLINKX_HOME/lib/*
-CLASS_NAME=com.dtstack.flinkx.client.Launcher
+JAR_DIR=$CHUNJUN_HOME/lib/*
+CLASS_NAME=com.dtstack.chunjun.client.Launcher
 
-echo "flinkx starting ..."
+echo "ChunJun starting ..."
 nohup $JAVA_RUN -cp $JAR_DIR $CLASS_NAME $@ &

build/build.sh

@@ -19,7 +19,7 @@
 
 find_build=`find build -type f -maxdepth 2`
 if [[ $find_build == "" ]] ; then
- echo "You have to call the script from the flinkx/ dir"
+ echo "You have to call the script from the chunjun/ dir"
  exit 1
 fi
 

flinkx-clients/pom.xml → chunjun-clients/pom.xml

@@ -3,14 +3,14 @@
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <parent>
- <artifactId>flinkx-parent</artifactId>
- <groupId>com.dtstack.flinkx</groupId>
+ <artifactId>chunjun</artifactId>
+ <groupId>com.dtstack.chunjun</groupId>
  <version>1.12-SNAPSHOT</version>
  </parent>
  <modelVersion>4.0.0</modelVersion>
 
- <artifactId>flinkx-clients</artifactId>
- <name>FlinkX : Clients</name>
+ <artifactId>chunjun-clients</artifactId>
+ <name>ChunJun : Clients</name>
 
  <dependencies>
 
@@ -21,8 +21,8 @@
  </dependency>
 
  <dependency>
- <groupId>com.dtstack.flinkx</groupId>
- <artifactId>flinkx-core</artifactId>
+ <groupId>com.dtstack.chunjun</groupId>
+ <artifactId>chunjun-core</artifactId>
  <version>${project.version}</version>
  </dependency>
 

flinkx-clients/src/main/java/com/dtstack/flinkx/client/ClusterClientHelper.java → chunjun-clients/src/main/java/com/dtstack/chunjun/client/ClusterClientHelper.java

@@ -15,12 +15,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.dtstack.flinkx.client;
+package com.dtstack.chunjun.client;
 
 import org.apache.flink.client.program.ClusterClient;
 
 /**
- * @program: flinkx
+ * @program chunjun
  * @author: xiuzhu
  * @create: 2021/05/31
  */

flinkx-clients/src/main/java/com/dtstack/flinkx/client/JobDeployer.java → chunjun-clients/src/main/java/com/dtstack/chunjun/client/JobDeployer.java

@@ -15,10 +15,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.dtstack.flinkx.client;
+package com.dtstack.chunjun.client;
 
-import com.dtstack.flinkx.options.Options;
-import com.dtstack.flinkx.util.MapUtil;
+import com.dtstack.chunjun.options.Options;
+import com.dtstack.chunjun.util.MapUtil;
 
 import org.apache.flink.configuration.Configuration;
 
@@ -29,7 +29,7 @@
 import java.util.Properties;
 
 /**
- * @program: flinkx
+ * @program: Chunjun
  * @author: xiuzhu
  * @create: 2021/05/31
  */

flinkx-clients/src/main/java/com/dtstack/flinkx/client/Launcher.java → chunjun-clients/src/main/java/com/dtstack/chunjun/client/Launcher.java

@@ -15,19 +15,19 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.dtstack.flinkx.client;
-
-import com.dtstack.flinkx.classloader.ClassLoaderManager;
-import com.dtstack.flinkx.client.kubernetes.KubernetesApplicationClusterClientHelper;
-import com.dtstack.flinkx.client.kubernetes.KubernetesSessionClusterClientHelper;
-import com.dtstack.flinkx.client.local.LocalClusterClientHelper;
-import com.dtstack.flinkx.client.standalone.StandaloneClusterClientHelper;
-import com.dtstack.flinkx.client.yarn.YarnPerJobClusterClientHelper;
-import com.dtstack.flinkx.client.yarn.YarnSessionClusterClientHelper;
-import com.dtstack.flinkx.enums.ClusterMode;
-import com.dtstack.flinkx.options.OptionParser;
-import com.dtstack.flinkx.options.Options;
-import com.dtstack.flinkx.util.ExecuteProcessHelper;
+package com.dtstack.chunjun.client;
+
+import com.dtstack.chunjun.classloader.ClassLoaderManager;
+import com.dtstack.chunjun.client.kubernetes.KubernetesApplicationClusterClientHelper;
+import com.dtstack.chunjun.client.kubernetes.KubernetesSessionClusterClientHelper;
+import com.dtstack.chunjun.client.local.LocalClusterClientHelper;
+import com.dtstack.chunjun.client.standalone.StandaloneClusterClientHelper;
+import com.dtstack.chunjun.client.yarn.YarnPerJobClusterClientHelper;
+import com.dtstack.chunjun.client.yarn.YarnSessionClusterClientHelper;
+import com.dtstack.chunjun.enums.ClusterMode;
+import com.dtstack.chunjun.options.OptionParser;
+import com.dtstack.chunjun.options.Options;
+import com.dtstack.chunjun.util.ExecuteProcessHelper;
 
 import org.apache.flink.client.deployment.ClusterDeploymentException;
 import org.apache.flink.configuration.ConfigConstants;
@@ -43,7 +43,7 @@
 import java.util.List;
 
 /**
- * FlinkX commandline Launcher
+ * Chunjun commandline Launcher
  *
  * <p>Company: www.dtstack.com
  *
@@ -52,11 +52,11 @@
 public class Launcher {
  private static final Logger LOG = LoggerFactory.getLogger(Launcher.class);
 
- public static final String KEY_FLINKX_HOME = "FLINKX_HOME";
+ public static final String KEY_CHUNJUN_HOME = "CHUNJUN_HOME";
  public static final String KEY_FLINK_HOME = "FLINK_HOME";
  public static final String KEY_HADOOP_HOME = "HADOOP_HOME";
 
- public static final String PLUGINS_DIR_NAME = "flinkx-dist";
+ public static final String PLUGINS_DIR_NAME = "chunjun-dist";
 
  public static void main(String[] args) throws Exception {
  OptionParser optionParser = new OptionParser(args);
@@ -121,7 +121,7 @@ public static void main(String[] args) throws Exception {
 
  private static void findDefaultConfigDir(Options launcherOptions)
  throws ClusterDeploymentException {
- findDefaultFlinkxDistDir(launcherOptions);
+ findDefaultChunJunDistDir(launcherOptions);
 
  if (ClusterMode.local.name().equalsIgnoreCase(launcherOptions.getMode())) {
  return;
@@ -166,24 +166,24 @@ private static void findDefaultFlinkConf(Options launcherOptions) {
  }
  }
 
- private static void findDefaultFlinkxDistDir(Options launcherOptions)
+ private static void findDefaultChunJunDistDir(Options launcherOptions)
  throws ClusterDeploymentException {
- String distDir = launcherOptions.getFlinkxDistDir();
+ String distDir = launcherOptions.getChunjunDistDir();
  if (StringUtils.isEmpty(distDir)) {
- String flinkxHome = getSystemProperty(KEY_FLINKX_HOME);
- if (StringUtils.isNotEmpty(flinkxHome)) {
- flinkxHome = flinkxHome.trim();
- if (flinkxHome.endsWith(File.separator)) {
- distDir = flinkxHome + PLUGINS_DIR_NAME;
+ String chunjunHome = getSystemProperty(KEY_CHUNJUN_HOME);
+ if (StringUtils.isNotEmpty(chunjunHome)) {
+ chunjunHome = chunjunHome.trim();
+ if (chunjunHome.endsWith(File.separator)) {
+ distDir = chunjunHome + PLUGINS_DIR_NAME;
  } else {
- distDir = flinkxHome + File.separator + PLUGINS_DIR_NAME;
+ distDir = chunjunHome + File.separator + PLUGINS_DIR_NAME;
  }
 
- launcherOptions.setFlinkxDistDir(distDir);
+ launcherOptions.setChunjunDistDir(distDir);
  }
  }
  if (StringUtils.isEmpty(distDir)) {
- notConfiguredException(KEY_FLINKX_HOME);
+ notConfiguredException(KEY_CHUNJUN_HOME);
  }
  System.setProperty(ConfigConstants.ENV_FLINK_PLUGINS_DIR, distDir);
  }

flinkx-clients/src/main/java/com/dtstack/flinkx/client/constants/ConfigConstant.java → chunjun-clients/src/main/java/com/dtstack/chunjun/client/constants/ConfigConstant.java

@@ -15,10 +15,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.dtstack.flinkx.client.constants;
+package com.dtstack.chunjun.client.constants;
 
 /**
- * @program: flinkx
+ * @program: ChunJun
  * @author: xiuzhu
  * @create: 2021/06/13
  */

flinkx-clients/src/main/java/com/dtstack/flinkx/client/kubernetes/KubernetesApplicationClusterClientHelper.java → chunjun-clients/src/main/java/com/dtstack/chunjun/client/kubernetes/KubernetesApplicationClusterClientHelper.java

@@ -15,13 +15,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.dtstack.flinkx.client.kubernetes;
+package com.dtstack.chunjun.client.kubernetes;
 
-import com.dtstack.flinkx.client.ClusterClientHelper;
-import com.dtstack.flinkx.client.JobDeployer;
-import com.dtstack.flinkx.client.constants.ConfigConstant;
-import com.dtstack.flinkx.client.util.PluginInfoUtil;
-import com.dtstack.flinkx.options.Options;
+import com.dtstack.chunjun.client.ClusterClientHelper;
+import com.dtstack.chunjun.client.JobDeployer;
+import com.dtstack.chunjun.client.constants.ConfigConstant;
+import com.dtstack.chunjun.client.util.PluginInfoUtil;
+import com.dtstack.chunjun.options.Options;
 
 import org.apache.flink.client.deployment.ClusterSpecification;
 import org.apache.flink.client.deployment.application.ApplicationConfiguration;
@@ -55,7 +55,7 @@
 import static org.apache.flink.util.Preconditions.checkNotNull;
 
 /**
- * @program: flinkx
+ * @program: ChunJun
  * @author: xiuzhu
  * @create: 2021/05/31
  */
@@ -155,10 +155,10 @@ private void setDeployerConfig(Configuration configuration, Options launcherOpti
  throws FileNotFoundException {
  configuration.set(DeploymentOptionsInternal.CONF_DIR, launcherOptions.getFlinkConfDir());
 
- String coreJarFileName = PluginInfoUtil.getCoreJarName(launcherOptions.getFlinkxDistDir());
+ String coreJarFileName = PluginInfoUtil.getCoreJarName(launcherOptions.getChunjunDistDir());
  String remoteCoreJarPath =
  "local://"
- + launcherOptions.getRemoteFlinkxDistDir()
+ + launcherOptions.getRemoteChunJunDistDir()
  + File.separator
  + coreJarFileName;
  configuration.set(PipelineOptions.JARS, Collections.singletonList(remoteCoreJarPath));

flinkx-clients/src/main/java/com/dtstack/flinkx/client/kubernetes/KubernetesSessionClusterClientHelper.java → chunjun-clients/src/main/java/com/dtstack/chunjun/client/kubernetes/KubernetesSessionClusterClientHelper.java

@@ -15,12 +15,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.dtstack.flinkx.client.kubernetes;
+package com.dtstack.chunjun.client.kubernetes;
 
-import com.dtstack.flinkx.client.ClusterClientHelper;
-import com.dtstack.flinkx.client.JobDeployer;
-import com.dtstack.flinkx.client.util.JobGraphUtil;
-import com.dtstack.flinkx.options.Options;
+import com.dtstack.chunjun.client.ClusterClientHelper;
+import com.dtstack.chunjun.client.JobDeployer;
+import com.dtstack.chunjun.client.util.JobGraphUtil;
+import com.dtstack.chunjun.options.Options;
 
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.client.program.ClusterClient;
@@ -39,7 +39,7 @@
 import java.util.List;
 
 /**
- * @program: flinkx
+ * @program: ChunJun
  * @author: xiuzhu
  * @create: 2021/05/31
  */
@@ -61,7 +61,7 @@ public ClusterClient submit(JobDeployer jobDeployer) throws Exception {
  }
 
  FlinkKubeClient flinkKubeClient =
- FlinkKubeClientFactory.getInstance().fromConfiguration(configuration, "flinkx");
+ FlinkKubeClientFactory.getInstance().fromConfiguration(configuration, "ChunJun");
  try (KubernetesClusterDescriptor descriptor =
  new KubernetesClusterDescriptor(configuration, flinkKubeClient); ) {
  ClusterClientProvider<String> retrieve = descriptor.retrieve(clusterId);