shading changed & union read for append table

Author: Mehul Batra

fluss-lake/fluss-lake-iceberg/pom.xml

@@ -319,15 +319,20 @@
                                 </includes>
                             </artifactSet>
                             <relocations>
-                                <!-- Shade Jackson to match Iceberg's shaded package -->
+                                <!-- Shade Iceberg to Fluss namespace for complete isolation -->
+                                <relocation>
+                                    <pattern>org.apache.iceberg</pattern>
+                                    <shadedPattern>org.apache.fluss.lake.iceberg.shaded.org.apache.iceberg</shadedPattern>
+                                </relocation>
+                                <!-- Shade Jackson to Fluss namespace -->
                                 <relocation>
                                     <pattern>com.fasterxml.jackson</pattern>
-                                    <shadedPattern>org.apache.iceberg.shaded.com.fasterxml.jackson</shadedPattern>
+                                    <shadedPattern>org.apache.fluss.lake.iceberg.shaded.com.fasterxml.jackson</shadedPattern>
                                 </relocation>
-                                <!-- Shade Parquet to match Iceberg's shaded package -->
+                                <!-- Shade Parquet to Fluss namespace -->
                                 <relocation>
                                     <pattern>org.apache.parquet</pattern>
-                                    <shadedPattern>org.apache.iceberg.shaded.org.apache.parquet</shadedPattern>
+                                    <shadedPattern>org.apache.fluss.lake.iceberg.shaded.org.apache.parquet</shadedPattern>
                                 </relocation>
                             </relocations>
                             <filters>

website/docs/quickstart/flink-iceberg.md

@@ -63,7 +63,6 @@ services:
 
   coordinator-server:
     image: fluss/fluss:$FLUSS_DOCKER_VERSION$
-    command: coordinatorServer
     depends_on:
       - zookeeper
     environment:
@@ -401,8 +400,7 @@ CREATE TABLE datalake_enriched_orders (
     `cust_phone` STRING,
     `cust_acctbal` DECIMAL(15, 2),
     `cust_mktsegment` STRING,
-    `nation_name` STRING,
-    PRIMARY KEY (`order_key`) NOT ENFORCED
+    `nation_name` STRING
 ) WITH (
     'table.datalake.enabled' = 'true',
     'table.datalake.freshness' = '30s'
@@ -429,11 +427,14 @@ SELECT o.order_key,
        c.acctbal,
        c.mktsegment,
        n.name
-FROM fluss_order o
-       LEFT JOIN fluss_customer FOR SYSTEM_TIME AS OF `o`.`ptime` AS `c`
-                 ON o.cust_key = c.cust_key
-       LEFT JOIN fluss_nation FOR SYSTEM_TIME AS OF `o`.`ptime` AS `n`
-                 ON c.nation_key = n.nation_key;
+FROM (
+    SELECT *, PROCTIME() as ptime
+    FROM `default_catalog`.`default_database`.source_order
+) o
+LEFT JOIN fluss_customer FOR SYSTEM_TIME AS OF o.ptime AS c
+    ON o.cust_key = c.cust_key
+LEFT JOIN fluss_nation FOR SYSTEM_TIME AS OF o.ptime AS n
+    ON c.nation_key = n.nation_key;
 ```
 
 ### Real-Time Analytics on Fluss datalake-enabled Tables
@@ -459,11 +460,12 @@ SELECT snapshot_id, operation FROM datalake_enriched_orders$lake$snapshots;
 
 **Sample Output:**
 ```shell
-+-------------+--------------------+
-| snapshot_id |          operation |
-+-------------+--------------------+
-|           1 |             append |
-+-------------+--------------------+
++---------------------+-----------+
+|         snapshot_id | operation |
++---------------------+-----------+
+| 7792523713868625335 |    append |
+| 7960217942125627573 |    append |
++---------------------+-----------+
 ```
 **Note:** Make sure to wait for the configured `datalake.freshness` (~30s) to complete before querying the snapshots, otherwise the result will be empty.
 
@@ -474,30 +476,27 @@ SELECT sum(total_price) as sum_price FROM datalake_enriched_orders$lake;
 ```
 **Sample Output:**
 ```shell
-+------------+
-|  sum_price |
-+------------+
-| 1669519.92 |
-+------------+
++-----------+
+| sum_price |
++-----------+
+| 432880.93 |
++-----------+
 ```
 
 To achieve results with sub-second data freshness, you can query the table directly, which seamlessly unifies data from both Fluss and Iceberg:
 
 ```sql  title="Flink SQL"
--- all orders (combining fluss and iceberg data)
-> SELECT * FROM datalake_enriched_orders limit 2;
+-- to sum prices of all orders (combining fluss and iceberg data)
+> SELECT sum(total_price) as sum_price FROM datalake_enriched_orders;
 ```
 
 **Sample Output:**
 ```shell
-
-+-----------+----------+-------------+------------+----------------+--------+--------------+----------------+--------------+-----------------+-------------+
-| order_key | cust_key | total_price | order_date | order_priority |  clerk |    cust_name |     cust_phone | cust_acctbal | cust_mktsegment | nation_name |
-+-----------+----------+-------------+------------+----------------+--------+--------------+----------------+--------------+-----------------+-------------+
-|  77733888 |       12 |      412.61 | 2025-07-11 |           high | Clerk3 | Frank Furter | 1-203-732-5680 |       623.86 |       HOUSEHOLD |       CHINA |
-|    340736 |        1 |      111.26 | 2025-09-05 |            low | Clerk1 |       <NULL> |         <NULL> |       <NULL> |          <NULL> |      <NULL> |
-+-----------+----------+-------------+------------+----------------+--------+--------------+----------------+--------------+-----------------+-------------+
-
++-----------+
+| sum_price |
++-----------+
+| 558660.03 |
++-----------+
 ```
 
 You can execute the real-time analytics query multiple times, and the results will vary with each run as new data is continuously written to Fluss in real-time.
@@ -509,7 +508,7 @@ docker compose exec taskmanager tree /tmp/iceberg/fluss.db
 
 **Sample Output:**
 ```shell
-/tmp/iceberg/fluss.db
+/tmp/iceberg/fluss
 └── datalake_enriched_orders
     ├── data
     │   └── 00000-0-abc123.parquet