low-latency

Describe the bug

No response

To reproduce

create table pricetable2
(ts timestamp,symbolname SYMBOL CACHE ,price Double,aggregateTradeId Long,firstTradeId Long,lastTradeId Long,buyerMaker Boolean,qty Double) 
partition by day;

Executes without error and crates table without designated timestamp partitioned by DAY

Expected Behavior

Create table query sh

Avoid controlling endless loop with exception in loadAnonymousClasses, e.g. by extracting loading class to the method:

  private boolean tryLoadClass(String innerClassName) {
        try {
            parent.loadClass(innerClassName);
        } catch (ClassNotFoundException ex) {
            return false;
        }
        return true;
    }

https://sonarcloud.io/project

For example, given a simple pipeline such as:

Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
 .aggregate(aggregator)
 .writeTo(Sinks.logger());

I'd like aggregator to be something requiring a non-serialisable dependency to do its work.

I know I can do this:

Pipeline p = Pipeline.create();
p.readFrom(TestSource