pg-source-after-ssh-restart.td 977 B

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