@Override
  public void validateTransientQuery(
      final SessionConfig config,
      final ExecutionPlan executionPlan,
      final Collection<QueryMetadata> runningQueries
  ) {
    validateCacheBytesUsage(
        runningQueries.stream()
            .filter(q -> q instanceof TransientQueryMetadata)
            .collect(Collectors.toList()),
        config,
        config.getConfig(false)
            .getLong(KsqlConfig.KSQL_TOTAL_CACHE_MAX_BYTES_BUFFERING_TRANSIENT)
    );
  }
@Test
  public void shouldIgnoreBufferCacheLimitIfNotSetForTransientQueries() {
    // Given:
    final SessionConfig config = configWithLimits(100000000000L, OptionalLong.empty());

    // When/Then (no throw)
    queryValidator.validateTransientQuery(config, plan, queries);
  }