fix: Revert named stores in expected topologies, disable naming store…

…s from StreamJoined, re-enable join tests. (#3550) This PR disables the naming of stores in join operations and reverts the named stores in the expected topologies files. Note that in the future KSQL can easily re-enable the naming of state stores for joins. After this PR is merged, we should be able to close #3364 Reviewers: Andy Coates <[email protected]>, Almog Gavra <[email protected]>
confluentinc · Oct 11, 2019 · 0b8ccc1 · 0b8ccc1
1 parent 5315f1e
commit 0b8ccc1
Show file tree

Hide file tree

Showing 33 changed files with 125 additions and 135 deletions.
diff --git a/...ces/expected_topology/5_2_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts b/...ces/expected_topology/5_2_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/.../5_2_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts_extractor_both_sides b/.../5_2_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts_extractor_both_sides
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...ctional-tests/src/test/resources/expected_topology/5_2_0/joins_-_stream_stream_inner_join b/...ctional-tests/src/test/resources/expected_topology/5_2_0/joins_-_stream_stream_inner_join
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...urces/expected_topology/5_2_0/joins_-_stream_stream_inner_join_all_left_fields_some_right b/...urces/expected_topology/5_2_0/joins_-_stream_stream_inner_join_all_left_fields_some_right
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...urces/expected_topology/5_2_0/joins_-_stream_stream_inner_join_all_right_fields_some_left b/...urces/expected_topology/5_2_0/joins_-_stream_stream_inner_join_all_right_fields_some_left
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...d_topology/5_2_0/joins_-_stream_stream_inner_join_with_different_before_and_after_windows b/...d_topology/5_2_0/joins_-_stream_stream_inner_join_with_different_before_and_after_windows
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...urces/expected_topology/5_2_0/joins_-_stream_stream_inner_join_with_out_of_order_messages b/...urces/expected_topology/5_2_0/joins_-_stream_stream_inner_join_with_out_of_order_messages
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...nctional-tests/src/test/resources/expected_topology/5_2_0/joins_-_stream_stream_left_join b/...nctional-tests/src/test/resources/expected_topology/5_2_0/joins_-_stream_stream_left_join
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-outer-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-OUTEROTHER-0000000009-store])
       --> Join-outer-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-outer-other-join (stores: [Join-this-join-store])
+    Processor: Join-outer-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-outer-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-OUTEROTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...ctional-tests/src/test/resources/expected_topology/5_2_0/joins_-_stream_stream_outer_join b/...ctional-tests/src/test/resources/expected_topology/5_2_0/joins_-_stream_stream_outer_join
@@ -48,16 +48,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-outer-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-OUTEROTHER-0000000009-store])
       --> Join-outer-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-outer-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-OUTERTHIS-0000000008-store])
       --> Join-outer-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-outer-other-join (stores: [Join-outer-this-join-store])
+    Processor: Join-outer-other-join (stores: [KSTREAM-OUTERTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-outer-this-join (stores: [Join-outer-other-join-store])
+    Processor: Join-outer-this-join (stores: [KSTREAM-OUTEROTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...tional-tests/src/test/resources/expected_topology/5_3_0/identifiers_-_aliased_join_source b/...tional-tests/src/test/resources/expected_topology/5_3_0/identifiers_-_aliased_join_source
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...ests/src/test/resources/expected_topology/5_3_0/identifiers_-_aliased_join_source_with_AS b/...ests/src/test/resources/expected_topology/5_3_0/identifiers_-_aliased_join_source_with_AS
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...sts/src/test/resources/expected_topology/5_3_0/identifiers_-_aliased_left_unaliased_right b/...sts/src/test/resources/expected_topology/5_3_0/identifiers_-_aliased_left_unaliased_right
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...sts/src/test/resources/expected_topology/5_3_0/identifiers_-_unaliased_left_aliased_right b/...sts/src/test/resources/expected_topology/5_3_0/identifiers_-_unaliased_left_aliased_right
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...ces/expected_topology/5_3_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts b/...ces/expected_topology/5_3_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/.../5_3_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts_extractor_both_sides b/.../5_3_0/join-with-custom-timestamp_-_stream_stream_inner_join_with_ts_extractor_both_sides
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...y/5_3_0/joins_-_join_using_ROWKEY_in_the_criteria_-_new_key_fields_-_no_source_key_fields b/...y/5_3_0/joins_-_join_using_ROWKEY_in_the_criteria_-_new_key_fields_-_no_source_key_fields
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-outer-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-OUTEROTHER-0000000009-store])
       --> Join-outer-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-outer-other-join (stores: [Join-this-join-store])
+    Processor: Join-outer-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-outer-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-OUTEROTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...ctional-tests/src/test/resources/expected_topology/5_3_0/joins_-_stream_stream_inner_join b/...ctional-tests/src/test/resources/expected_topology/5_3_0/joins_-_stream_stream_inner_join
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...ces/expected_topology/5_3_0/joins_-_stream_stream_inner_join_-_join_key_not_in_projection b/...ces/expected_topology/5_3_0/joins_-_stream_stream_inner_join_-_join_key_not_in_projection
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])

diff --git a/...s/expected_topology/5_3_0/joins_-_stream_stream_inner_join_-_right_join_key_in_projection b/...s/expected_topology/5_3_0/joins_-_stream_stream_inner_join_-_right_join_key_in_projection
@@ -56,16 +56,16 @@ Topologies:
     Processor: KSTREAM-TRANSFORMVALUES-0000000005 (stores: [])
       --> Join-other-windowed
       <-- KSTREAM-MAPVALUES-0000000004
-    Processor: Join-other-windowed (stores: [Join-other-join-store])
+    Processor: Join-other-windowed (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-other-join
       <-- KSTREAM-TRANSFORMVALUES-0000000005
-    Processor: Join-this-windowed (stores: [Join-this-join-store])
+    Processor: Join-this-windowed (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-this-join
       <-- KSTREAM-TRANSFORMVALUES-0000000002
-    Processor: Join-other-join (stores: [Join-this-join-store])
+    Processor: Join-other-join (stores: [KSTREAM-JOINTHIS-0000000008-store])
       --> Join-merge
       <-- Join-other-windowed
-    Processor: Join-this-join (stores: [Join-other-join-store])
+    Processor: Join-this-join (stores: [KSTREAM-JOINOTHER-0000000009-store])
       --> Join-merge
       <-- Join-this-windowed
     Processor: Join-merge (stores: [])