Skip to content

Commit 976178d

Browse files
authored
Fix Zeppelin k8s connection (#105)
1 parent 2705864 commit 976178d

File tree

4 files changed

+14
-5
lines changed

4 files changed

+14
-5
lines changed

Makefile

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ deploy-flink: deploy
5050
helm repo add flink-operator-repo https://downloads.apache.org/flink/flink-kubernetes-operator-1.9.0/
5151
helm upgrade --install --atomic --set webhook.create=false,image.pullPolicy=Never,image.repository=docker.io/library/hoptimator-flink-operator,image.tag=latest --set-json='watchNamespaces=["default","flink"]' flink-kubernetes-operator flink-operator-repo/flink-kubernetes-operator
5252
kubectl apply -f deploy/dev/flink-session-cluster.yaml
53+
kubectl apply -f deploy/dev/flink-sql-gateway.yaml
5354
kubectl apply -f deploy/samples/flink-template.yaml
5455

5556
undeploy-flink:
@@ -132,6 +133,7 @@ build-zeppelin: build
132133

133134
# attaches to terminal (not run as daemon)
134135
run-zeppelin: build-zeppelin
136+
kubectl apply -f deploy/docker/zeppelin/zeppelin-flink-engine.yaml
135137
docker run --rm -p 8080:8080 \
136138
--volume=${HOME}/.kube/config:/opt/zeppelin/.kube/config \
137139
--add-host=docker-for-desktop:host-gateway \

deploy/docker/zeppelin/Dockerfile-zeppelin

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,10 +18,7 @@ USER root
1818
RUN chmod 660 /opt/zeppelin/conf/interpreter.json \
1919
/opt/zeppelin/conf/zeppelin-site.xml
2020

21-
# Add overrides for K8s (see: com.linkedin.hoptimator.k8s.K8sConfig)
22-
# host must match docker argument --add-host=<host>:host-gateway
23-
ENV KUBECONFIG_BASEPATH="https://docker-for-desktop:6443" \
24-
ZEPPELIN_HOME="/opt/zeppelin"
21+
ENV ZEPPELIN_HOME="/opt/zeppelin"
2522

2623
# restore settings from upstream Dockerfile
2724
USER 1000

deploy/docker/zeppelin/interpreter.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -515,7 +515,7 @@
515515
"properties": {
516516
"default.url": {
517517
"name": "default.url",
518-
"value": "jdbc:hoptimator://",
518+
"value": "jdbc:hoptimator://k8s.server=https://docker-for-desktop:6443",
519519
"type": "string",
520520
"description": "The URL for JDBC."
521521
},
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
# This is required as long as zeppelin is run via docker
2+
# If started via k8s we can remove this in favor of the standard flink-engine.yaml
3+
apiVersion: hoptimator.linkedin.com/v1alpha1
4+
kind: Engine
5+
metadata:
6+
name: flink-engine
7+
spec:
8+
url: jdbc:flink://host.docker.internal:8083
9+
dialect: Flink
10+

0 commit comments

Comments
 (0)