4.0.0
com.nextbreakpoint
com.nextbreakpoint.flink.client
1.1.4
jar
Flink Client
Java client for managing Apache Flink via REST API
https://github.com/nextbreakpoint/flink-client
BSD 3
http://nextbreakpoint.com/licenses/BSD3
Andrea Medeghini
andrea@nextbreakpoint.com
scm:git:git@github.com:nextbreakpoint/flink-client.git
scm:git:git@github.com:nextbreakpoint/flink-client.git
git@github.com:nextbreakpoint/flink-client.git
11
11
11
11
3.8
UTF-8
UTF-8
1.20
${flink-major.version}.0
1.18.36
2.0.16
2.24.1
2.11.0
4.12.0
1.9.0
1.7.0
1.3.2
2.2.26
0.0.6
5.11.3
3.26.3
5.14.2
4.2.2
3.4.2
3.3.1
3.11.1
3.13.0
3.6.0
3.5.2
3.5.2
3.2.0
3.4.0
3.5.0
3.2.0
3.2.7
1.2
3.6.0
1.13.0
2.18.0
3.0.64
1.7.0
1.6.0
0.45.1
0.8.12
1.3.0
https://oss.sonatype.org
https://oss.sonatype.org/content/repositories/snapshots
true
true
org.slf4j
slf4j-bom
${slf4j.version}
pom
import
org.apache.logging.log4j
log4j-bom
${log4j.version}
pom
import
org.projectlombok
lombok
${lombok.version}
io.swagger.core.v3
swagger-annotations
${swagger-annotations.version}
javax.annotation
javax.annotation-api
${javax.annotation-api.version}
com.squareup.okhttp3
okhttp
${okhttp.version}
com.squareup.okhttp3
logging-interceptor
${okhttp.version}
com.google.code.gson
gson
${gson.version}
io.gsonfire
gson-fire
${gson-fire.version}
org.threeten
threetenbp
${threetenbp.version}
org.junit
junit-bom
${junit5.version}
pom
import
org.mockito
mockito-bom
${mockito.version}
pom
import
org.assertj
assertj-bom
${assertj.version}
pom
import
org.awaitility
awaitility
${awaitility.version}
org.projectlombok
lombok
provided
io.swagger.core.v3
swagger-annotations
javax.annotation
javax.annotation-api
com.squareup.okhttp3
okhttp
com.squareup.okhttp3
logging-interceptor
com.google.code.gson
gson
io.gsonfire
gson-fire
org.threeten
threetenbp
org.slf4j
slf4j-api
org.slf4j
jul-to-slf4j
runtime
org.apache.logging.log4j
log4j-slf4j2-impl
runtime
org.junit.jupiter
junit-jupiter-engine
test
org.junit.jupiter
junit-jupiter-params
test
org.junit.platform
junit-platform-runner
test
org.assertj
assertj-core
test
org.mockito
mockito-core
test
org.awaitility
awaitility
test
src/main/resources
**/*
org.apache.maven.plugins
maven-toolchains-plugin
${maven-toolchains-plugin.version}
validate
toolchain
[${java.version},)
org.apache.maven.plugins
maven-enforcer-plugin
${maven-enforcer-plugin.version}
enforce-versions
enforce
${maven.version}
${java.version}
maven-clean-plugin
${maven-clean-plugin.version}
org.codehaus.mojo
build-helper-maven-plugin
${build-helper-maven-plugin.version}
org.apache.maven.plugins
maven-source-plugin
${maven-source-plugin.version}
attach-sources
jar
org.apache.maven.plugins
maven-javadoc-plugin
${maven-javadoc-plugin.version}
attach-javadocs
jar
false
org.apache.maven.plugins
maven-compiler-plugin
${maven-compiler-plugin.version}
org.projectlombok
lombok
${lombok.version}
org.apache.maven.plugins
maven-surefire-plugin
${maven-surefire-plugin.version}
false
@{argLine}
junit.jupiter.execution.parallel.enabled = true
junit.jupiter.execution.parallel.mode.default = same_thread
junit.jupiter.execution.parallel.mode.classes.default = concurrent
junit.jupiter.execution.parallel.config.strategy = fixed
junit.jupiter.execution.parallel.config.fixed.parallelism = 5
**/*Test.java
${flink.version}
${project.version}
${maven.multiModuleProjectDirectory}
plain
false
ASCII
org.apache.maven.surefire
surefire-junit-platform
${maven-surefire-plugin.version}
me.fabriciorby
maven-surefire-junit5-tree-reporter
${maven-surefire-junit5-tree-reporter.version}
org.apache.maven.plugins
maven-failsafe-plugin
${maven-failsafe-plugin.version}
integration-test
integration-test
verify
false
@{argLine}
junit.jupiter.execution.parallel.enabled = false
**/*IT.java
${flink.version}
${project.version}
${flink-dummies.version}
${maven.multiModuleProjectDirectory}
plain
false
ASCII
org.apache.maven.surefire
surefire-junit-platform
${maven-surefire-plugin.version}
me.fabriciorby
maven-surefire-junit5-tree-reporter
${maven-surefire-junit5-tree-reporter.version}
org.apache.maven.plugins
maven-dependency-plugin
${maven-dependency-plugin.version}
org.apache.maven.plugins
maven-shade-plugin
${maven-shade-plugin.version}
org.apache.maven.plugins
maven-jar-plugin
${maven-jar-plugin.version}
org.apache.maven.plugins
maven-gpg-plugin
${maven-gpg-plugin.version}
org.apache.maven.plugins
maven-patch-plugin
${maven-patch-plugin.version}
org.codehaus.mojo
versions-maven-plugin
${versions-maven-plugin.version}
file://${maven.multiModuleProjectDirectory}/maven-version-rules.xml
com.googlecode.maven-download-plugin
download-maven-plugin
${download-maven-plugin.version}
io.swagger.codegen.v3
swagger-codegen-maven-plugin
${swagger-codegen-maven-plugin.version}
io.fabric8
docker-maven-plugin
${docker-maven-plugin.version}
org.sonatype.plugins
nexus-staging-maven-plugin
${nexus-staging-maven-plugin.version}
de.jutzig
github-release-plugin
${github-release-plugin.version}
org.jacoco
jacoco-maven-plugin
${jacoco-maven-plugin.version}
prepare-agent
prepare-agent
report
report
org.apache.maven.plugins
maven-toolchains-plugin
org.apache.maven.plugins
maven-enforcer-plugin
org.codehaus.mojo
versions-maven-plugin
maven-clean-plugin
>${project.build.directory}/generated-sources
**/*
false
com.googlecode.maven-download-plugin
download-maven-plugin
download-openapi
clean
wget
https://nightlies.apache.org/flink/flink-docs-release-${flink-major.version}/generated/rest_v1_dispatcher.yml
${project.build.directory}/openapi
true
true
2
org.apache.maven.plugins
maven-patch-plugin
patch-openapi
clean
apply
${project.basedir}/patches
${project.build.directory}/openapi
1
true
openapi.patch
io.swagger.codegen.v3
swagger-codegen-maven-plugin
generate-code
clean
generate
${project.build.directory}/openapi/rest_v1_dispatcher.yml
com.nextbreakpoint.flink.client.api
com.nextbreakpoint.flink.client.model
com.nextbreakpoint.flink.client.api
ApiClient.java,ApiException.java,ApiResponse.java,ApiCallback.java,Authentication.java,JSON.java,Pair.java,Configuration.java,ProgressRequestBody.java,ProgressResponseBody.java,HttpBasicAuth.java,ApiKeyAuth.java,OAuth.java,StringUtil.java
false
false
java
okhttp4-gson
${project.basedir}/templates
src/main/java
java8
org.codehaus.mojo
build-helper-maven-plugin
add_sources
generate-sources
add-source
${project.build.directory}/generated-sources/src/main/java
org.apache.maven.plugins
maven-source-plugin
org.apache.maven.plugins
maven-javadoc-plugin
org.apache.maven.plugins
maven-compiler-plugin
org.apache.maven.plugins
maven-surefire-plugin
org.apache.maven.plugins
maven-failsafe-plugin
org.apache.maven.plugins
maven-dependency-plugin
copy
pre-integration-test
copy
com.nextbreakpoint
com.nextbreakpoint.flink.dummies
${flink-dummies.version}
shaded
jar
true
${project.build.directory}/downloaded
io.fabric8
docker-maven-plugin
true
true
%a
test-jobmanager-data
local
tmpfs
tmpfs
size=100m,uid=9999
test-taskmanager-1-data
local
tmpfs
tmpfs
size=100m,uid=9999
test-taskmanager-2-data
local
tmpfs
tmpfs
size=100m,uid=9999
apache/flink:${flink.version}-java11
jobmanager
jobmanager
8081:8081
jobmanager
rest.bind-port: 8081
jobmanager.rpc.address: jobmanager
jobmanager.memory.jvm-overhead.min: 64mb
jobmanager.memory.jvm-metaspace.size: 192mb
jobmanager.memory.off-heap.size: 64mb
jobmanager.memory.process.size: 500mb
jobmanager.memory.flink.size: 200mb
state.backend.type: hashmap
execution.checkpointing.dir: file:///data/checkpoints
execution.checkpointing.savepoint-dir: file:///data/savepoints
parallelism.default: 1
custom
flink-test
jobmanager
test-jobmanager-data:/data
./config:/var/config
Rest endpoint listening at 0.0.0.0:8081
apache/flink:${flink.version}-java11
taskmanager-1
taskmanager-1
taskmanager
jobmanager.rpc.address: jobmanager
jobmanager.memory.jvm-overhead.min: 64mb
jobmanager.memory.jvm-metaspace.size: 192mb
jobmanager.memory.off-heap.size: 64mb
jobmanager.memory.process.size: 500mb
jobmanager.memory.flink.size: 200mb
taskmanager.numberOfTaskSlots: 2
taskmanager.memory.jvm-overhead.min: 64mb
taskmanager.memory.jvm-metaspace.size: 192mb
taskmanager.memory.framework.heap.size: 64mb
taskmanager.memory.framework.off-heap.size: 64mb
taskmanager.memory.process.size: 600mb
taskmanager.memory.flink.size: 300mb
taskmanager.memory.network.fraction: 0.1
taskmanager.memory.managed.fraction: 0.1
state.backend.type: hashmap
execution.checkpointing.dir: file:///data/checkpoints
execution.checkpointing.savepoint-dir: file:///data/savepoints
parallelism.default: 1
custom
flink-test
taskmanager-1
test-taskmanager-1-data:/data
Successful registration
jobmanager
apache/flink:${flink.version}-java11
taskmanager-2
taskmanager-2
taskmanager
jobmanager.rpc.address: jobmanager
jobmanager.memory.jvm-overhead.min: 64mb
jobmanager.memory.jvm-metaspace.size: 192mb
jobmanager.memory.off-heap.size: 64mb
jobmanager.memory.process.size: 500mb
jobmanager.memory.flink.size: 200mb
taskmanager.numberOfTaskSlots: 2
taskmanager.memory.jvm-overhead.min: 64mb
taskmanager.memory.jvm-metaspace.size: 192mb
taskmanager.memory.framework.heap.size: 64mb
taskmanager.memory.framework.off-heap.size: 64mb
taskmanager.memory.process.size: 600mb
taskmanager.memory.flink.size: 300mb
taskmanager.memory.network.fraction: 0.1
taskmanager.memory.managed.fraction: 0.1
state.backend.type: hashmap
execution.checkpointing.dir: file:///data/checkpoints
execution.checkpointing.savepoint-dir: file:///data/savepoints
parallelism.default: 1
custom
flink-test
taskmanager-2
test-taskmanager-2-data:/data
Successful registration
jobmanager
start-flink
pre-integration-test
start
stop-flink
post-integration-test
stop
clean-flink
clean
volume-remove
org.jacoco
jacoco-maven-plugin
coverage-check
check
BUNDLE
*Test
*IT
LINE
COVEREDRATIO
20%
ossrh
channel
ossrh
org.apache.maven.plugins
maven-gpg-plugin
sign-artifacts
verify
sign
org.sonatype.plugins
nexus-staging-maven-plugin
true
ossrh
${nexus.host}
${nexus.autoreleaseafterclose}
ossrh
${nexus.url}
github
channel
github
de.jutzig
github-release-plugin
release
release
Flink Client ${project.version}
v${project.version}
false
false
${github.draft}