fix: change locate() error message for a more user-friendly message (#…

…6709)
confluentinc · Dec 3, 2020 · e6ba436 · e6ba436
1 parent 9805481
commit e6ba436
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/...reams/src/main/java/io/confluent/ksql/execution/streams/materialization/ks/KsLocator.java b/...reams/src/main/java/io/confluent/ksql/execution/streams/materialization/ks/KsLocator.java
@@ -89,10 +89,11 @@ public List<KsqlPartitionLocation> locate(
 
       // Fail fast if Streams not ready. Let client handle it
       if (metadata == KeyQueryMetadata.NOT_AVAILABLE) {
-        LOG.debug("KeyQueryMetadata not available for state store {} and key {}",
+        LOG.debug("KeyQueryMetadata not available for state store '{}' and key {}",
             stateStoreName, key);
         throw new MaterializationException(String.format(
-            "KeyQueryMetadata not available for state store %s and key %s", stateStoreName, key));
+            "Materialized data for key %s is not available yet. "
+                + "Please try again later.", key));
       }
 
       LOG.debug("Handling pull query for key {} in partition {} of state store {}.",

diff --git a/...s/src/test/java/io/confluent/ksql/execution/streams/materialization/ks/KsLocatorTest.java b/...s/src/test/java/io/confluent/ksql/execution/streams/materialization/ks/KsLocatorTest.java
@@ -164,7 +164,7 @@ public void shouldThrowIfMetadataNotAvailable() {
 
     // Then:
     assertThat(e.getMessage(), containsString(
-        "KeyQueryMetadata not available for state store someStoreName and key [1]"));
+        "Materialized data for key [1] is not available yet. Please try again later."));
   }
 
   @Test