FLINK_REPO_NAME=bahir-flink
FLINK_BAHIR_SOURCE_DIR=target/$FLINK_REPO_NAME
+GIT_REF=${GIT_REF:-master}
+
function checkout_code {
# Checkout code
cd "$BASE_DIR" # make sure we're in the base dir
rm -rf target
mkdir target
cd target
- git clone "https://git-wip-us.apache.org/repos/asf/$1.git" --quiet
+ git clone "https://gitbox.apache.org/repos/asf/$1.git" --quiet
cd "$1"
git checkout "$GIT_REF"
git_hash=$(git rev-parse --short HEAD)
spark-streaming-akka streaming-akka \
spark-streaming-mqtt streaming-mqtt \
spark-streaming-pubsub streaming-pubsub \
+ spark-streaming-pubnub streaming-pubnub \
spark-streaming-twitter streaming-twitter \
spark-streaming-zeromq streaming-zeromq
flink-streaming-activemq flink-connector-activemq \
flink-streaming-akka flink-connector-akka \
flink-streaming-flume flink-connector-flume \
+ flink-streaming-influxdb flink-connector-influxdb \
+ flink-streaming-influxdb2 flink-connector-influxdb2 \
+ flink-streaming-kudu flink-connector-kudu \
flink-streaming-netty flink-connector-netty \
+ flink-streaming-pinot flink-connector-pinot \
flink-streaming-redis flink-connector-redis
check_version_strings "$FLINK_WEBSITE_DOC_DIR"