项目配置 #

$ mvn archetype:generate \  -DarchetypeGroupId=org.apache.flink \  -DarchetypeArtifactId=flink-quickstart-java \  -DarchetypeVersion=2.3-SNAPSHOT 

$ curl https://flink.apache.org/q/quickstart.sh | bash -s 2.3-SNAPSHOT 

plugins {  id 'java'  id 'application'  // shadow plugin to produce fat JARs  id 'com.github.johnrengelman.shadow' version '7.1.2' } // artifact properties group = 'org.quickstart' version = '0.1-SNAPSHOT' mainClassName = 'org.quickstart.DataStreamJob' description = """Flink Quickstart Job""" ext {  javaVersion = '1.8'  flinkVersion = '2.3-SNAPSHOT'  scalaBinaryVersion = '_2.12'  slf4jVersion = '1.7.36'  log4jVersion = '2.24.3' } sourceCompatibility = javaVersion targetCompatibility = javaVersion tasks.withType(JavaCompile) {  options.encoding = 'UTF-8' } applicationDefaultJvmArgs = ["-Dlog4j.configurationFile=log4j2.properties"]  // declare where to find the dependencies of your project repositories {  mavenCentral()  maven {  url "https://repository.apache.org/content/repositories/snapshots"  mavenContent {  snapshotsOnly()  }  } } // NOTE: We cannot use "compileOnly" or "shadow" configurations since then we could not run code // in the IDE or with "gradle run". We also cannot exclude transitive dependencies from the // shadowJar yet (see https://github.com/johnrengelman/shadow/issues/159). // -> Explicitly define the // libraries we want to be included in the "flinkShadowJar" configuration! configurations {  flinkShadowJar // dependencies which go into the shadowJar  // always exclude these (also from transitive dependencies) since they are provided by Flink  flinkShadowJar.exclude group: 'org.apache.flink', module: 'force-shading'  flinkShadowJar.exclude group: 'com.google.code.findbugs', module: 'jsr305'  flinkShadowJar.exclude group: 'org.slf4j'  flinkShadowJar.exclude group: 'org.apache.logging.log4j' } // declare the dependencies for your production and test code dependencies {  // --------------------------------------------------------------  // Compile-time dependencies that should NOT be part of the  // shadow (uber) jar and are provided in the lib folder of Flink  // --------------------------------------------------------------  implementation "org.apache.flink:flink-streaming-java:${flinkVersion}"  implementation "org.apache.flink:flink-clients:${flinkVersion}"  // --------------------------------------------------------------  // Dependencies that should be part of the shadow jar, e.g.  // connectors. These must be in the flinkShadowJar configuration!  // --------------------------------------------------------------  //flinkShadowJar "org.apache.flink:flink-connector-kafka:${flinkVersion}"  runtimeOnly "org.apache.logging.log4j:log4j-slf4j-impl:${log4jVersion}"  runtimeOnly "org.apache.logging.log4j:log4j-api:${log4jVersion}"  runtimeOnly "org.apache.logging.log4j:log4j-core:${log4jVersion}"  // Add test dependencies here.  // testCompile "junit:junit:4.12" } // make compileOnly dependencies available for tests: sourceSets {  main.compileClasspath += configurations.flinkShadowJar  main.runtimeClasspath += configurations.flinkShadowJar  test.compileClasspath += configurations.flinkShadowJar  test.runtimeClasspath += configurations.flinkShadowJar  javadoc.classpath += configurations.flinkShadowJar } run.classpath = sourceSets.main.runtimeClasspath  jar {  manifest {  attributes 'Built-By': System.getProperty('user.name'),  'Build-Jdk': System.getProperty('java.version')  } }  shadowJar {  configurations = [project.configurations.flinkShadowJar] } 

rootProject.name = 'quickstart' 

bash -c "$(curl https://flink.apache.org/q/gradle-quickstart.sh)" -- 2.3-SNAPSHOT _2.12