Changed DEBUG log level to WARN

apache · Apr 4, 2019 · ac27e85 · ac27e85
1 parent 09ace6b
commit ac27e85
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java
@@ -234,7 +234,7 @@ public KeyValueIterator<Bytes, byte[]> range(final Bytes from,
                                                  final Bytes to) {
         // Make sure this is a valid query
         if (from.compareTo(to) > 0) {
-            LOG.debug("Returning empty iterator for range query with invalid range: keyFrom > keyTo.");
+            LOG.warn("Returning empty iterator for range query with invalid range: keyFrom > keyTo.");
             return KeyValueIterators.emptyIterator();
         }
 

diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java
@@ -159,7 +159,7 @@ public KeyValueIterator<Windowed<Bytes>, byte[]> findSessions(final Bytes keyFro
                                                                   final long latestSessionStartTime) {
         // Make sure this is a valid query
         if (keyFrom.compareTo(keyTo) > 0) {
-            LOG.debug("Returning empty iterator for findSessions call with invalid range: keyFrom > keyTo.");
+            LOG.warn("Returning empty iterator for findSessions call with invalid range: keyFrom > keyTo.");
             return KeyValueIterators.emptyIterator();
         }
 

diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java
@@ -202,7 +202,7 @@ public KeyValueIterator<Windowed<Bytes>, byte[]> fetch(final Bytes from,
                                                            final long timeTo) {
         // Make sure this is a valid query
         if (from.compareTo(to) > 0) {
-            LOG.debug("Returning empty iterator for fetch with invalid range: keyFrom > keyTo.");
+            LOG.warn("Returning empty iterator for fetch with invalid range: keyFrom > keyTo.");
             return KeyValueIterators.emptyIterator();
         }
 

diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
@@ -117,7 +117,7 @@ public byte[] delete(final Bytes key) {
     public KeyValueIterator<Bytes, byte[]> range(final Bytes from, final Bytes to) {
         // Make sure this is a valid query
         if (from.compareTo(to) > 0) {
-            LOG.debug("Returning empty iterator for range query with invalid range: keyFrom > keyTo.");
+            LOG.warn("Returning empty iterator for range query with invalid range: keyFrom > keyTo.");
             return KeyValueIterators.emptyIterator();
         }
 

diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java
@@ -131,7 +131,7 @@ public void put(final Bytes key, final byte[] value, final long windowStartTimes
 
         if (windowStartTimestamp <= this.observedStreamTime - this.retentionPeriod) {
             expiredRecordSensor.record();
-            LOG.debug("Skipping record for expired segment.");
+            LOG.warn("Skipping record for expired segment.");
         } else {
             if (value != null) {
                 this.segmentMap.computeIfAbsent(windowStartTimestamp, t -> new ConcurrentSkipListMap<>());