cancel
Showing results for 
Search instead for 
Did you mean: 
lprevost
Contributor II
since ‎08-27-2021
‎06-09-2025

User Stats

  • 40 Posts
  • 1 Solutions
  • 6 Kudos given
  • 3 Kudos received

User Activity

[STREAM_FAILED] Query [id = 6a821fbc-490b-4ad8-891d-e4cacc2af1d6, runId = e055fede-8012-4369-861b-47183999e91d] terminated with exception: [STREAMING_STATEFUL_OPERATOR_NOT_MATCH_IN_STATE_METADATA] Streaming stateful operator name does not match with ...
I've saved a query on my sql warehouse which has a parameter called :list_parameter.   I've found my query id as follows:  from databricks.sdk import WorkspaceClient w = WorkspaceClient() for query in w.queries.list(): print(f"query: {query.displ...
If I'm running a scheduled batch Autoloader query which read from csv files on S3 and incrementally loads a delta table, how can I determine if new rows were added?  I'm currently trying to do this from the streaming query.lastProgress as follows.  s...
I've been using Autloloader in a DLT pipeline loading data from an s3 location to my hive_metastore shared with AWS glue.I'm now trying to migrate this over to Unity Catalog to take advantage of liquid clustering and data quality.However, I'm getting...
I would like to create a sampleBy (stratified version of sample) copy/clone of my delta table.   Ideally, I'd like to do this using a DLT.     My source table grows incrementally each month as batch files are added and autoloader picks them up.    Id...