root@sdl63641:~/satish/airbyte/airbyte-integrations/connectors/destination-teradata# cat messages.jsonl | docker run --rm -v $(pwd)/secrets:/secrets -v $(pwd)/sample_files:/sample_files airbyte/destination-teradata:dev write --config /secrets/config.json --catalog /sample_files/configured_catalog.json
{"type":"LOG","log":{"level":"INFO","message":"integration args: {catalog=/sample_files/configured_catalog.json, write=null, config=/secrets/config.json}"}}
{"type":"LOG","log":{"level":"INFO","message":"Running integration: io.airbyte.integrations.destination.teradata.TeradataDestination"}}
{"type":"LOG","log":{"level":"INFO","message":"Command: WRITE"}}
{"type":"LOG","log":{"level":"INFO","message":"Integration config: IntegrationConfig{command=WRITE, configPath='/secrets/config.json', catalogPath='/sample_files/configured_catalog.json', statePath='null'}"}}
{"type":"LOG","log":{"level":"WARN","message":"Unknown keyword order - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword"}}
{"type":"LOG","log":{"level":"WARN","message":"Unknown keyword airbyte_secret - you should define your own Meta Schema. If the keyword is irrelevant for validation, just use a NonValidationKeyword"}}
{"type":"LOG","log":{"level":"INFO","message":"HikariPool-1 - Starting..."}}
{"type":"LOG","log":{"level":"INFO","message":"HikariPool-1 - Start completed."}}
{"type":"LOG","log":{"level":"INFO","message":"JdbcBufferedConsumerFactory : create"}}
{"type":"LOG","log":{"level":"INFO","message":"Write config: WriteConfig{streamName=airbyte_acceptance_table, namespace=null, outputSchemaName=airbytenewtoday, tmpTableName=_airbyte_tmp_aim_airbyte_acceptance_table, outputTableName=_airbyte_raw_airbyte_acceptance_table, syncMode=append}"}}
JdbcBufferedConsumerFactory : recordWriterFunction
sqlOperations: io.airbyte.integrations.destination.teradata.TeradataSqlOperations@63a5e46c
writeConfigs: 1
Each write config : WriteConfig{streamName=airbyte_acceptance_table, namespace=null, outputSchemaName=airbytenewtoday, tmpTableName=_airbyte_tmp_aim_airbyte_acceptance_table, outputTableName=_airbyte_raw_airbyte_acceptance_table, syncMode=append}
catalog: io.airbyte.protocol.models.ConfiguredAirbyteCatalog@4985cbcb[streams=[io.airbyte.protocol.models.ConfiguredAirbyteStream@72f46e16[stream=io.airbyte.protocol.models.AirbyteStream@3c9168dc[name=airbyte_acceptance_table,jsonSchema={"type":"object","required":["name"],"properties":{"name":{"type":"string"},"age":{"type":"number"}}},supportedSyncModes=[full_refresh],sourceDefinedCursor=false,defaultCursorField=[],sourceDefinedPrimaryKey=[],namespace=<null>,additionalProperties={}],syncMode=full_refresh,cursorField=[],destinationSyncMode=append,primaryKey=[],additionalProperties={}]],additionalProperties={}]
 StreamName : airbyte_acceptance_table
 Namespace : null
pairToWriteConfig after filter : {AirbyteStreamNameNamespacePair{name='airbyte_acceptance_table', namespace='null'}=WriteConfig{streamName=airbyte_acceptance_table, namespace=null, outputSchemaName=airbytenewtoday, tmpTableName=_airbyte_tmp_aim_airbyte_acceptance_table, outputTableName=_airbyte_raw_airbyte_acceptance_table, syncMode=append}}
Key = AirbyteStreamNameNamespacePair{name='airbyte_acceptance_table', namespace='null'}, Value = WriteConfig{streamName=airbyte_acceptance_table, namespace=null, outputSchemaName=airbytenewtoday, tmpTableName=_airbyte_tmp_aim_airbyte_acceptance_table, outputTableName=_airbyte_raw_airbyte_acceptance_table, syncMode=append}
{"type":"LOG","log":{"level":"INFO","message":"InMemoryRecordBufferingStrategy : io.airbyte.integrations.destination.jdbc.JdbcBufferedConsumerFactory$$Lambda$187/0x0000000800e3eb20@71652c98"}}
{"type":"LOG","log":{"level":"INFO","message":"InMemoryRecordBufferingStrategy : io.airbyte.integrations.destination.jdbc.JdbcBufferedConsumerFactory$$Lambda$187/0x0000000800e3eb20@71652c98"}}
{"type":"LOG","log":{"level":"INFO","message":"class io.airbyte.integrations.destination.buffered_stream_consumer.BufferedStreamConsumer started."}}
{"type":"LOG","log":{"level":"INFO","message":"Preparing tmp tables in destination started for 1 streams"}}
{"type":"LOG","log":{"level":"INFO","message":"Preparing tmp table in destination started for stream airbyte_acceptance_table. schema: airbytenewtoday, tmp table name: _airbyte_tmp_aim_airbyte_acceptance_table"}}
{"type":"LOG","log":{"level":"INFO","message":"HikariPool-1 - Driver does not support get/set network timeout for connections. (Receiver class com.teradata.jdbc.jdk6.JDK6_SQL_Connection does not define or inherit an implementation of the resolved method 'abstract int getNetworkTimeout()' of interface java.sql.Connection.)"}}
{"type":"LOG","log":{"level":"WARN","message":"Database airbytenewtoday already exists."}}
{"type":"LOG","log":{"level":"INFO","message":"Preparing tables in destination completed."}}
{"type":"LOG","log":{"level":"INFO","message":"Airbyte message consumer: succeeded."}}
{"type":"LOG","log":{"level":"INFO","message":"executing on success close procedure."}}
{"type":"LOG","log":{"level":"INFO","message":"No onDestinationCloseOperations required for this destination."}}
{"type":"LOG","log":{"level":"INFO","message":"Finalizing tables in destination started for 1 streams"}}
{"type":"LOG","log":{"level":"INFO","message":"Finalizing stream airbyte_acceptance_table. schema airbytenewtoday, tmp table _airbyte_tmp_aim_airbyte_acceptance_table, final table _airbyte_raw_airbyte_acceptance_table"}}
{"type":"LOG","log":{"level":"WARN","message":"Table airbytenewtoday._airbyte_raw_airbyte_acceptance_table already exists."}}
{"type":"LOG","log":{"level":"INFO","message":"Executing finalization of tables."}}
executeTransaction
{"type":"LOG","log":{"level":"INFO","message":"queries to be executed:  [INSERT INTO airbytenewtoday._airbyte_raw_airbyte_acceptance_table SELECT * FROM airbytenewtoday._airbyte_tmp_aim_airbyte_acceptance_table;\n]"}}
{"type":"LOG","log":{"level":"INFO","message":"Finalizing tables in destination completed."}}
{"type":"LOG","log":{"level":"INFO","message":"Cleaning tmp tables in destination started for 1 streams"}}
{"type":"LOG","log":{"level":"INFO","message":"Cleaning tmp table in destination started for stream airbyte_acceptance_table. schema airbytenewtoday, tmp table name: _airbyte_tmp_aim_airbyte_acceptance_table"}}
{"type":"LOG","log":{"level":"INFO","message":"Cleaning tmp tables in destination completed."}}
{"type":"LOG","log":{"level":"INFO","message":"Completed integration: io.airbyte.integrations.destination.teradata.TeradataDestination"}}
root@sdl63641:~/satish/airbyte/airbyte-integrations/connectors/destination-teradata#