Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -81,9 +81,9 @@ deploy-kafka: deploy deploy-flink
kubectl wait --for=condition=Established=True crds/kafkas.kafka.strimzi.io
kubectl apply -f ./deploy/samples/kafkadb.yaml
kubectl apply -f ./deploy/dev/kafka.yaml
kubectl wait kafka.kafka.strimzi.io/one --for=condition=Ready --timeout=10m -n kafka
kubectl wait kafkatopic.kafka.strimzi.io/kafka-database-existing-topic-1 --for=condition=Ready --timeout=10m
kubectl wait kafkatopic.kafka.strimzi.io/kafka-database-existing-topic-2 --for=condition=Ready --timeout=10m
kubectl wait kafka.kafka.strimzi.io/one --for=condition=Ready --timeout=15m -n kafka
kubectl wait kafkatopic.kafka.strimzi.io/kafka-database-existing-topic-1 --for=condition=Ready --timeout=15m
kubectl wait kafkatopic.kafka.strimzi.io/kafka-database-existing-topic-2 --for=condition=Ready --timeout=15m

undeploy-kafka:
kubectl delete kafkatopic.kafka.strimzi.io --all || echo "skipping"
Expand Down
4 changes: 2 additions & 2 deletions deploy/dev/kafka.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ metadata:
labels:
strimzi.io/cluster: one
spec:
replicas: 3
replicas: 1
roles:
- controller
storage:
Expand All @@ -42,7 +42,7 @@ metadata:
labels:
strimzi.io/cluster: one
spec:
replicas: 3
replicas: 1
roles:
- broker
storage:
Expand Down
2 changes: 1 addition & 1 deletion docs/kubernetes/crd-reference.md
Original file line number Diff line number Diff line change
Expand Up @@ -437,7 +437,7 @@ spec:
| Field | Type | Required | Description |
| --------------- | ------ | :------: | --------------------------------------------------------------------------------- |
| `sql` | array | yes | One or more SQL statements run as a single job. |
| `dialect` | enum | | `Flink` (default) or `FlinkBeam`. |
| `dialect` | enum | | `Flink` (default), `FlinkBeam`, or `Spark`. |
| `executionMode` | enum | | `Streaming` (default) or `Batch`. |
| `configs` | object | | Job-level configuration passed through to the engine. |

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
* SQL job spec
*/
@ApiModel(description = "SQL job spec")
@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2026-05-19T19:18:59.968Z[Etc/UTC]")
@javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2026-06-23T18:44:48.199Z[Etc/UTC]")
public class V1alpha1SqlJobSpec {
public static final String SERIALIZED_NAME_CONFIGS = "configs";
@SerializedName(SERIALIZED_NAME_CONFIGS)
Expand All @@ -45,7 +45,9 @@ public class V1alpha1SqlJobSpec {
public enum DialectEnum {
FLINK("Flink"),

FLINKBEAM("FlinkBeam");
FLINKBEAM("FlinkBeam"),

SPARK("Spark");

private String value;

Expand Down
1 change: 1 addition & 0 deletions hoptimator-k8s/src/main/resources/sqljobs.crd.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@ spec:
enum:
- Flink
- FlinkBeam
- Spark
default: Flink
executionMode:
description: Streaming or Batch.
Expand Down
Loading