Hi Team, I am getting below error source: custom connector (Singer based oracle connector) Target: snowflake OS: Ubuntu Error: 2022-06-02 160409 destination > java.lang.IllegalArgumentException: Message contained record from a stream that was not in the catalog. 2022-06-02 160409 destination > catalog: {"streams":[{"stream":{"name":"mytable","json_schema":{"type":"object","properties":{"DOMAIN":{"type":["string"]},"DESCRIPTION":{"type":["null","string"]}}},"supported_sync_modes":["full_refresh"],"default_cursor_field":[],"source_defined_primary_key":[]},"sync_mode":"full_refresh","cursor_field":[],"destination_sync_mode":"overwrite","primary_key":[]}]} , 2022-06-02 160409 destination > message: {"type":"RECORD","record":{"stream":"myschema-mytable","data":{"DESCRIPTION":"AnalyticsConsultant for solution","DOMAIN":"MyDomain"},"emitted_at":1654185848000}} 2022-06-02 160409 destination > at io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer.throwUnrecognizedStream(BufferedStreamConsumer.java:155) ~[io.airbyte.airbyte-integrations.bases-base-java-0.35.59-alpha.jar:?]

yeah correct but catalog contains mytable stream, and message contains myschema-mytable. if this both are different then how do I fix? where should I look in the code?

Hey @Rahul Patel, please post on our forum if you need troubleshooting assistance 🙏🏻