rmoff

2024-04-15 11:25:36,164 INFO  org.apache.flink.client.program.rest.RestClusterClient       [] - Successfully submitted job 'collect' (926ca3f6cfa9f0a4b5bc7f215b4681eb) to 'http://localhost:8081'.
2024-04-15 11:25:36,256 ERROR org.apache.flink.table.gateway.service.operation.OperationManager [] - Failed to execute the operation a2f854a9-938c-4c57-a484-4abe9d8eeb78.
org.apache.flink.table.api.TableException: Failed to execute sql
	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:1084) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
	at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1120) ~[flink-table-api-java-uber-1.18.1.jar:1.18.1]
	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeOperation(OperationExecutor.java:435) ~[flink-sql-gateway-1.18.1.jar:1.18.1]
	at org.apache.flink.table.gateway.service.operation.OperationExecutor.executeStatement(OperationExecutor.java:207) ~[f

rmoff

This is a collection for Postman to access the Apache Flink SQL Gateway. It’s based on the yaml published for version 1.18.1.

I’ve added Tests to set Session and Operation handles, and amended the collection to use these variables.

You need to set a Global Variable for baseURL to your Flink SQL Gateway.

If you launch the gateway locally with:

rmoff

[0.004s][info][class,load] opened: /Users/rmoff/.sdkman/candidates/java/11.0.21-tem/lib/modules
[0.006s][info][class,load] java.lang.Object source: jrt:/java.base
[0.006s][info][class,load] java.io.Serializable source: jrt:/java.base
[0.006s][info][class,load] java.lang.Comparable source: jrt:/java.base
[0.006s][info][class,load] java.lang.CharSequence source: jrt:/java.base
[0.006s][info][class,load] java.lang.String source: jrt:/java.base
[0.006s][info][class,load] java.lang.reflect.AnnotatedElement source: jrt:/java.base
[0.006s][info][class,load] java.lang.reflect.GenericDeclaration source: jrt:/java.base
[0.006s][info][class,load] java.lang.reflect.Type source: jrt:/java.base
[0.006s][info][class,load] java.lang.Class source: jrt:/java.base

rmoff

[0.004s][info][class,load] opened: /Users/rmoff/.sdkman/candidates/java/11.0.21-tem/lib/modules
[0.006s][info][class,load] java.lang.Object source: jrt:/java.base
[0.006s][info][class,load] java.io.Serializable source: jrt:/java.base
[0.006s][info][class,load] java.lang.Comparable source: jrt:/java.base
[0.006s][info][class,load] java.lang.CharSequence source: jrt:/java.base
[0.006s][info][class,load] java.lang.String source: jrt:/java.base
[0.006s][info][class,load] java.lang.reflect.AnnotatedElement source: jrt:/java.base
[0.006s][info][class,load] java.lang.reflect.GenericDeclaration source: jrt:/java.base
[0.006s][info][class,load] java.lang.reflect.Type source: jrt:/java.base
[0.007s][info][class,load] java.lang.Class source: jrt:/java.base

rmoff

rmoff

rmoff

⚠️ ⚠️ This gist is superseded by databricks/docker-spark-iceberg#76.

rmoff

rmoff

rmoff

rmoff: mac regex replace in file from CLI

Raycast AI: You can use the sed command on macOS to perform a regex replacement in a file from the command line. Here's the general syntax:

sed 's/regex/replacement/g' input_file > output_file

• regex: The regular expression you want to search for.
• replacement: The text you want to replace the matched regex with.