cancel
Turn on suggestions
Auto-suggest helps you quickly narrow down your search results by suggesting possible matches as you type.
Showing results for 
Search instead for 
Did you mean: 
Help
Nastia
New Contributor III
since ‎04-17-2024
‎06-24-2024

User Stats

  • 7 Posts
  • 0 Solutions
  • 2 Kudos given
  • 1 Kudos received

User Activity

DLT fails with Queries with streaming sources must be executed with writeStream.start();

06-24-2024
Hi guys!I am having an issue with passing the "streaming flow" between layers of the DLT.first layer "ETD_Bz" is passing through, but then "ETD_Flattened_Bz" is failing with "pyspark.errors.exceptions.captured.AnalysisException: Queries with streamin...

I keep getting dataset from spark.table command (instead of dataframe)

06-18-2024
I am trying to create a simple dlt pipeline: @dlt.tabledef today_latest_execution():  return spark.sql("SELECT * FROM LIVE.last_execution") @on_event_hookdef write_events_to_x(event  if (     today_latest_execution().count() == 0      try:       .....

I am getting NoneType error when running a query from API on cluster

04-17-2024
When I am running a query on Databricks itself from notebook, it is running fine and giving me results. But the same query when executed from FastAPI (Python, using databricks library) is giving me "TypeError: 'NoneType' object is not iterable".I can...
Kudos from
View all
Kudos given to