Flink FROM_CHANGELOG and TO_CHANGELOG functions generally available
Built-in changelog conversion functions read custom-format change data into queryable tables and turn updating tables back into append-only streams, with user-mapped operation codes and no UDFs required.
Also shipped Aug 17, 2026Confluent in August 2026 →
AI mode for sensitive data classification (Public Preview)
Sensitive data classification now supports AI mode in public preview. When you enable AI mode on a classification profile, Snowflake uses the OpenAI GPT-5 Mini model to identify additional semantic categories beyond those detected by standard classification, which can improve accuracy.
New SNOWFLAKE_COCO_USAGE_HISTORY view in Account Usage and Organization Usage (General availability)
The SNOWFLAKE_COCO_USAGE_HISTORY view is now generally available in the ACCOUNT_USAGE and ORGANIZATION_USAGE schemas. It provides a unified view of usage history for CoCo across the CLI, Desktop, and Snowsight interfaces. The information in the view includes the number of credits consumed each time a user interacts with CoCo.
Upcoming deprecation of the data quality monitoring downstream_impact column
The downstream_impact column in the data quality monitoring results system table is being deprecated. Deprecation begins September 7, 2026, and rolls out gradually across regions over the following week. Until the rollout reaches your workspace, you might still be able to query downstream_impact .
Upcoming deprecation of the data quality monitoring root_cause_analysis column
The root_cause_analysis column in the data quality monitoring results system table is being deprecated. Deprecation begins August 18, 2026, and rolls out gradually across regions over the following several days. Until the rollout reaches your workspace, you might still be able to query root_cause_analysis .
Session restore for serverless jobs is now in Beta
Restore the Python variables and Spark session from a serverless compute job run into a new interactive notebook, so you can debug a failure or explore results without rerunning the job. Databricks automatically captures a state snapshot when an eligible run fails, runs 30 minutes or longer, or is cancelled, and keeps it for 7 days after the run completes.
Identity attributes in ABAC column mask policies (Beta)
Identity attributes are in Beta. You can now write Unity Catalog ABAC column mask policy conditions that target users by attributes synced from your identity provider, such as department or country , in addition to group membership.
More from Confluent CloudEvery Confluent Cloud release →
New in Confluent Cloud and WarpStream: Evolving the Data Streaming Platform for AI, Scale, and Control
Accelerate enterprise streaming and AI workloads with new product updates across Kora, connectors, Flink, Tableflow, AI anomaly detection and forecasting, security enhancements, and Warpstream.
New in Confluent Intelligence and AI Tools: Making Agents Native to the Stream, Expanded Model Support, New Agent Skills, and Confluent Assistant
Explore new AI features and AI tools: support for IBM Granite Time Series models and TimesFM models (EA), enhanced Real-Time Context Engine experience, new Agent Skills, Confluent Assistant
Confluent Cloud for Apache Flink: Engine for Mission-Critical, Real-Time Operational Systems and dbt/SQL-Native Home for Data Science and AI
Flink now acts as a robust engine for developers through Table API, UDFs, and PTFs while offering a SQL-native, dbt-integrated platform for data science and AI teams.
Baseline CFU for Flink statements (Limited Availability)
Set a best-effort minimum scaling target for an individual Flink statement; Autopilot keeps the statement at or above it. Configurable in Console or the Flink SQL REST API.
Lightning queries for Real-Time Context Engine data (Early Access)
Query the data the Real-Time Context Engine serves to AI agents directly through an API, without an agent, by reading the materialized table Confluent maintains for a topic.
AI_FORECAST and AI_DETECT_ANOMALIES support IBM Granite time-series models
The built-in functions now support IBM Granite TTM, FlowState, and PatchTST-FM models as an Early Access Program feature, alongside Google TimesFM 2.5.
Secret manager integration adds HTTP V2 and Oracle XStream connectors
Secret manager integration now extends to the HTTP Sink V2, HTTP Source V2, and Oracle XStream CDC Source fully managed connectors.
Cloud Console idle session timeout raised to two hours
The idle session timeout increases from 30 minutes to two hours, measured by console interaction. The eight-hour maximum session length is unchanged.