Robin Moffatt 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:

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

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

	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

	[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

	[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