Improve logging

Author: gyfora

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/observer/JobStatusObserver.java

@@ -200,10 +200,8 @@ protected void observeJobManagerExceptions(FlinkResourceContext<R> ctx) {
                 emitJobManagerExceptionEvent(ctx, exception, exceptionTime, maxStackTraceLines);
             }
 
-            if (count < maxEvents && exceptionHistory.isTruncated()) {
-                LOG.warn(
-                        "Job exception history is truncated for jobId '{}'. Some exceptions may be missing.",
-                        jobId);
+            if (count > maxEvents) {
+                LOG.warn("Job exception history is truncated. Some exceptions may be missing.");
             }
 
             cacheEntry.setJobId(currentJobId);