From ff3275c590acbde558c8c87a97b7c86f358eaa5b Mon Sep 17 00:00:00 2001
From: "release-feldera-feldera[bot]"
 <release-feldera-feldera[bot]@users.noreply.github.com>
Date: Mon, 13 Jul 2026 16:36:32 +0000
Subject: [PATCH 1/7] ci: Prepare for v0.321.0

---
 Cargo.lock                                | 42 +++++++++++------------
 Cargo.toml                                | 26 +++++++-------
 openapi.json                              |  2 +-
 python/dbt-feldera/pyproject.toml         |  2 +-
 python/felderize/pyproject.toml           |  2 +-
 python/pyproject.toml                     |  2 +-
 python/uv.lock                            |  4 +--
 sql-to-dbsp-compiler/SQL-compiler/pom.xml |  2 +-
 8 files changed, 41 insertions(+), 41 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 8f8059a5e0e..7d1a0f0883a 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3976,7 +3976,7 @@ dependencies = [
 
 [[package]]
 name = "dbsp"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "anyhow",
  "arc-swap",
@@ -4066,7 +4066,7 @@ dependencies = [
 
 [[package]]
 name = "dbsp_adapters"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "actix",
  "actix-codec",
@@ -4210,7 +4210,7 @@ dependencies = [
 
 [[package]]
 name = "dbsp_nexmark"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "anyhow",
  "ascii_table",
@@ -5194,7 +5194,7 @@ dependencies = [
 
 [[package]]
 name = "fda"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "anyhow",
  "arrow",
@@ -5246,7 +5246,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-adapterlib"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "actix-web",
  "anyhow",
@@ -5280,7 +5280,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-buffer-cache"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "crossbeam-utils",
  "enum-map",
@@ -5308,7 +5308,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-datagen"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "anyhow",
  "async-channel 2.5.0",
@@ -5334,7 +5334,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-fxp"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "bytecheck",
  "dbsp",
@@ -5354,7 +5354,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-iceberg"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "anyhow",
  "chrono",
@@ -5377,7 +5377,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-ir"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "proptest",
  "proptest-derive",
@@ -5389,7 +5389,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-macros"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "prettyplease",
  "proc-macro2",
@@ -5399,7 +5399,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-observability"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "actix-http",
  "awc",
@@ -5414,7 +5414,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-rest-api"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "chrono",
  "feldera-observability",
@@ -5433,7 +5433,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-samply"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "crossbeam",
  "feldera-size-of",
@@ -5469,7 +5469,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-sqllib"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "arcstr",
  "base58",
@@ -5513,7 +5513,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-storage"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "anyhow",
  "crossbeam",
@@ -5536,7 +5536,7 @@ dependencies = [
 
 [[package]]
 name = "feldera-types"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "actix-web",
  "anyhow",
@@ -8813,7 +8813,7 @@ checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184"
 
 [[package]]
 name = "pipeline-manager"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "actix-cors",
  "actix-files",
@@ -10023,7 +10023,7 @@ dependencies = [
 
 [[package]]
 name = "readers"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "async-std",
  "csv",
@@ -11722,7 +11722,7 @@ checksum = "0c790de23124f9ab44544d7ac05d60440adc586479ce501c1d6d7da3cd8c9cf5"
 
 [[package]]
 name = "sltsqlvalue"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "dbsp",
  "feldera-sqllib",
@@ -12193,7 +12193,7 @@ checksum = "a2eb9349b6444b326872e140eb1cf5e7c522154d69e7a0ffb0fb81c06b37543f"
 
 [[package]]
 name = "storage-test-compat"
-version = "0.320.0"
+version = "0.321.0"
 dependencies = [
  "dbsp",
  "derive_more 1.0.0",
diff --git a/Cargo.toml b/Cargo.toml
index 2985273bea9..61f342a1bd5 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [workspace.package]
 authors = ["Feldera Team <dev@feldera.com>"]
-version = "0.320.0"
+version = "0.321.0"
 license = "MIT OR Apache-2.0"
 homepage = "https://github.com/feldera/feldera"
 repository = "https://github.com/feldera/feldera"
@@ -108,7 +108,7 @@ csv = "1.2.2"
 csv-core = "0.1.10"
 dashmap = "6.1.0"
 datafusion = "53.1"
-dbsp = { path = "crates/dbsp", version = "0.320.0" }
+dbsp = { path = "crates/dbsp", version = "0.321.0" }
 dbsp_nexmark = { path = "crates/nexmark" }
 deadpool-postgres = "0.14.1"
 # Feldera fork of delta-rs: upstream tag `rust-v0.32.3` + 2 patches, on branch
@@ -133,20 +133,20 @@ erased-serde = "0.3.31"
 fake = "2.10"
 fastbloom = "0.14.0"
 fdlimit = "0.3.0"
-feldera-buffer-cache = { version = "0.320.0", path = "crates/buffer-cache" }
+feldera-buffer-cache = { version = "0.321.0", path = "crates/buffer-cache" }
 feldera-cloud1-client = "0.1.2"
 feldera-datagen = { path = "crates/datagen" }
-feldera-fxp = { version = "0.320.0", path = "crates/fxp", features = ["dbsp"] }
+feldera-fxp = { version = "0.321.0", path = "crates/fxp", features = ["dbsp"] }
 feldera-iceberg = { path = "crates/iceberg" }
-feldera-observability = { version = "0.320.0", path = "crates/feldera-observability" }
-feldera-macros = { version = "0.320.0", path = "crates/feldera-macros" }
-feldera-sqllib = { version = "0.320.0", path = "crates/sqllib" }
-feldera-storage = { version = "0.320.0", path = "crates/storage" }
-feldera-types = { version = "0.320.0", path = "crates/feldera-types" }
-feldera-rest-api = { version = "0.320.0", path = "crates/rest-api" }
-feldera-ir = { version = "0.320.0", path = "crates/ir" }
-feldera-adapterlib = { version = "0.320.0", path = "crates/adapterlib" }
-feldera-samply = { version = "0.320.0", path = "crates/samply" }
+feldera-observability = { version = "0.321.0", path = "crates/feldera-observability" }
+feldera-macros = { version = "0.321.0", path = "crates/feldera-macros" }
+feldera-sqllib = { version = "0.321.0", path = "crates/sqllib" }
+feldera-storage = { version = "0.321.0", path = "crates/storage" }
+feldera-types = { version = "0.321.0", path = "crates/feldera-types" }
+feldera-rest-api = { version = "0.321.0", path = "crates/rest-api" }
+feldera-ir = { version = "0.321.0", path = "crates/ir" }
+feldera-adapterlib = { version = "0.321.0", path = "crates/adapterlib" }
+feldera-samply = { version = "0.321.0", path = "crates/samply" }
 flate2 = "1.1.0"
 form_urlencoded = "1.2.0"
 fs_extra = "1.3.0"
diff --git a/openapi.json b/openapi.json
index bee0dc1721c..551d45762bb 100644
--- a/openapi.json
+++ b/openapi.json
@@ -10,7 +10,7 @@
     "license": {
       "name": "MIT OR Apache-2.0"
     },
-    "version": "0.320.0"
+    "version": "0.321.0"
   },
   "paths": {
     "/config/authentication": {
diff --git a/python/dbt-feldera/pyproject.toml b/python/dbt-feldera/pyproject.toml
index 5abf506ade6..52b68ec121e 100644
--- a/python/dbt-feldera/pyproject.toml
+++ b/python/dbt-feldera/pyproject.toml
@@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta"
 name = "dbt-feldera"
 readme = "README.md"
 description = "The dbt adapter for Feldera — DBSP-native incremental view maintenance"
-version = "0.320.0"
+version = "0.321.0"
 license = "MIT"
 requires-python = ">=3.10"
 authors = [
diff --git a/python/felderize/pyproject.toml b/python/felderize/pyproject.toml
index db8477dd1c1..b85605a12d3 100644
--- a/python/felderize/pyproject.toml
+++ b/python/felderize/pyproject.toml
@@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta"
 name = "felderize"
 readme = "README.md"
 description = "SQL dialect to Feldera SQL translator agent"
-version = "0.320.0"
+version = "0.321.0"
 license = "MIT"
 requires-python = ">=3.10"
 authors = [
diff --git a/python/pyproject.toml b/python/pyproject.toml
index f0f9beb5c52..616e8287b1c 100644
--- a/python/pyproject.toml
+++ b/python/pyproject.toml
@@ -6,7 +6,7 @@ build-backend = "setuptools.build_meta"
 name = "feldera"
 readme = "README.md"
 description = "The feldera python client"
-version = "0.320.0"
+version = "0.321.0"
 license = "MIT"
 requires-python = ">=3.10,<3.14"
 authors = [
diff --git a/python/uv.lock b/python/uv.lock
index c3f873082a4..3456b3766fd 100644
--- a/python/uv.lock
+++ b/python/uv.lock
@@ -9,7 +9,7 @@ resolution-markers = [
 ]
 
 [options]
-exclude-newer = "2026-07-03T22:21:56.598744158Z"
+exclude-newer = "2026-07-06T16:35:57.058623357Z"
 exclude-newer-span = "P1W"
 
 [[package]]
@@ -273,7 +273,7 @@ wheels = [
 
 [[package]]
 name = "feldera"
-version = "0.320.0"
+version = "0.321.0"
 source = { editable = "." }
 dependencies = [
     { name = "numpy", version = "2.2.6", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.11'" },
diff --git a/sql-to-dbsp-compiler/SQL-compiler/pom.xml b/sql-to-dbsp-compiler/SQL-compiler/pom.xml
index 3925e922dc0..d0856c923bd 100644
--- a/sql-to-dbsp-compiler/SQL-compiler/pom.xml
+++ b/sql-to-dbsp-compiler/SQL-compiler/pom.xml
@@ -19,7 +19,7 @@
         <calcite.version>1.43.0</calcite.version>
         <jackson.version>2.22.0</jackson.version>
         <janino.version>3.1.12</janino.version>
-        <project.version>0.320.0</project.version>
+        <project.version>0.321.0</project.version>
         <avatica.version>1.28.0</avatica.version>
     </properties>
 

From 9e60cdd6746d427a6ffbbe4bdd150edb364ac454 Mon Sep 17 00:00:00 2001
From: Karakatiza666 <bulakh.96@gmail.com>
Date: Fri, 10 Jul 2026 16:10:10 +0000
Subject: [PATCH 2/7] [web-console] Enable loading profiles without a circuit
 profile present

Signed-off-by: Karakatiza666 <bulakh.96@gmail.com>
---
 .devcontainer/Dockerfile                      |   1 +
 js-packages/profiler-app/src/App.svelte       |   8 +-
 .../SupportBundleViewerLayout.svelte          | 143 +++++++++++-------
 .../lib/functions/processZipBundle.test.ts    |  54 ++++++-
 .../src/lib/functions/processZipBundle.ts     |  43 ++++--
 .../components/pipelines/list/Actions.svelte  |   4 +-
 .../lib/functions/pipelines/status.spec.ts    |  12 +-
 .../profile-viewer/+page.svelte               |   8 +-
 8 files changed, 192 insertions(+), 81 deletions(-)

diff --git a/.devcontainer/Dockerfile b/.devcontainer/Dockerfile
index a99f3c0effb..06fd09d9de1 100644
--- a/.devcontainer/Dockerfile
+++ b/.devcontainer/Dockerfile
@@ -84,6 +84,7 @@ RUN curl -fsSL https://claude.ai/install.sh | bash
 
 RUN \
    rustup install $RUST_VERSION && \
+   rustup default $RUST_VERSION && \
    rustup component add rustfmt && \
    rustup component add clippy && \
    cargo install cargo-make
diff --git a/js-packages/profiler-app/src/App.svelte b/js-packages/profiler-app/src/App.svelte
index d59000790d5..960e370f1bc 100644
--- a/js-packages/profiler-app/src/App.svelte
+++ b/js-packages/profiler-app/src/App.svelte
@@ -20,7 +20,7 @@
   let sqlPanelFullHeight = $state(false)
 
   let profileData: {
-    profile: JsonProfiles
+    profile: JsonProfiles | undefined
     dataflow: Dataflow | undefined
     sources: string[] | undefined
     logText: string | undefined
@@ -65,7 +65,7 @@
         const suitableProfiles = getSuitableProfiles(zipData)
         if (suitableProfiles.length === 0) {
           throw new Error(
-            'No suitable profiles found in the uploaded support bundle. Check if it contains the circuit profile and dataflow graph (optional).'
+            'No readable data found in the uploaded support bundle. Check that it contains a circuit profile, config, logs or stats.'
           )
         }
         profileFiles = suitableProfiles
@@ -147,8 +147,8 @@
 
       <div class="bg-surface-50 max-w-md rounded-container p-6 shadow-lg">
         <p class="mb-6 text-sm text-surface-700">
-          Load a Feldera support bundle (.zip file) containing circuit profile data to begin
-          visualization.
+          Load a Feldera support bundle (.zip file) to explore the circuit profile,
+          program code, logs and the pipeline config.
         </p>
 
         {#if isLoading}
diff --git a/js-packages/profiler-layout/src/lib/components/SupportBundleViewerLayout.svelte b/js-packages/profiler-layout/src/lib/components/SupportBundleViewerLayout.svelte
index 96d588c24c5..21b6f7ec623 100644
--- a/js-packages/profiler-layout/src/lib/components/SupportBundleViewerLayout.svelte
+++ b/js-packages/profiler-layout/src/lib/components/SupportBundleViewerLayout.svelte
@@ -39,7 +39,8 @@
   type AnalysisTab = (typeof TABS)[number]
 
   interface Props {
-    profileData: JsonProfiles
+    /** Parsed circuit profile */
+    profileData?: JsonProfiles
     dataflowData: Dataflow | undefined
     programCode: string[] | undefined
     logText?: string
@@ -81,6 +82,12 @@
     onRenderingChange
   }: Props = $props()
 
+  const hasProfile = $derived(profileData !== undefined)
+
+  const graphPaneDefaultSize = 55
+  const graphPaneMinSize = 20
+  const belowGraphPaneDefaultSize = 100 - graphPaneDefaultSize
+
   let profilerDiagram: ProfilerDiagram | undefined = $state()
   // The loaded profile's toplevel node id, so the analysis panel can recognise overview data.
   const diagramRootNodeId = $derived(profilerDiagram?.getProfile()?.rootNodeId)
@@ -137,7 +144,6 @@
       const attrs = data.match({ some: (v) => v, none: () => null })
       untrack(() => {
         if (attrs) {
-          currentTab = 'Metrics'
           tooltipData = { nodeAttributes: attrs }
           // Only cache while we're on a node view, so an `'overview'` round-trip can't
           // overwrite the operator the user actually inspected.
@@ -205,19 +211,18 @@
     profilerDiagram?.selectMetric(selectedMetricId)
   })
 
-  // Show the overview each time a profile loads. `analysisView` is reset first so the
+  // Reset to the overview whenever the loaded bundle changes. `analysisView` is reset first so the
   // SegmentedControl indicator follows the new view, and so the sticky `displayNodeAttributes`
   // that `showGlobalMetrics` triggers sees a non-node view and can't overwrite `lastNodeData`
   // with the overview payload.
   $effect(() => {
     void profileData
     const diagram = profilerDiagram
-    if (!diagram) {
-      return
-    }
     queueMicrotask(() => {
       analysisView = 'overview'
-      diagram.showGlobalMetrics(true)
+      tooltipData = null
+      lastNodeData = null
+      diagram?.showGlobalMetrics(true)
     })
   })
 
@@ -316,42 +321,54 @@
 
 <!-- ── Graph panel (dataflow graph) ────────────────────────────────────────── -->
 {#snippet graphPanel()}
-  <div class="flex h-full flex-col overflow-hidden rounded-container bg-surface-50-950">
+  <div
+    class="flex flex-col overflow-hidden rounded-container bg-surface-50-950 {hasProfile
+      ? 'h-full'
+      : ''}"
+  >
     <!-- Header -->
     <div class="flex flex-shrink-0 flex-wrap items-center gap-2 p-4">
       {@render loadProfileControl?.()}
       <ProfileTimestampSelector {profileFiles} {selectedTimestamp} {onSelectTimestamp} />
-      <div class="ml-auto">
-        <input
-          bind:value={nodeSearchQuery}
-          type="text"
-          placeholder="Search node"
-          title="Search for a node by ID or persistent ID"
-          onkeydown={(e) => e.key === 'Enter' && handleSearch()}
-          class="input h-6 w-36 text-sm"
-        />
-      </div>
+      {#if hasProfile}
+        <div class="ml-auto">
+          <input
+            bind:value={nodeSearchQuery}
+            type="text"
+            placeholder="Search node"
+            title="Search for a node by ID or persistent ID"
+            onkeydown={(e) => e.key === 'Enter' && handleSearch()}
+            class="input h-6 w-36 text-sm"
+          />
+        </div>
+      {:else}
+        <p class="text-sm text-surface-600-400">
+          This bundle has no circuit profile, so the dataflow graph is unavailable.
+        </p>
+      {/if}
     </div>
     <!-- Diagram slot. The actual <ProfilerDiagram> is rendered once outside the layout-
          toggle as a <PersistentContent> overlay so it survives the sqlPanelFullHeight
          layout toggle without re-initialising the Visualizer. The `use:` action mirrors
          this div's bounding rect onto the shared handle. -->
-    <div use:diagramRect.placeholder class="relative min-h-0 flex-1 bg-white-dark">
-      {#if error}
-        <div
-          class="absolute inset-x-4 top-4 z-10 rounded border border-red-300 bg-white p-3 font-mono text-sm text-red-600 shadow"
-        >
-          {error}
-        </div>
-      {/if}
-      {#if message}
-        <div
-          class="absolute left-2 top-2 z-10 rounded bg-white/90 px-2 py-1 font-mono text-sm shadow"
-        >
-          {message}
-        </div>
-      {/if}
-    </div>
+    {#if hasProfile}
+      <div use:diagramRect.placeholder class="relative min-h-0 flex-1 bg-white-dark">
+        {#if error}
+          <div
+            class="absolute inset-x-4 top-4 z-10 rounded border border-red-300 bg-white p-3 font-mono text-sm text-red-600 shadow"
+          >
+            {error}
+          </div>
+        {/if}
+        {#if message}
+          <div
+            class="absolute left-2 top-2 z-10 rounded bg-white/90 px-2 py-1 font-mono text-sm shadow"
+          >
+            {message}
+          </div>
+        {/if}
+      </div>
+    {/if}
   </div>
 {/snippet}
 
@@ -446,7 +463,7 @@
     items={[
       { value: 'overview', label: 'Overview' },
       { value: 'node', label: 'Node', disabled: !lastNodeData },
-      { value: 'top-nodes', label: 'Top nodes' }
+      { value: 'top-nodes', label: 'Top nodes', disabled: !hasProfile }
     ]}
     class="px-2"
   />
@@ -491,11 +508,17 @@
 <!-- ══ Layout: normal (graph top, SQL + tabs bottom) ══════════════════════ -->
 {#if !sqlPanelFullHeight}
   <PaneGroup direction="vertical" class="!overflow-visible h-full">
-    <Pane defaultSize={55} minSize={20} class="!overflow-visible">
-      {@render graphPanel()}
-    </Pane>
-    <PaneResizer class="pane-divider-horizontal my-2" />
-    <Pane defaultSize={45} minSize={15} class="!overflow-visible">
+    {#if hasProfile}
+      <Pane defaultSize={graphPaneDefaultSize} minSize={graphPaneMinSize} class="!overflow-visible">
+        {@render graphPanel()}
+      </Pane>
+      <PaneResizer class="pane-divider-horizontal my-2" />
+    {:else}
+      <div class="mb-4">
+        {@render graphPanel()}
+      </div>
+    {/if}
+    <Pane defaultSize={belowGraphPaneDefaultSize} minSize={15} class="!overflow-visible">
       <PaneGroup direction="horizontal" class="!overflow-visible h-full">
         <Pane defaultSize={50} minSize={0} class="!overflow-visible">
           <div use:sqlPanelRect.placeholder class="h-full"></div>
@@ -516,11 +539,21 @@
     <PaneResizer class="pane-divider-vertical mx-1.5" />
     <Pane minSize={20} class="!overflow-visible">
       <PaneGroup direction="vertical" class="!overflow-visible h-full">
-        <Pane defaultSize={55} minSize={20} class="!overflow-visible">
-          {@render graphPanel()}
-        </Pane>
-        <PaneResizer class="pane-divider-horizontal my-2" />
-        <Pane defaultSize={45} minSize={15} class="!overflow-visible">
+        {#if hasProfile}
+          <Pane
+            defaultSize={graphPaneDefaultSize}
+            minSize={graphPaneMinSize}
+            class="!overflow-visible"
+          >
+            {@render graphPanel()}
+          </Pane>
+          <PaneResizer class="pane-divider-horizontal my-2" />
+        {:else}
+          <div class="mb-4">
+            {@render graphPanel()}
+          </div>
+        {/if}
+        <Pane defaultSize={belowGraphPaneDefaultSize} minSize={15} class="!overflow-visible">
           {@render analysisPanel()}
         </Pane>
       </PaneGroup>
@@ -532,15 +565,17 @@
      <PersistentPlaceholder> in graphPanel. Surviving the layout toggle (and any other
      conditional re-render of graphPanel) is what keeps the Visualizer's internal state intact
      instead of being torn down and re-created from `profileData` each time. -->
-<PersistentContent persistent={diagramRect} class="overflow-hidden bg-white-dark">
-  <ProfilerDiagram
-    bind:this={profilerDiagram}
-    {profileData}
-    {dataflowData}
-    {programCode}
-    {callbacks}
-  />
-</PersistentContent>
+{#if profileData}
+  <PersistentContent persistent={diagramRect} class="overflow-hidden bg-white-dark">
+    <ProfilerDiagram
+      bind:this={profilerDiagram}
+      {profileData}
+      {dataflowData}
+      {programCode}
+      {callbacks}
+    />
+  </PersistentContent>
+{/if}
 
 <!-- Persistent SQL panel overlay. Hoisted out of the layout branches for the same reason as the
      diagram: rendered once, it mirrors the placeholder in whichever {#if} branch is active, so the
diff --git a/js-packages/profiler-layout/src/lib/functions/processZipBundle.test.ts b/js-packages/profiler-layout/src/lib/functions/processZipBundle.test.ts
index f9cad849f7c..563472880fa 100644
--- a/js-packages/profiler-layout/src/lib/functions/processZipBundle.test.ts
+++ b/js-packages/profiler-layout/src/lib/functions/processZipBundle.test.ts
@@ -1,6 +1,6 @@
 import type { ZipItem } from 'but-unzip'
 import { describe, expect, it } from 'vitest'
-import { processProfileFiles } from './processZipBundle.js'
+import { processProfileFiles, selectProfiles } from './processZipBundle.js'
 
 /** Build a ZipItem whose `read()` returns the UTF-8 bytes of `text`. */
 function file(filename: string, text: string): ZipItem {
@@ -9,19 +9,61 @@ function file(filename: string, text: string): ZipItem {
 
 const TIMESTAMP = '2026-05-25T12-34-56.789Z'
 
-/** A minimal circuit profile; `processProfileFiles` requires this file to exist. */
-function circuitProfile(): ZipItem {
-  return file(`${TIMESTAMP}/circuit_profile.json`, JSON.stringify({ nodes: [] }))
+/** A minimal circuit profile. */
+function circuitProfile(dir = TIMESTAMP): ZipItem {
+  return file(`${dir}/circuit_profile.json`, JSON.stringify({ nodes: [] }))
 }
 
 /** A `pipeline_config.json` with the given extra top-level fields alongside `program_code`. */
-function pipelineConfig(extra: Record<string, unknown>): ZipItem {
+function pipelineConfig(extra: Record<string, unknown>, dir = TIMESTAMP): ZipItem {
   return file(
-    `${TIMESTAMP}/pipeline_config.json`,
+    `${dir}/pipeline_config.json`,
     JSON.stringify({ program_code: 'SELECT 1;', name: 'p', ...extra })
   )
 }
 
+function logs(dir = TIMESTAMP): ZipItem {
+  return file(`${dir}/logs.txt`, 'starting up\n')
+}
+
+describe('selectProfiles', () => {
+  it('keeps a collection that has no circuit profile but does have other files', () => {
+    // Regression: the old filter required a circuit_profile.json, so a config/logs-only bundle
+    // was dropped and refused to open.
+    const collections = selectProfiles([pipelineConfig({}), logs()])
+    expect(collections).toHaveLength(1)
+    expect(collections[0][1]).toHaveLength(2)
+  })
+
+  it('drops files that carry no recognised content', () => {
+    const collections = selectProfiles([
+      file(`${TIMESTAMP}/unknown.bin`, 'x'),
+      file('README.txt', 'not in a collection dir')
+    ])
+    expect(collections).toEqual([])
+  })
+
+  it('sorts multiple collections oldest-first', () => {
+    const older = '2026-05-25T12-00-00.000Z'
+    const newer = '2026-05-25T13-00-00.000Z'
+    const collections = selectProfiles([circuitProfile(newer), logs(older)])
+    expect(collections.map(([d]) => d.getTime())).toEqual([
+      new Date('2026-05-25T12:00:00.000Z').getTime(),
+      new Date('2026-05-25T13:00:00.000Z').getTime()
+    ])
+  })
+})
+
+describe('processProfileFiles without a circuit profile', () => {
+  it('leaves profile undefined while still extracting config and logs', async () => {
+    const result = await processProfileFiles([pipelineConfig({}), logs()])
+    expect(result.profile).toBeUndefined()
+    expect(result.sources).toEqual(['SELECT 1;'])
+    expect(result.pipelineName).toBe('p')
+    expect(result.logText).toBe('starting up\n')
+  })
+})
+
 describe('processProfileFiles runtimeConfig', () => {
   it('extracts runtime_config from pipeline_config.json', async () => {
     const runtime_config = { workers: 8, storage: { backend: { name: 'default' } } }
diff --git a/js-packages/profiler-layout/src/lib/functions/processZipBundle.ts b/js-packages/profiler-layout/src/lib/functions/processZipBundle.ts
index ac5999b7b0a..dfdecc2acd0 100644
--- a/js-packages/profiler-layout/src/lib/functions/processZipBundle.ts
+++ b/js-packages/profiler-layout/src/lib/functions/processZipBundle.ts
@@ -10,6 +10,16 @@ const pipelineConfigRegex = /pipeline_config\.json$/
 const logsRegex = /logs\.txt$/
 const statsRegex = /stats\.json$/
 
+// Any of these files makes a collection worth opening. A bundle missing the circuit profile
+// still carries program code, config, logs and stats, all of which the viewer can display.
+const usefulFileRegexes = [
+  circuitProfileRegex,
+  dataflowGraphRegex,
+  pipelineConfigRegex,
+  logsRegex,
+  statsRegex
+]
+
 // New bundle layout (since support-bundle metadata_version 1): each collection
 // lives under a directory named after its timestamp, e.g.
 // "2026-05-25T12-34-56.789Z/circuit_profile.json". Collisions get a "-N" suffix
@@ -42,7 +52,8 @@ function collectionDate(key: string): Date {
 }
 
 export interface ProcessedProfile {
-  profile: JsonProfiles
+  /** Parsed `circuit_profile.json` */
+  profile?: JsonProfiles
   dataflow?: Dataflow
   sources?: string[]
   logText?: string
@@ -55,8 +66,10 @@ export interface ProcessedProfile {
 }
 
 /**
- * Unzip a bundle and extract all suitable profiles with their files.
+ * Unzip a bundle and extract every readable profile with its files.
  * This function only unzips once - store the result for efficient timestamp switching.
+ * A profile is readable when it holds any recognised file (circuit profile, dataflow graph,
+ * pipeline config, logs or stats).
  * @param zipData Raw zip file data
  * @returns Array of [timestamp, files] tuples sorted by timestamp (oldest first)
  * @throws Error if the zip is invalid
@@ -70,14 +83,23 @@ export function getSuitableProfiles(zipData: Uint8Array): [Date, ZipItem[]][] {
       `Failed to unzip bundle: ${error instanceof Error ? error.message : String(error)}`
     )
   }
+  return selectProfiles(profileFiles)
+}
 
-  const profileTimestamps = groupBy(profileFiles, (file) => collectionKey(file.filename)).filter(
-    (group) => group[0] && group[1].some((file) => circuitProfileRegex.test(file.filename))
-    // Pipeline config and dataflow graph are not required
+/**
+ * Group already-unzipped bundle files into readable profiles, sorted oldest-first.
+ * A collection is kept when its timestamp directory holds any recognised file; the circuit
+ * profile is not required.
+ */
+export function selectProfiles(files: ZipItem[]): [Date, ZipItem[]][] {
+  const profiles = groupBy(files, (file) => collectionKey(file.filename)).filter(
+    (group) =>
+      group[0] &&
+      group[1].some((file) => usefulFileRegexes.some((regex) => regex.test(file.filename)))
   )
 
   return sortOn(
-    profileTimestamps.map(([key, files]) => [collectionDate(key), files] as [Date, ZipItem[]]),
+    profiles.map(([key, files]) => [collectionDate(key), files] as [Date, ZipItem[]]),
     (p) => p[0]
   )
 }
@@ -91,9 +113,12 @@ export function getSuitableProfiles(zipData: Uint8Array): [Date, ZipItem[]][] {
 export async function processProfileFiles(files: ZipItem[]): Promise<ProcessedProfile> {
   const decoder = new TextDecoder()
 
-  // Read and parse the three required files
-  const profileFile = files.find((file) => circuitProfileRegex.test(file.filename))!
-  const profile = JSON.parse(decoder.decode(await profileFile.read())) as JsonProfiles
+  // The circuit profile is optional: a bundle without it still yields config, logs and stats.
+  const profileFile = files.find((file) => circuitProfileRegex.test(file.filename))
+  let profile: JsonProfiles | undefined
+  if (profileFile) {
+    profile = JSON.parse(decoder.decode(await profileFile.read())) as JsonProfiles
+  }
 
   const dataflowFile = files.find((file) => dataflowGraphRegex.test(file.filename))
   let dataflow: Dataflow | undefined
diff --git a/js-packages/web-console/src/lib/components/pipelines/list/Actions.svelte b/js-packages/web-console/src/lib/components/pipelines/list/Actions.svelte
index bb3cd817056..05f0ccf1fdd 100644
--- a/js-packages/web-console/src/lib/components/pipelines/list/Actions.svelte
+++ b/js-packages/web-console/src/lib/components/pipelines/list/Actions.svelte
@@ -117,7 +117,9 @@ groups related actions into multi-action dropdowns when multiple options are ava
 
   // An already-deleted pipeline offers no Delete action; otherwise the backend
   // dictates when deletion is possible (fully stopped, storage cleared).
-  const deleteDisabledReason = $derived(deletePipelineDisabledReason(pipeline.current.status, pipeline.current.storageStatus, deleted))
+  const deleteDisabledReason = $derived(
+    deletePipelineDisabledReason(pipeline.current.status, pipeline.current.storageStatus, deleted)
+  )
 
   const actions = {
     _start,
diff --git a/js-packages/web-console/src/lib/functions/pipelines/status.spec.ts b/js-packages/web-console/src/lib/functions/pipelines/status.spec.ts
index b2ac7a138d4..4185532bb56 100644
--- a/js-packages/web-console/src/lib/functions/pipelines/status.spec.ts
+++ b/js-packages/web-console/src/lib/functions/pipelines/status.spec.ts
@@ -21,13 +21,17 @@ describe('deletePipelineDisabledReason', () => {
   })
 
   it('asks to stop the pipeline while it is still running', () => {
-    expect(deletePipelineDisabledReason('Running', 'Cleared', false)).toBe('Stop the pipeline to delete it.')
+    expect(deletePipelineDisabledReason('Running', 'Cleared', false)).toBe(
+      'Stop the pipeline to delete it.'
+    )
   })
 
   // Stop takes priority: a running pipeline always holds its storage, so naming
   // storage first would send the user down a step they cannot take yet.
   it('asks to stop first even when storage is still in use', () => {
-    expect(deletePipelineDisabledReason('Running', 'InUse', false)).toBe('Stop the pipeline to delete it.')
+    expect(deletePipelineDisabledReason('Running', 'InUse', false)).toBe(
+      'Stop the pipeline to delete it.'
+    )
   })
 
   it('asks to clear storage when stopped but storage is in use', () => {
@@ -61,7 +65,9 @@ describe('deletePipelineDisabledReason', () => {
     const anyStorage: StorageStatus[] = ['Cleared', 'InUse', 'Clearing']
     for (const status of transitional) {
       for (const storage of anyStorage) {
-        expect(deletePipelineDisabledReason(status, storage, false)).toBe('Stop the pipeline to delete it.')
+        expect(deletePipelineDisabledReason(status, storage, false)).toBe(
+          'Stop the pipeline to delete it.'
+        )
       }
     }
   })
diff --git a/js-packages/web-console/src/routes/(system)/(authenticated)/profile-viewer/+page.svelte b/js-packages/web-console/src/routes/(system)/(authenticated)/profile-viewer/+page.svelte
index 103e7aeb117..26b2729c6d4 100644
--- a/js-packages/web-console/src/routes/(system)/(authenticated)/profile-viewer/+page.svelte
+++ b/js-packages/web-console/src/routes/(system)/(authenticated)/profile-viewer/+page.svelte
@@ -45,7 +45,7 @@
   let selectedProfile: Date | null = $state(null)
   let getProfileData:
     | (() => {
-        profile: JsonProfiles
+        profile: JsonProfiles | undefined
         dataflow: Dataflow | undefined
         sources: string[] | undefined
         logText: string | undefined
@@ -126,7 +126,7 @@
         const buffer = await receiveUploadedBundle(channel)
         await processZipBundle(
           new Uint8Array(buffer),
-          'No suitable profiles found in the uploaded bundle.'
+          'No readable data found in the uploaded bundle.'
         )
       } else {
         downloadProgress.onProgress(0, 1)
@@ -144,7 +144,7 @@
         const supportBundle = await dataPromise
         await processZipBundle(
           new Uint8Array(await supportBundle.data.arrayBuffer()),
-          'No suitable profiles found. Try enabling "Collect new data".'
+          'No readable data found. Try enabling "Collect new data".'
         )
       }
     }, onLoadError('Failed to load the profile bundle.'))
@@ -169,7 +169,7 @@
       const bundle = await dataPromise
       await processZipBundle(
         new Uint8Array(await bundle.data.arrayBuffer()),
-        'No suitable profiles found. Try enabling "Collect new data".'
+        'No readable data found. Try enabling "Collect new data".'
       )
     }, onLoadError('Failed to download the profile bundle.'))
   }

From c063b200b50213bdb6d5ec43d800bbd4d86f6aac Mon Sep 17 00:00:00 2001
From: Karakatiza666 <bulakh.96@gmail.com>
Date: Thu, 9 Jul 2026 12:14:54 +0000
Subject: [PATCH 3/7] [docs][pipeline-manager] Clean up crawler/SEO issues
 flagged by Google Search Console
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

  Docs (docs.feldera.com):
  - Set `trailingSlash: true` to match the host, which serves canonical
    pages with a trailing slash - this avoids unnecessary redirects for
    links, canonical tags and sitemap entries, generated by Docusaurus.
  - Sitemap: emit `lastmod` (the only freshness signal search engines
    honor) and drop utility routes and the raw OpenAPI spec from it.
  - Add `static/robots.txt` (allow all + sitemap pointer).
  - Fix internal doc links to use explicit `.md`/`.mdx` targets so they
    resolve to the canonical URL instead of a redirect hop.
  - De-slash blog/paper links (what-is-feldera, literature/papers x2,
    fraud_detection) to drop the 308 hop to the canonical no-slash URL.
  - Add three client-redirects for real 404s (eks/ingress, k3d, kafka/
    debezium) so old indexed URLs land on live pages.
  - Mark the sandbox "Run in sandbox" link `nofollow`: it deep-links to
    `try.feldera.com/create?code=...`, and following it floods Search
    Console with duplicate/redirect entries for un-indexable app URLs.
  - Remove the unused markdown-page.md example stub.

  Pipeline-manager:
  - Serve `GET /robots.txt` with a blanket `Disallow: /`. The web console
    is a client-side SPA, so per-page robots hints never reach crawlers; a
    root disallow is the only reliable way to keep app URLs (the sandbox's
    `/create?...` deep-links) out of search indexes. Covers every
    deployment, which is the desired default. Regression test included.
  - Exclude the test-only `POST /pipelines/{name}/testing` endpoint from
    the public OpenAPI spec (dropped from `paths()`, route kept for the
    test harness); regenerate openapi.json. Stops docs from publishing —
    and Google from indexing — a URL that was never a supported API.

Signed-off-by: Karakatiza666 <bulakh.96@gmail.com>
---
 .../src/api/endpoints/pipeline_management.rs  | 24 +------
 crates/pipeline-manager/src/api/main.rs       | 34 +++++++++-
 .../docs/connectors/sinks/confluent-jdbc.md   |  2 +-
 .../docs/connectors/sinks/snowflake.md        |  2 +-
 .../docs/connectors/sources/debezium.md       |  2 +-
 .../docs/connectors/sources/kafka.md          |  2 +-
 .../enterprise/helm-chart-reference.md        | 10 +--
 .../docs/get-started/enterprise/helm-guide.md |  2 +-
 docs.feldera.com/docs/literature/papers.md    |  4 +-
 docs.feldera.com/docs/operations/guide.md     |  2 +-
 docs.feldera.com/docs/sql/grammar.md          |  2 +-
 docs.feldera.com/docs/sql/recursion.mdx       |  2 +-
 .../docs/tutorials/basics/part4.md            |  2 +-
 .../docs/use_cases/batch/part3.md             |  2 +-
 .../fine_grained_authorization/static.md      |  2 +-
 .../fraud_detection/fraud_detection.md        |  2 +-
 docs.feldera.com/docs/what-is-feldera.md      |  2 +-
 docs.feldera.com/docusaurus.config.ts         | 24 +++++++
 docs.feldera.com/src/pages/markdown-page.md   |  7 --
 .../theme/CodeBlock/SandboxButton/index.tsx   |  2 +-
 docs.feldera.com/static/robots.txt            |  4 ++
 openapi.json                                  | 67 -------------------
 22 files changed, 85 insertions(+), 117 deletions(-)
 delete mode 100644 docs.feldera.com/src/pages/markdown-page.md
 create mode 100644 docs.feldera.com/static/robots.txt

diff --git a/crates/pipeline-manager/src/api/endpoints/pipeline_management.rs b/crates/pipeline-manager/src/api/endpoints/pipeline_management.rs
index 58ca1a34b09..ee66d6bf2a9 100644
--- a/crates/pipeline-manager/src/api/endpoints/pipeline_management.rs
+++ b/crates/pipeline-manager/src/api/endpoints/pipeline_management.rs
@@ -1775,27 +1775,9 @@ pub struct PostPipelineTesting {
 ///
 /// This endpoint is used as part of the test harness. Only available if the `testing`
 /// unstable feature is enabled. Do not use in production.
-#[utoipa::path(
-    context_path = "/v0",
-    security(("JSON web token (JWT) or API key" = [])),
-    params(
-        ("pipeline_name" = String, Path, description = "Unique pipeline name"),
-        PostPipelineTesting,
-    ),
-    responses(
-        (status = OK
-            , description = "Request successfully processed"),
-        (status = NOT_FOUND
-            , description = "Pipeline with that name does not exist"
-            , body = ErrorResponse
-            , example = json!(examples::error_unknown_pipeline_name())),
-        (status = METHOD_NOT_ALLOWED
-            , description = "Endpoint is disabled. Set FELDERA_UNSTABLE_FEATURES=\"testing\" to enable."
-            , body = ErrorResponse
-        )
-    ),
-    tag = "Metrics & Debugging"
-)]
+///
+/// Deliberately excluded from the public OpenAPI spec (not in `ApiDoc`'s `paths()`): it is a
+/// test-only hook, not a supported API. The route stays registered so the test harness can call it.
 #[post("/pipelines/{pipeline_name}/testing")]
 pub(crate) async fn post_pipeline_testing(
     state: WebData<ServerState>,
diff --git a/crates/pipeline-manager/src/api/main.rs b/crates/pipeline-manager/src/api/main.rs
index e7f26ed1509..4121329c5c4 100644
--- a/crates/pipeline-manager/src/api/main.rs
+++ b/crates/pipeline-manager/src/api/main.rs
@@ -189,7 +189,6 @@ It contains the following fields:
         endpoints::pipeline_management::post_pipeline,
         endpoints::pipeline_management::put_pipeline,
         endpoints::pipeline_management::patch_pipeline,
-        endpoints::pipeline_management::post_pipeline_testing,
         endpoints::pipeline_management::post_update_runtime,
         endpoints::pipeline_management::delete_pipeline,
         endpoints::pipeline_management::post_pipeline_start,
@@ -639,6 +638,7 @@ fn public_scope(api_config: &ApiServerConfig) -> Scope {
         )
         .service(SwaggerUi::new("/swagger-ui/{_:.*}").url("/api-doc/openapi.json", openapi))
         .service(healthz)
+        .service(robots_txt)
         .service(
             web::scope("")
                 .wrap(middleware::from_fn(add_cache_headers))
@@ -1036,6 +1036,16 @@ async fn healthz(state: WebData<ServerState>) -> Result<HttpResponse, ManagerErr
     Ok(probe.as_http_response())
 }
 
+/// Disallow all crawlers instance-wide. The web-console is a client-side SPA, so per-page robots
+/// hints never reach crawlers; a root disallow is the only reliable way to keep app URLs (e.g.
+/// the sandbox's `/create?...` deep-links) out of search indexes.
+#[get("/robots.txt")]
+async fn robots_txt() -> HttpResponse {
+    HttpResponse::Ok()
+        .content_type("text/plain; charset=utf-8")
+        .body("User-agent: *\nDisallow: /\n")
+}
+
 #[cfg(test)]
 mod tests {
     //! Tests covering the static-asset caching middleware and the CORS surface
@@ -1102,6 +1112,28 @@ mod tests {
         assert!(res.headers().get(header::EXPIRES).is_none());
     }
 
+    /// `/robots.txt` must be answered by the backend with a blanket crawler
+    /// disallow, not fall through to the SPA catch-all. Drives the production
+    /// App from `build_app`. Without the explicit `robots_txt` route this path
+    /// resolves to the web-console bundle (index.html in production, a 404 in
+    /// the bundle-less test build) and crawlers get no valid robots rules — so
+    /// they index the sandbox's generated `/create?...` deep-links. Removing
+    /// the `.service(robots_txt)` wiring flips the status to 404 and fails here.
+    #[actix_web::test]
+    async fn robots_txt_disallows_all_crawlers() {
+        let cfg = ApiServerConfig::test_config();
+        let app = test::init_service(build_app(&cfg, &None)).await;
+        let req = test::TestRequest::get().uri("/robots.txt").to_request();
+        let res = test::call_service(&app, req).await;
+        assert_eq!(res.status(), StatusCode::OK);
+        assert_eq!(
+            res.headers().get(header::CONTENT_TYPE).unwrap(),
+            "text/plain; charset=utf-8",
+        );
+        let body = test::read_body(res).await;
+        assert_eq!(&body[..], b"User-agent: *\nDisallow: /\n");
+    }
+
     // -------- CORS surface integration tests --------
     //
     // All integration tests below use `build_app(&cfg, &None)` — the same
diff --git a/docs.feldera.com/docs/connectors/sinks/confluent-jdbc.md b/docs.feldera.com/docs/connectors/sinks/confluent-jdbc.md
index 55031f94cc6..5e7c803e3bd 100644
--- a/docs.feldera.com/docs/connectors/sinks/confluent-jdbc.md
+++ b/docs.feldera.com/docs/connectors/sinks/confluent-jdbc.md
@@ -16,7 +16,7 @@ Avro format expected by this connector.  In this format, the key of the Kafka me
 of the target table. The value component of the message contains the new or updated value for this primary key
 or `null` if the key is to be deleted from the table.
 
-Because this connector uses the [Kafka output connector](kafka), it
+Because this connector uses the [Kafka output connector](kafka.md), it
 supports [fault tolerance](/pipelines/fault-tolerance) too.
 
 Setting up a Confluent JDBC Sink Connector integration involves three steps:
diff --git a/docs.feldera.com/docs/connectors/sinks/snowflake.md b/docs.feldera.com/docs/connectors/sinks/snowflake.md
index 8fd485aba92..80d4bac75bd 100644
--- a/docs.feldera.com/docs/connectors/sinks/snowflake.md
+++ b/docs.feldera.com/docs/connectors/sinks/snowflake.md
@@ -3,7 +3,7 @@
 The Feldera Snowflake connector ingests data change events produced by a Feldera
 pipeline into a Snowflake database in near-realtime.
 
-Because this connector uses the [Kafka output connector](kafka), it
+Because this connector uses the [Kafka output connector](kafka.md), it
 supports [fault tolerance](/pipelines/fault-tolerance) too.
 
 :::caution Experimental feature
diff --git a/docs.feldera.com/docs/connectors/sources/debezium.md b/docs.feldera.com/docs/connectors/sources/debezium.md
index d25eb09e5be..5e7ae507777 100644
--- a/docs.feldera.com/docs/connectors/sources/debezium.md
+++ b/docs.feldera.com/docs/connectors/sources/debezium.md
@@ -130,7 +130,7 @@ Configure an input connector for each Feldera SQL table that must ingest changes
 Use the `kafka_input` transport with either `json` or `avro` format. Debezium automatically
 creates a Kafka topic for each database table.
 
-Because input from Debezium uses the [Kafka input connector](kafka), it
+Because input from Debezium uses the [Kafka input connector](kafka.md), it
 supports [fault tolerance](/pipelines/fault-tolerance) too.
 
 ### JSON
diff --git a/docs.feldera.com/docs/connectors/sources/kafka.md b/docs.feldera.com/docs/connectors/sources/kafka.md
index e9657d18448..875c68088ba 100644
--- a/docs.feldera.com/docs/connectors/sources/kafka.md
+++ b/docs.feldera.com/docs/connectors/sources/kafka.md
@@ -240,7 +240,7 @@ the latter will be overwritten.
 
 The Kafka connector can be used to ingest data from a source via
 Debezium.  For information on how to setup Debezium integration for Feldera, see
-[Debezium connector documentation](debezium).
+[Debezium connector documentation](debezium.md).
 
 ### Connecting to AWS MSK with IAM SASL
 
diff --git a/docs.feldera.com/docs/get-started/enterprise/helm-chart-reference.md b/docs.feldera.com/docs/get-started/enterprise/helm-chart-reference.md
index 68181fda62c..9d4b1b39795 100644
--- a/docs.feldera.com/docs/get-started/enterprise/helm-chart-reference.md
+++ b/docs.feldera.com/docs/get-started/enterprise/helm-chart-reference.md
@@ -1,7 +1,7 @@
 # Helm Chart Reference
 
 This page documents all configurable values for the Feldera Enterprise Helm chart.
-See the [Helm guide](./helm-guide) for installation instructions.
+See the [Helm guide](./helm-guide.md) for installation instructions.
 
 ## Required Values
 
@@ -111,7 +111,7 @@ Controls which Kubernetes secrets can be mounted in connectors via [secret refer
 
 ## Parallel Compilation
 
-Parallel compilation runs multiple compiler server replicas to reduce total compile time. See the [parallel compilation guide](./parallel-compilation) for additional details.
+Parallel compilation runs multiple compiler server replicas to reduce total compile time. See the [parallel compilation guide](./parallel-compilation.md) for additional details.
 
 | Key | Default | Description |
 |-----|---------|-------------|
@@ -137,12 +137,12 @@ When running multiple compiler replicas, sccache allows them to share compiled a
 
 ## Authentication
 
-When `auth.enabled` is `true`, the API server requires OIDC authentication. See the guides for [AWS Cognito](./authentication/aws-cognito), [Okta](./authentication/okta-sso), or [generic OIDC providers](./authentication/generic-oidc).
+When `auth.enabled` is `true`, the API server requires OIDC authentication. See the guides for [AWS Cognito](./authentication/aws-cognito.md), [Okta](./authentication/okta-sso.md), or [generic OIDC providers](./authentication/generic-oidc.md).
 
 | Key | Default | Description |
 |-----|---------|-------------|
 | `auth.enabled` | `false` | Enable authentication for the API server. |
-| `auth.provider` | `"aws-cognito"` | OIDC provider type. Set the appropriate value based on your [supported authentication provider](./authentication) |
+| `auth.provider` | `"aws-cognito"` | OIDC provider type. Set the appropriate value based on your [supported authentication provider](./authentication/index.mdx) |
 | `auth.clientId` | `""` | OIDC application client ID. |
 | `auth.issuer` | `""` | OIDC issuer URL. |
 | `auth.cognitoLoginUrl` | `""` | Cognito hosted UI login URL (Cognito only). |
@@ -292,7 +292,7 @@ annotations:
 
 ## HTTPS / TLS
 
-Configure HTTPS for all Feldera components. See the [HTTPS guide](./https) for certificate generation and setup.
+Configure HTTPS for all Feldera components. See the [HTTPS guide](./https.md) for certificate generation and setup.
 
 | Key | Default | Description |
 |-----|---------|-------------|
diff --git a/docs.feldera.com/docs/get-started/enterprise/helm-guide.md b/docs.feldera.com/docs/get-started/enterprise/helm-guide.md
index b77079fcd57..cf19080f5db 100644
--- a/docs.feldera.com/docs/get-started/enterprise/helm-guide.md
+++ b/docs.feldera.com/docs/get-started/enterprise/helm-guide.md
@@ -126,7 +126,7 @@ The `values.yaml` file can be retrieved for an existing Feldera release or from
 
 Remote Feldera registry: Run `helm show values oci://public.ecr.aws/feldera/feldera-chart --version {version} >> values.yaml` where `version` is the Feldera platform version for which you want to retrieve values.
 
-Existing Feldera release: Run `helm get values {feldera-release-name} --all -o yaml >> values.yaml` where `feldera-release-name` is the name of your release. The value is usually `feldera`, unless the value has been configured during the [installation](./helm-guide#installing-feldera-enterprise) process.
+Existing Feldera release: Run `helm get values {feldera-release-name} --all -o yaml >> values.yaml` where `feldera-release-name` is the name of your release. The value is usually `feldera`, unless the value has been configured during the [installation](#installing-feldera-enterprise) process.
 
 ### Configure custom database credentials
 
diff --git a/docs.feldera.com/docs/literature/papers.md b/docs.feldera.com/docs/literature/papers.md
index 60ca7a31ae2..ded260e34c1 100644
--- a/docs.feldera.com/docs/literature/papers.md
+++ b/docs.feldera.com/docs/literature/papers.md
@@ -4,8 +4,8 @@ The following publications and awards describe Feldera's theoretical foundation,
 
 ## Awards
 
-* :trophy: [DBSP in ACM SIGMOD Research Highlights](https://www.feldera.com/blog/sigmod-research-highlights/)
-* :trophy: [DBSP wins Best Paper award at VLDB 2023 ](https://www.feldera.com/blog/Best-Research-Paper-VLDB-2023/)
+* :trophy: [DBSP in ACM SIGMOD Research Highlights](https://www.feldera.com/blog/sigmod-research-highlights)
+* :trophy: [DBSP wins Best Paper award at VLDB 2023 ](https://www.feldera.com/blog/Best-Research-Paper-VLDB-2023)
 
 ## Publications
 
diff --git a/docs.feldera.com/docs/operations/guide.md b/docs.feldera.com/docs/operations/guide.md
index 89eaa502365..0b15740dce8 100644
--- a/docs.feldera.com/docs/operations/guide.md
+++ b/docs.feldera.com/docs/operations/guide.md
@@ -94,7 +94,7 @@ ALTER TABLE my_table SET TBLPROPERTIES (
 **Error**: `The pipeline container has restarted. This was likely caused by an Out-Of-Memory (OOM) crash.`
 
 Feldera runs each pipeline in a separate container with configurable memory limits.
-See [documentation on the pipeline's memory usage](memory) for a detailed breakdown
+See [documentation on the pipeline's memory usage](memory.md) for a detailed breakdown
 of how memory is used and available control knobs.
 
 ### Out-of-storage Errors
diff --git a/docs.feldera.com/docs/sql/grammar.md b/docs.feldera.com/docs/sql/grammar.md
index 9b36a77a66c..14c57d086c7 100644
--- a/docs.feldera.com/docs/sql/grammar.md
+++ b/docs.feldera.com/docs/sql/grammar.md
@@ -310,7 +310,7 @@ See [Materialized Tables and Views](materialized.md) for more details.
 `DECLARE RECURSIVE VIEW` is used to declare a view that can afterwards
 be used in a recursive SQL query.  The syntax of this statement is
 reminiscent of a table declaration, without constraints.  Recursive
-queries are documented in [this section](recursion).
+queries are documented in [this section](recursion.mdx).
 
 ```
 declareRecursiveViewStatement:
diff --git a/docs.feldera.com/docs/sql/recursion.mdx b/docs.feldera.com/docs/sql/recursion.mdx
index 5e32fb497a9..393033b35a0 100644
--- a/docs.feldera.com/docs/sql/recursion.mdx
+++ b/docs.feldera.com/docs/sql/recursion.mdx
@@ -250,4 +250,4 @@ The following are currently not supported in recursive queries:
 
 ### Known Limitations
 
-- Recursive queries mixed with [streaming annotations](streaming) currently can not leverage garbage collection.
\ No newline at end of file
+- Recursive queries mixed with [streaming annotations](streaming.md) currently can not leverage garbage collection.
\ No newline at end of file
diff --git a/docs.feldera.com/docs/tutorials/basics/part4.md b/docs.feldera.com/docs/tutorials/basics/part4.md
index 6ddffca76de..a691abdc9bc 100644
--- a/docs.feldera.com/docs/tutorials/basics/part4.md
+++ b/docs.feldera.com/docs/tutorials/basics/part4.md
@@ -161,4 +161,4 @@ changes in `PREFERRED_VENDOR` view approximately every second.
 
 To summarize Part 4 of the tutorial, we can attach a random generator to Feldera tables to simulate different scenarios
 such as backfill, continuous evaluation or a combination of the two.
-You'll find a complete datagen reference in the [connectors section](../../connectors/sources/datagen).
+You'll find a complete datagen reference in the [connectors section](../../connectors/sources/datagen.md).
diff --git a/docs.feldera.com/docs/use_cases/batch/part3.md b/docs.feldera.com/docs/use_cases/batch/part3.md
index 1049bc14c2c..59c0ca1030c 100644
--- a/docs.feldera.com/docs/use_cases/batch/part3.md
+++ b/docs.feldera.com/docs/use_cases/batch/part3.md
@@ -7,7 +7,7 @@ accumulated in the source database over an extended period (months or years)
 before processing new real-time inputs. This process is known as **backfill**.
 
 In some cases, both historical and real-time data can be ingested from the same
-data source. For example, in [Part 2](part2) of this tutorial, we configured the
+data source. For example, in [Part 2](part2.md) of this tutorial, we configured the
 Delta Lake connector to read the current snapshot of the table before following
 new updates in the table's transaction log.
 
diff --git a/docs.feldera.com/docs/use_cases/fine_grained_authorization/static.md b/docs.feldera.com/docs/use_cases/fine_grained_authorization/static.md
index a5bbf401101..34a85cb430f 100644
--- a/docs.feldera.com/docs/use_cases/fine_grained_authorization/static.md
+++ b/docs.feldera.com/docs/use_cases/fine_grained_authorization/static.md
@@ -282,7 +282,7 @@ where not users.is_banned;
 ```
 </details>
 
-Start the pipeline and populate the object graph to match the [example](intro#object-graph) by issuing the following
+Start the pipeline and populate the object graph to match the [example](intro.md#object-graph) by issuing the following
 ad hoc queries:
 
 ```sql
diff --git a/docs.feldera.com/docs/use_cases/fraud_detection/fraud_detection.md b/docs.feldera.com/docs/use_cases/fraud_detection/fraud_detection.md
index d0fbf791bb2..30e77c82c01 100644
--- a/docs.feldera.com/docs/use_cases/fraud_detection/fraud_detection.md
+++ b/docs.feldera.com/docs/use_cases/fraud_detection/fraud_detection.md
@@ -483,4 +483,4 @@ input.
 ## Resources
 
 A version of this use case focusing on integration with the Delta Lake and Spark ecosystem
-is published as a [blog post](https://www.feldera.com/blog/feature-engineering-part2/).
+is published as a [blog post](https://www.feldera.com/blog/feature-engineering-part2).
diff --git a/docs.feldera.com/docs/what-is-feldera.md b/docs.feldera.com/docs/what-is-feldera.md
index 17b23388f74..a8402436819 100644
--- a/docs.feldera.com/docs/what-is-feldera.md
+++ b/docs.feldera.com/docs/what-is-feldera.md
@@ -18,7 +18,7 @@ Our defining features:
 
 3. **Datasets larger than RAM**. Feldera is designed to handle datasets that exceed the available RAM by spilling efficiently to disk, taking advantage of recent advances in NVMe storage.
 
-4. **Strong guarantees on consistency and freshness**. Feldera is strongly consistent: it [guarantees](https://www.feldera.com/blog/synchronous-streaming/) that the state of the views always corresponds to what you'd get if you ran the queries in a batch system for the same input.
+4. **Strong guarantees on consistency and freshness**. Feldera is strongly consistent: it [guarantees](https://www.feldera.com/blog/synchronous-streaming) that the state of the views always corresponds to what you'd get if you ran the queries in a batch system for the same input.
 
 5. **Connectors for your favorite data sources and destinations**. Feldera connects to myriad batch and streaming data sources, like Kafka, HTTP, CDC streams, S3, Data Lakes, Warehouses and more. If you need a connector that we don't yet support, [let us know](https://github.com/feldera/feldera/issues/new/choose).
 
diff --git a/docs.feldera.com/docusaurus.config.ts b/docs.feldera.com/docusaurus.config.ts
index 56b5a9a15cc..aef1ca3b012 100644
--- a/docs.feldera.com/docusaurus.config.ts
+++ b/docs.feldera.com/docusaurus.config.ts
@@ -15,6 +15,11 @@ const config: Config = {
   // For GitHub pages deployment, it is often '/<projectName>/'
   baseUrl: "/",
 
+  // The static host serves canonical pages with a trailing slash and 301s the
+  // non-slash form to it. Match that so generated links, canonical tags, and
+  // sitemap entries point at the served URL instead of a redirect.
+  trailingSlash: true,
+
   // GitHub pages deployment config.
   // If you aren't using GitHub pages, you don't need these.
   organizationName: "feldera", // Usually your GitHub org/user name.
@@ -54,6 +59,13 @@ const config: Config = {
         theme: {
           customCss: "./src/css/custom.css",
         },
+        sitemap: {
+          // Emit a real freshness signal; changefreq/priority are ignored by
+          // search engines, but lastmod is honored.
+          lastmod: "date",
+          // Keep utility routes and the raw OpenAPI spec out of the sitemap.
+          ignorePatterns: ["/search", "/**/openapi.json/**", "/**/openapi.json"],
+        },
       } satisfies PresetOpenapi.Options,
     ],
     [
@@ -262,6 +274,18 @@ const config: Config = {
             from: "/api/retrieve-the-status-of-an-output-connector",
             to: "/api/get-output-status",
           },
+          {
+            from: "/get-started/enterprise/kubernetes-guides/eks/ingress",
+            to: "/get-started/enterprise/kubernetes-guides/eks/envoy-gateway",
+          },
+          {
+            from: "/enterprise/kubernetes-guides/k3d",
+            to: "/get-started/enterprise/kubernetes-guides/k3d",
+          },
+          {
+            from: "/connectors/sources/kafka/debezium",
+            to: "/connectors/sources/debezium",
+          },
         ],
       },
     ],
diff --git a/docs.feldera.com/src/pages/markdown-page.md b/docs.feldera.com/src/pages/markdown-page.md
deleted file mode 100644
index 9756c5b6685..00000000000
--- a/docs.feldera.com/src/pages/markdown-page.md
+++ /dev/null
@@ -1,7 +0,0 @@
----
-title: Markdown page example
----
-
-# Markdown page example
-
-You don't need React to write simple standalone pages.
diff --git a/docs.feldera.com/src/theme/CodeBlock/SandboxButton/index.tsx b/docs.feldera.com/src/theme/CodeBlock/SandboxButton/index.tsx
index 6a3ff77243f..dc1ce916b76 100644
--- a/docs.feldera.com/src/theme/CodeBlock/SandboxButton/index.tsx
+++ b/docs.feldera.com/src/theme/CodeBlock/SandboxButton/index.tsx
@@ -21,7 +21,7 @@ console.log('styles', styles)
       <a
         href={href}
         target="_blank"
-        rel="noopener noreferrer"
+        rel="noopener noreferrer nofollow"
         aria-label={translate({
           id: 'theme.CodeBlock.SandboxButtonAriaLabel',
           message: 'Run code in the Feldera Online Sandbox',
diff --git a/docs.feldera.com/static/robots.txt b/docs.feldera.com/static/robots.txt
new file mode 100644
index 00000000000..076d124be30
--- /dev/null
+++ b/docs.feldera.com/static/robots.txt
@@ -0,0 +1,4 @@
+User-agent: *
+Allow: /
+
+Sitemap: https://docs.feldera.com/sitemap.xml
diff --git a/openapi.json b/openapi.json
index 551d45762bb..d056cd59b89 100644
--- a/openapi.json
+++ b/openapi.json
@@ -6390,73 +6390,6 @@
         ]
       }
     },
-    "/v0/pipelines/{pipeline_name}/testing": {
-      "post": {
-        "tags": [
-          "Metrics & Debugging"
-        ],
-        "summary": "Test Endpoint",
-        "description": "This endpoint is used as part of the test harness. Only available if the `testing`\nunstable feature is enabled. Do not use in production.",
-        "operationId": "post_pipeline_testing",
-        "parameters": [
-          {
-            "name": "pipeline_name",
-            "in": "path",
-            "description": "Unique pipeline name",
-            "required": true,
-            "schema": {
-              "type": "string"
-            }
-          },
-          {
-            "name": "set_platform_version",
-            "in": "query",
-            "required": false,
-            "schema": {
-              "type": "string",
-              "nullable": true
-            }
-          }
-        ],
-        "responses": {
-          "200": {
-            "description": "Request successfully processed"
-          },
-          "404": {
-            "description": "Pipeline with that name does not exist",
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/ErrorResponse"
-                },
-                "example": {
-                  "message": "Unknown pipeline name 'non-existent-pipeline'",
-                  "error_code": "UnknownPipelineName",
-                  "details": {
-                    "pipeline_name": "non-existent-pipeline"
-                  }
-                }
-              }
-            }
-          },
-          "405": {
-            "description": "Endpoint is disabled. Set FELDERA_UNSTABLE_FEATURES=\"testing\" to enable.",
-            "content": {
-              "application/json": {
-                "schema": {
-                  "$ref": "#/components/schemas/ErrorResponse"
-                }
-              }
-            }
-          }
-        },
-        "security": [
-          {
-            "JSON web token (JWT) or API key": []
-          }
-        ]
-      }
-    },
     "/v0/pipelines/{pipeline_name}/time_series": {
       "get": {
         "tags": [

From dbdb924c8f6a37d9ef40233306cfdc9b74eb64e4 Mon Sep 17 00:00:00 2001
From: Karakatiza666 <bulakh.96@gmail.com>
Date: Thu, 9 Jul 2026 13:04:39 +0000
Subject: [PATCH 4/7] [ci] blacklist slack invite URLs from the link checker
 because they only work for browsers

Signed-off-by: Karakatiza666 <bulakh.96@gmail.com>
---
 .github/workflows/docs-linkcheck.yml | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/.github/workflows/docs-linkcheck.yml b/.github/workflows/docs-linkcheck.yml
index d4159bd94b5..f5212dc1cb1 100644
--- a/.github/workflows/docs-linkcheck.yml
+++ b/.github/workflows/docs-linkcheck.yml
@@ -18,7 +18,9 @@ jobs:
         uses: astral-sh/setup-uv@6dfebec6ddbcd197e02256fbdf54deb334fb7f06 # v2
 
       # ignored crates.io due to https://github.com/rust-lang/crates.io/issues/788
-      - name: Check links on feldera.com
+      # browser-like user-agent avoids WAFs dropping the connection on the
+      # default LinkChecker UA (the classic UNEXPECTED_EOF cause)
+      - name: Check links on docs.feldera.com
         run: |
-          uv run --locked linkchecker https://docs.feldera.com --check-extern --no-warnings --ignore-url "https?://localhost|https://crates.io|https://www.linkedin.com|https://ieeexplore.ieee.org|https://x.com|https?://127.0.0.1" --no-robots
+          uv run --locked linkchecker https://docs.feldera.com --check-extern --no-warnings --ignore-url "https?://localhost|https://crates.io|https://www.linkedin.com|https://ieeexplore.ieee.org|https://x.com|https?://127.0.0.1|https://join.slack.com|https://felderacommunity.slack.com" --no-robots
         working-directory: docs.feldera.com

From 898776ae9c5558d4c1047c78d93db2dae9702eed Mon Sep 17 00:00:00 2001
From: mrswastik-robot <swastikpatel29@gmail.com>
Date: Sat, 11 Jul 2026 18:13:01 +0530
Subject: [PATCH 5/7] [web-console] Improve empty-state and Enter submit for
 tags

Submit the create tag form on Enter, skip the empty search list
when no tags exist, and open create directly in that case.

Fixes #6596
Fixes #6595

Signed-off-by: mrswastik-robot <swastikpatel29@gmail.com>
---
 .../components/pipelines/table/Tags.svelte    | 25 ++++++++++++++-----
 1 file changed, 19 insertions(+), 6 deletions(-)

diff --git a/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte b/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte
index d88f3df6322..8d8ef0c5dd9 100644
--- a/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte
+++ b/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte
@@ -284,6 +284,9 @@
   {#snippet trigger(toggle)}
     {@const open = () => {
       closeForm()
+      if (knownTags.size === 0) {
+        openCreate('')
+      }
       toggle()
     }}
     <div class="flex flex-nowrap items-center gap-1">
@@ -331,9 +334,11 @@
     </div>
 
     {#snippet listPage()}
-      <div class="p-2">
-        <input class="input h-9 w-full" type="search" placeholder="Search" bind:value={search} />
-      </div>
+      {#if knownTags.size > 0}
+        <div class="p-2">
+          <input class="input h-9 w-full" type="search" placeholder="Search" bind:value={search} />
+        </div>
+      {/if}
       <div class="scrollbar flex max-h-[280px] flex-col overflow-y-auto pb-1">
         {#each selectedTags as tag (tag)}
           {@render tagRow(tag, true)}
@@ -470,7 +475,15 @@
       </button>
     {/if}
   </div>
-  <div class="flex flex-col gap-3 px-3 pb-3">
+  <form
+    class="flex flex-col gap-3 px-3 pb-3"
+    onsubmit={(e) => {
+      e.preventDefault()
+      if (!opts.submitDisabled) {
+        opts.onSubmit()
+      }
+    }}
+  >
     <label class="flex flex-col gap-1 text-sm font-medium">
       Tag name
       <input
@@ -509,9 +522,9 @@
       </div>
     </div>
     <button
+      type="submit"
       class="btn h-9! w-full preset-filled-primary-500"
       disabled={opts.submitDisabled}
-      onclick={opts.onSubmit}
     >
       {opts.submitLabel}
     </button>
@@ -520,5 +533,5 @@
         The tag “{newTagName.trim()}” already exists.
       </p>
     {/if}
-  </div>
+  </form>
 {/snippet}

From 81b844df03b5b563e2f8f739644e0d06f75c7884 Mon Sep 17 00:00:00 2001
From: mrswastik-robot <swastikpatel29@gmail.com>
Date: Mon, 13 Jul 2026 23:18:45 +0530
Subject: [PATCH 6/7] [web-console] Add Tags unit tests for Enter, keyboard
 color, empty pool

Signed-off-by: mrswastik-robot <swastikpatel29@gmail.com>
---
 .../pipelines/table/Tags.svelte.spec.ts       | 81 ++++++++++++++++++-
 1 file changed, 77 insertions(+), 4 deletions(-)

diff --git a/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte.spec.ts b/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte.spec.ts
index afe19b14ba4..7391ec20ad2 100644
--- a/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte.spec.ts
+++ b/js-packages/web-console/src/lib/components/pipelines/table/Tags.svelte.spec.ts
@@ -1,5 +1,5 @@
 import { describe, expect, it, vi } from 'vitest'
-import { page } from 'vitest/browser'
+import { page, userEvent } from 'vitest/browser'
 import { render } from 'vitest-browser-svelte'
 import type { PipelineManagerApi } from '$lib/compositions/usePipelineManager.svelte'
 import Tags from './Tags.svelte'
@@ -90,13 +90,30 @@ describe('Tags.svelte', () => {
         tags: ['prod|ef4444']
       })
     })
+
+    it('opens the create form directly when no known tags exist yet', async () => {
+      renderTags({ tags: [], knownTags: [] })
+      await page.getByRole('button', { name: 'Tag' }).click()
+
+      // Empty pool skips the search list and lands on create immediately.
+      await expect.element(page.getByPlaceholder('Tag name')).toBeVisible()
+      await expect.element(page.getByRole('button', { name: 'Create' })).toBeVisible()
+      expect(page.getByPlaceholder('Search').elements()).toHaveLength(0)
+    })
+
+    it('shows search when known tags exist', async () => {
+      renderTags({ tags: [], knownTags: ['dev'] })
+      await page.getByRole('button', { name: 'Tag' }).click()
+
+      await expect.element(page.getByPlaceholder('Search')).toBeVisible()
+    })
   })
 
-  describe('create form validation', () => {
+  describe('create form', () => {
     it('blocks an invalid name and surfaces the reason; a valid name is color-encoded', async () => {
-      const { patchPipeline } = renderTags({ tags: [] })
+      const { patchPipeline } = renderTags({ tags: [], knownTags: [] })
+      // Empty knownTags opens create directly — no "Create a new tag" list click.
       await page.getByRole('button', { name: 'Tag' }).click()
-      await page.getByRole('button', { name: 'Create a new tag' }).click()
 
       const nameInput = page.getByPlaceholder('Tag name')
       const createButton = page.getByRole('button', { name: 'Create' })
@@ -117,5 +134,61 @@ describe('Tags.svelte', () => {
         tags: ['qa|ef4444']
       })
     })
+
+    it('submits the create form when Enter is pressed in the name field', async () => {
+      const { patchPipeline } = renderTags({ tags: [], knownTags: [] })
+      await page.getByRole('button', { name: 'Tag' }).click()
+
+      const nameInput = page.getByPlaceholder('Tag name')
+      await nameInput.fill('qa')
+      // `fill` leaves the input focused; Enter submits the surrounding <form>.
+      await userEvent.keyboard('{Enter}')
+
+      expect(patchPipeline).toHaveBeenCalledWith('test-pipeline', {
+        tags: ['qa|ef4444']
+      })
+    })
+
+    it('does not submit on Enter when the create button is disabled', async () => {
+      const { patchPipeline } = renderTags({ tags: [], knownTags: [] })
+      await page.getByRole('button', { name: 'Tag' }).click()
+
+      const nameInput = page.getByPlaceholder('Tag name')
+      await expect.element(page.getByRole('button', { name: 'Create' })).toBeDisabled()
+      // Focus the empty name field and press Enter — submit must stay a no-op.
+      await nameInput.click()
+      await userEvent.keyboard('{Enter}')
+
+      expect(patchPipeline).not.toHaveBeenCalled()
+    })
+
+    it('selects a color with Tab and Space before submitting', async () => {
+      const { patchPipeline } = renderTags({ tags: [], knownTags: [] })
+      await page.getByRole('button', { name: 'Tag' }).click()
+
+      const nameInput = page.getByPlaceholder('Tag name')
+      await nameInput.fill('qa')
+      // Tab moves from the name field onto the first color swatch (Red), then
+      // Purple; Space activates that focused swatch like a mouse click.
+      await userEvent.keyboard('{Tab}')
+      await userEvent.keyboard('{Tab}')
+      await expect.element(page.getByRole('button', { name: 'Purple' })).toHaveFocus()
+      await userEvent.keyboard(' ')
+
+      await expect
+        .element(page.getByRole('button', { name: 'Purple' }))
+        .toHaveAttribute('aria-pressed', 'true')
+      // Enter on a color swatch only re-activates the button (expected). Shift+Tab
+      // the same number of times returns focus to the name field, then Enter submits.
+      await userEvent.keyboard('{Shift>}{Tab}{/Shift}')
+      await userEvent.keyboard('{Shift>}{Tab}{/Shift}')
+      await expect.element(nameInput).toHaveFocus()
+      await userEvent.keyboard('{Enter}')
+
+      // Purple is #a855f7 in the palette → stored as |a855f7.
+      expect(patchPipeline).toHaveBeenCalledWith('test-pipeline', {
+        tags: ['qa|a855f7']
+      })
+    })
   })
 })

From 69579e5bb03475d57e320f196e5e485a3820e760 Mon Sep 17 00:00:00 2001
From: Swanand Mulay <73115739+swanandx@users.noreply.github.com>
Date: Tue, 30 Jun 2026 19:25:26 +0530
Subject: [PATCH 7/7] [connectors]: read UC-Uniform/Iceberg column-mapped
 tables by field-id

Bump the delta-rs fork to 9a58fbef, which resolves columnMapping.mode=id
columns by Parquet field-id rather than physical name. Without it, reading a
UC-Uniform-over-Iceberg table fails with `col-<id> is missing from the physical
schema`. Add a snapshot-read regression test (fixture + e2e).

Signed-off-by: Swanand Mulay <73115739+swanandx@users.noreply.github.com>
---
 Cargo.lock                                    |  14 +-
 Cargo.toml                                    |  13 +-
 .../platform/fixtures/uniform_iceberg.py      | 217 ++++++++++++++++++
 .../test_delta_input_uniform_iceberg.py       | 139 +++++++++++
 4 files changed, 371 insertions(+), 12 deletions(-)
 create mode 100644 python/tests/platform/fixtures/uniform_iceberg.py
 create mode 100644 python/tests/platform/test_delta_input_uniform_iceberg.py

diff --git a/Cargo.lock b/Cargo.lock
index 7d1a0f0883a..337c2ee257a 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -4305,7 +4305,7 @@ checksum = "26bf8fc351c5ed29b5c2f0cbbac1b209b74f60ecd62e675a998df72c49af5204"
 [[package]]
 name = "deltalake"
 version = "0.32.3"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "buoyant_kernel",
  "ctor 0.10.1",
@@ -4319,7 +4319,7 @@ dependencies = [
 [[package]]
 name = "deltalake-aws"
 version = "0.15.0"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "async-trait",
  "aws-config",
@@ -4345,7 +4345,7 @@ dependencies = [
 [[package]]
 name = "deltalake-azure"
 version = "0.15.0"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "bytes",
  "deltalake-core",
@@ -4358,7 +4358,7 @@ dependencies = [
 [[package]]
 name = "deltalake-catalog-unity"
 version = "0.16.0"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "async-trait",
  "chrono",
@@ -4385,7 +4385,7 @@ dependencies = [
 [[package]]
 name = "deltalake-core"
 version = "0.32.3"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "arrow",
  "arrow-arith",
@@ -4439,7 +4439,7 @@ dependencies = [
 [[package]]
 name = "deltalake-derive"
 version = "1.0.0"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "convert_case 0.9.0",
  "itertools 0.14.0",
@@ -4451,7 +4451,7 @@ dependencies = [
 [[package]]
 name = "deltalake-gcp"
 version = "0.16.0"
-source = "git+https://github.com/feldera/delta-rs.git?rev=5b35c0988b07ab921d5eee5b8da8da55e4d65945#5b35c0988b07ab921d5eee5b8da8da55e4d65945"
+source = "git+https://github.com/feldera/delta-rs.git?rev=297f2dd146f9947795f8b77f25db8da9daff2ade#297f2dd146f9947795f8b77f25db8da9daff2ade"
 dependencies = [
  "async-trait",
  "bytes",
diff --git a/Cargo.toml b/Cargo.toml
index 61f342a1bd5..ffecd064b40 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -111,17 +111,20 @@ datafusion = "53.1"
 dbsp = { path = "crates/dbsp", version = "0.321.0" }
 dbsp_nexmark = { path = "crates/nexmark" }
 deadpool-postgres = "0.14.1"
-# Feldera fork of delta-rs: upstream tag `rust-v0.32.3` + 2 patches, on branch
-# `v0.32.3-feldera`. When bumping the pinned revision, preserve these patches:
+# Feldera fork of delta-rs: upstream tag `rust-v0.32.3` + 3 patches, on branch
+# `v0.32.3-feldera-fix`. When bumping the pinned revision, preserve these patches:
 #   - 7f8bb445 "Disable unsupported feature check." — relax the writer-side
 #     protocol-feature gate so we can write tables produced by newer clients.
 #   - 5b35c098 "delta-rs: round-robin pre-split unpartitioned scans into
 #     target_partitions FileGroups" — improves snapshot read parallelism for
 #     unpartitioned tables; pairs with the DataFusion knobs we tune in adapters.
+#   - 9a58fbef "delta-rs: resolve column-mapped Uniform/Iceberg columns by
+#     Parquet field-id" — fixes `col-<id> is missing from the physical schema`
+#     when reading UC-Uniform-over-Iceberg tables (columnMapping.mode=id). #6557.
 # Diff vs. upstream:
-#   https://github.com/delta-io/delta-rs/compare/rust-v0.32.3...feldera:delta-rs:v0.32.3-feldera
-deltalake = { git = "https://github.com/feldera/delta-rs.git", rev = "5b35c0988b07ab921d5eee5b8da8da55e4d65945" }
-deltalake-catalog-unity = { git = "https://github.com/feldera/delta-rs.git", rev = "5b35c0988b07ab921d5eee5b8da8da55e4d65945" }
+#   https://github.com/delta-io/delta-rs/compare/rust-v0.32.3...feldera:delta-rs:v0.32.3-feldera-fix
+deltalake = { git = "https://github.com/feldera/delta-rs.git", rev = "297f2dd146f9947795f8b77f25db8da9daff2ade" }
+deltalake-catalog-unity = { git = "https://github.com/feldera/delta-rs.git", rev = "297f2dd146f9947795f8b77f25db8da9daff2ade" }
 
 delta_kernel = { package = "buoyant_kernel", version = "0.22" }
 derive_more = { version = "1.0.0" }
diff --git a/python/tests/platform/fixtures/uniform_iceberg.py b/python/tests/platform/fixtures/uniform_iceberg.py
new file mode 100644
index 00000000000..78b4c2bd980
--- /dev/null
+++ b/python/tests/platform/fixtures/uniform_iceberg.py
@@ -0,0 +1,217 @@
+"""Build a UC-Uniform-over-Iceberg-shaped Delta table fixture with pyarrow.
+
+``tests.utils.ensure_delta_spark_fixture`` runs this as a subprocess
+(``uv run --with pyarrow python uniform_iceberg.py <output_dir>``). Unlike the
+column-mapping fixture, this one cannot be written by Delta Spark: it reproduces
+what a *native Iceberg writer* (Flink / pyiceberg, exposed as Delta by Unity
+Catalog Uniform) puts on disk -- Parquet columns named by their **logical** names
+carrying a Parquet ``field_id`` -- while the Delta log uses ``columnMapping.mode =
+'id'``. We therefore emit the Parquet with pyarrow and hand-write the
+``_delta_log``.
+
+The table mirrors the customer's ``cdc_raw`` shape:
+
+* ``id``     -- physical name ``col-100`` *diverges* from the on-disk ``id``
+               (a nullable scalar resolved by field id).
+* ``after``  -- a six-field nested struct whose children *also* diverge: each is
+               mapped to ``col-<id>`` while the file names them logically
+               (``transaction__id`` ...). Under by-name resolution the struct cast
+               target (``col-104`` ...) shares no overlap with the file's logical
+               child names, the customer's "Cannot cast struct with 6 fields to 6
+               fields because there is no field name overlap".
+* ``op``     -- physical name ``col-102`` *diverges* and is **non-nullable**.
+               This is the column that fails an unpatched read with
+               ``Non-nullable column 'col-102' is missing from the physical schema``.
+
+A correct snapshot read resolves every column -- top level and the struct's
+children -- by Parquet ``field_id``, so the diverging columns come back with their
+real values rather than NULL (or a hard error for ``op`` / the struct cast).
+
+Bump ``FIXTURE_VERSION`` in ``test_delta_input_uniform_iceberg.py`` on any change
+here, since a cached fixture is reused based on its path alone.
+"""
+
+from __future__ import annotations
+
+import json
+import os
+import sys
+
+
+# (logical child name, field id) for the six-field ``after`` struct. Children are
+# mapped to diverging physical names ``col-<id>`` in the Delta log below.
+AFTER_CHILDREN = [
+    ("transaction__id", 104),
+    ("transaction__merchant_id", 105),
+    ("transaction__merchant_name", 106),
+    ("transaction__time", 107),
+    ("transaction__status", 108),
+    ("transaction__amount", 109),
+]
+
+
+# Final logical rows expected from a snapshot read. Shared with the test via import
+# so the two never drift. ``after`` is a nested row.
+EXPECTED_ROWS = [
+    {
+        "id": "txn-001",
+        "after": {
+            "transaction__id": "txn-001",
+            "transaction__merchant_id": "m-100",
+            "transaction__merchant_name": "Coffee Shop",
+            "transaction__time": "2026-01-01T00:00:00Z",
+            "transaction__status": "settled",
+            "transaction__amount": "12.50",
+        },
+        "op": "c",
+    },
+    {
+        "id": "txn-002",
+        "after": {
+            "transaction__id": "txn-002",
+            "transaction__merchant_id": "m-200",
+            "transaction__merchant_name": "Gas Station",
+            "transaction__time": "2026-01-02T00:00:00Z",
+            "transaction__status": "settled",
+            "transaction__amount": "40.00",
+        },
+        "op": "c",
+    },
+    {
+        "id": "txn-003",
+        "after": {
+            "transaction__id": "txn-003",
+            "transaction__merchant_id": "m-300",
+            "transaction__merchant_name": "Restaurant",
+            "transaction__time": "2026-01-03T00:00:00Z",
+            "transaction__status": "reversed",
+            "transaction__amount": "75.25",
+        },
+        "op": "u",
+    },
+]
+
+
+def _field_id(value: int) -> dict:
+    return {b"PARQUET:field_id": str(value).encode()}
+
+
+def build(table_path: str) -> None:
+    """Create the UC-Uniform-over-Iceberg table at ``table_path``."""
+    import pyarrow as pa
+    import pyarrow.parquet as pq
+
+    after_type = pa.struct(
+        [
+            pa.field(name, pa.string(), metadata=_field_id(field_id))
+            for name, field_id in AFTER_CHILDREN
+        ]
+    )
+    schema = pa.schema(
+        [
+            pa.field("id", pa.string(), nullable=True, metadata=_field_id(100)),
+            pa.field("after", after_type, nullable=True, metadata=_field_id(103)),
+            pa.field("op", pa.string(), nullable=False, metadata=_field_id(102)),
+        ]
+    )
+    table = pa.table(
+        {
+            "id": [r["id"] for r in EXPECTED_ROWS],
+            "after": [r["after"] for r in EXPECTED_ROWS],
+            "op": [r["op"] for r in EXPECTED_ROWS],
+        },
+        schema=schema,
+    )
+
+    parquet_rel = "part-00000-uniform-iceberg.parquet"
+    log_dir = os.path.join(table_path, "_delta_log")
+    os.makedirs(log_dir, exist_ok=True)
+    # store_schema=False keeps the file Iceberg-shaped (no embedded Arrow schema);
+    # the field_ids are written into the Parquet schema regardless.
+    pq.write_table(table, os.path.join(table_path, parquet_rel), store_schema=False)
+    size = os.path.getsize(os.path.join(table_path, parquet_rel))
+
+    _write_log(log_dir, parquet_rel, size)
+
+
+def _column_metadata(field_id: int, physical_name: str) -> dict:
+    return {
+        "delta.columnMapping.id": field_id,
+        "delta.columnMapping.physicalName": physical_name,
+    }
+
+
+def _schema_string() -> str:
+    # Every field -- top level and the struct's children -- uses a diverging
+    # `col-<id>` physical name, exactly as a native Iceberg writer's Uniform log
+    # does, so a correct read must resolve by field id at every level.
+    after_type = {
+        "type": "struct",
+        "fields": [
+            {
+                "name": name,
+                "type": "string",
+                "nullable": True,
+                "metadata": _column_metadata(field_id, f"col-{field_id}"),
+            }
+            for name, field_id in AFTER_CHILDREN
+        ],
+    }
+    fields = [
+        {
+            "name": "id",
+            "type": "string",
+            "nullable": True,
+            "metadata": _column_metadata(100, "col-100"),
+        },
+        {
+            "name": "after",
+            "type": after_type,
+            "nullable": True,
+            "metadata": _column_metadata(103, "col-103"),
+        },
+        {
+            "name": "op",
+            "type": "string",
+            "nullable": False,
+            "metadata": _column_metadata(102, "col-102"),
+        },
+    ]
+    return json.dumps({"type": "struct", "fields": fields})
+
+
+def _write_log(log_dir: str, parquet_rel: str, size: int) -> None:
+    # Legacy column-mapping protocol (reader 2 / writer 5): no feature lists,
+    # which the delta kernel rejects below reader version 3.
+    protocol = {"protocol": {"minReaderVersion": 2, "minWriterVersion": 5}}
+    metadata = {
+        "metaData": {
+            "id": "uniform-iceberg-fixture-0000-0000-000000000000",
+            "format": {"provider": "parquet", "options": {}},
+            "schemaString": _schema_string(),
+            "partitionColumns": [],
+            "configuration": {
+                "delta.columnMapping.mode": "id",
+                "delta.columnMapping.maxColumnId": "109",
+            },
+            "createdTime": 1700000000000,
+        }
+    }
+    add = {
+        "add": {
+            "path": parquet_rel,
+            "partitionValues": {},
+            "size": size,
+            "modificationTime": 1700000000000,
+            "dataChange": True,
+        }
+    }
+    with open(os.path.join(log_dir, "00000000000000000000.json"), "w") as f:
+        for entry in (protocol, metadata, add):
+            f.write(json.dumps(entry) + "\n")
+
+
+if __name__ == "__main__":
+    if len(sys.argv) != 2:
+        raise SystemExit("usage: uniform_iceberg.py <output_dir>")
+    build(sys.argv[1])
diff --git a/python/tests/platform/test_delta_input_uniform_iceberg.py b/python/tests/platform/test_delta_input_uniform_iceberg.py
new file mode 100644
index 00000000000..a32766d348c
--- /dev/null
+++ b/python/tests/platform/test_delta_input_uniform_iceberg.py
@@ -0,0 +1,139 @@
+"""Snapshot read of a UC-Uniform-over-Iceberg table (``columnMapping.mode='id'``).
+
+A Unity Catalog Uniform table exposes Iceberg data files as Delta. A native
+Iceberg writer (Flink / pyiceberg) names the Parquet columns by their *logical*
+names and identifies them by Parquet ``field_id``; the synthesized Delta log uses
+``columnMapping.mode='id'`` with physical names ``col-<id>``. A correct snapshot
+read must resolve each column by field id, not by physical name -- otherwise a
+column whose physical name (``col-<id>``) is absent from the logically-named file
+reads as NULL (nullable) or fails outright (non-nullable).
+
+This reproduces the customer's ``cdc_raw`` failure on two fronts: the non-nullable
+top-level ``op`` (physical name ``col-102``) is missing from the physical schema
+under by-name resolution, and the nested ``after`` struct's six children are
+*themselves* mapped to ``col-<id>`` -- so a by-name struct cast finds no overlap
+with the file's logical child names ("Cannot cast struct with 6 fields to 6 fields
+because there is no field name overlap"). A correct read resolves by field id at
+every level. The fixture is written with pyarrow (Delta Spark cannot produce
+logical-name-on-disk Parquet); the builder lives in ``fixtures/uniform_iceberg.py``
+and runs via ``uv run --with pyarrow``.
+"""
+
+from __future__ import annotations
+
+import json
+from pathlib import Path
+
+from feldera import PipelineBuilder
+from feldera.runtime_config import RuntimeConfig
+from feldera.testutils import FELDERA_TEST_NUM_HOSTS, FELDERA_TEST_NUM_WORKERS
+
+from tests import TEST_CLIENT
+from tests.platform.fixtures.uniform_iceberg import EXPECTED_ROWS
+from tests.utils import DeltaTestLocation, ensure_delta_spark_fixture
+
+TABLE = "t"
+CONNECTOR = "delta_in"
+# Bump to invalidate cached MinIO/local copies when the fixture definition changes.
+FIXTURE_VERSION = "v1"
+
+# pyarrow builder that writes the logical-name Parquet + hand-written _delta_log.
+# It runs in a subprocess (see ensure_delta_spark_fixture) with only pyarrow.
+_FIXTURE_BUILDER = Path(__file__).parent / "fixtures" / "uniform_iceberg.py"
+
+
+def _build_sql(loc: DeltaTestLocation) -> str:
+    connectors = json.dumps(
+        [
+            {
+                "name": CONNECTOR,
+                "transport": {
+                    "name": "delta_table_input",
+                    "config": dict(loc.connector_config),
+                },
+            }
+        ]
+    ).replace("'", "''")
+    # `op` is declared NOT NULL to match the customer; `after` is the customer's
+    # six-field nested ROW whose children are column-mapped to diverging `col-<id>`
+    # names. Pre-fix, the snapshot fails resolving `op`/`col-102` and casting the
+    # `after` struct ("no field name overlap").
+    return (
+        f"CREATE TABLE {TABLE} ("
+        "id VARCHAR,"
+        "after ROW("
+        "transaction__id VARCHAR,"
+        "transaction__merchant_id VARCHAR,"
+        "transaction__merchant_name VARCHAR,"
+        "transaction__time VARCHAR,"
+        "transaction__status VARCHAR,"
+        "transaction__amount VARCHAR"
+        "),"
+        "op VARCHAR NOT NULL"
+        f") WITH ('materialized' = 'true', 'connectors' = '{connectors}');"
+    )
+
+
+def _snapshot_rows(pipeline) -> list[dict]:
+    # Project the two diverging top-level scalars plus a nested child of `after`.
+    # The nested projection exercises field-id resolution *inside* the struct --
+    # the case that fails the struct cast pre-fix, not just the top-level columns.
+    rows = pipeline.query(
+        f"SELECT id, op, after.transaction__merchant_name AS merchant FROM {TABLE}"
+    )
+    return sorted(
+        ({"id": r["id"], "op": r["op"], "merchant": r["merchant"]} for r in rows),
+        key=lambda r: r["id"],
+    )
+
+
+def test_delta_input_uniform_iceberg_id_snapshot(pipeline_name):
+    """Snapshot read of a UC-Uniform-over-Iceberg table resolves columns by
+    Parquet field id at every level: the diverging non-nullable ``op`` (``col-102``)
+    comes back with real values instead of failing, and the nested ``after`` struct
+    -- whose children are themselves mapped to ``col-<id>`` -- is reconstructed by
+    field id instead of failing the struct cast."""
+    loc = DeltaTestLocation.create(
+        pipeline_name,
+        mode="snapshot",
+        stable_subpath=f"uniform_iceberg_id_{FIXTURE_VERSION}",
+    )
+    try:
+        ensure_delta_spark_fixture(
+            loc, _FIXTURE_BUILDER, delta_spark_spec="pyarrow>=15"
+        )
+
+        pipeline = PipelineBuilder(
+            TEST_CLIENT,
+            pipeline_name,
+            sql=_build_sql(loc),
+            runtime_config=RuntimeConfig(
+                workers=FELDERA_TEST_NUM_WORKERS,
+                hosts=FELDERA_TEST_NUM_HOSTS,
+                logging="debug",
+            ),
+        ).create_or_replace()
+        pipeline.start()
+        pipeline.wait_for_completion(force_stop=False, timeout_s=600)
+
+        expected = sorted(
+            (
+                {
+                    "id": r["id"],
+                    "op": r["op"],
+                    "merchant": r["after"]["transaction__merchant_name"],
+                }
+                for r in EXPECTED_ROWS
+            ),
+            key=lambda r: r["id"],
+        )
+        rows = _snapshot_rows(pipeline)
+        assert rows == expected, (
+            "snapshot read must resolve column-mapped Uniform/Iceberg data by "
+            "field id at every level (top-level op/col-102 and the nested after "
+            f"struct's children); got {rows}"
+        )
+
+        pipeline.stop(force=True)
+    finally:
+        loc.cleanup()