1234567891011121314151617181920212223242526272829303132 |
- # Copyright Materialize, Inc. and contributors. All rights reserved.
- #
- # Use of this software is governed by the Business Source License
- # included in the LICENSE file at the root of this repository.
- #
- # As of the Change Date specified in that file, in accordance with
- # the Business Source License, use of this software will be governed
- # by the Apache License, Version 2.0.
- # Ensure that the source becomes healthy again once the SSH tunnel is restarted.
- # We specifically make sure that new data written to the Kafka topic is visible
- # in the source, as that is the true measure of health, vs what is reported in
- # the mz_source_statuses relation.
- $ postgres-execute connection=postgres://postgres:postgres@postgres
- INSERT INTO t1 VALUES (3);
- > SELECT f1 FROM t1 ORDER BY f1 ASC;
- 1
- 1
- 2
- 3
- > SELECT name, type, error
- FROM mz_internal.mz_source_statuses
- WHERE
- name
- IN (
- SELECT name FROM mz_tables WHERE source_id IS NOT NULL
- );
- t1 table <null>
|