2 hours 30 mins
Serves: 4
- 1 tbsp extra virgin olive oil
- 800g beef flank or skirt, diced
Robin Moffatt rmoff
rmoff
/ flink-rmoff-sql-client-asgard08.log
Created
April 15, 2024 10:32
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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
/ 0_README.adoc
Last active
March 8, 2024 15:56
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
/ iceberg.log
Created
February 1, 2024 12:50
This file has been truncated, but you can view the full file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [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
/ iceberg.log
Created
February 1, 2024 12:35
This file has been truncated, but you can view the full file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [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
/ Write-Audit-Publish (WAP) with Project Nessie.ipynb
Created
May 16, 2023 20:55
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
rmoff
/ create database spark sql problem.ipynb
Created
April 26, 2023 11:47
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
rmoff
/ 00 README.md
Last active
April 27, 2023 16:18
rmoff
/ lakeFS and Delta.ipynb
Created
April 6, 2023 20:21
Using lakeFS and Delta Lake with PySpark in a Jupyter Notebook
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
NewerOlder