When run
bazel run --define MEDIAPIPE_DISABLE_GPU=1 mediapipe/examples/desktop/hello_world:hello_world
Downloading org_tensorflow will time out.
I want use the pre-downloaded org_tensorflow by putting the tar.gz file in the .cache corresponding directory, but it didn't work.How should I operate it correctly?

Given a stream s1 that contains a NULL value:

CREATE STREAM s1 (x INTEGER) ...
INSERT INTO s1 (x) VALUES (null);

If that NULL expression is used in an arithmetic operation, the result of the operation will be NULL:

SELECT x + 1 FROM s1 EMIT CHANGES;

However, if a NULL literal is used in the same way, an NPE will be thrown:

ksql> SELECT NULL + 1 FROM

Basically, we don't need to have kafka-console-consumer, we have mill instead: https://github.com/ThreeDotsLabs/watermill/tree/master/tools/mill

It would be nice to replace it in all examples.

It can be very difficult to piece together a reasonably estimate of a history of events from the current workers logs because none of them have timestamps.

So for that end, I think we should add timestamps to the logs.

This has some cons:

1. We can't just use @printf like we have been until now. We need to either include a timestamp in every @printf call (laborious and error prone) or c

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