Solved

JDBC Multitable Consumer error


Hi, I am new to Streamsets, started using it today.

I have a task to create some backup data to hive and hadoop using jdbc multitable consumer.

the problem that occurs is that there is a table name with '-' instead of '_' example: call-outcomme_id should the correct one be call_outcomme_id.

I have used the field remover to maintain the table name with 'keep listed fields' when I start an error occurs, but when I select 'remove listed fields' the column that I targeted was deleted and it worked.

thanks in advance

icon

Best answer by realmatcha 25 May 2023, 09:27

View original

23 replies

@BikramĀ @saleempothiwalaĀ @tamilarasupĀ thank you all for helping a lot, everything is done and running well

Userlevel 5
Badge +1

@realmatchaĀ 

You can see the above result if you preview your pipeline.

Just preview and see the result. :)

I've followed and it's running, but I can't see a result like this

Ā 

Ā 

Userlevel 5
Badge +1

@realmatchaĀ 

If you are having problem in after importing my pipeline then you just use the processors has been used in my pipeline in your env.

Ā 

Please follow below steps and i hope it will help. Let me know in case of any issues.

step1 :Ā 

Origin as Dev Raw data source and inputs areĀ 

Ā 

{
Ā  "call-comme_id": "abc"
Ā Ā 
}
{
Ā  "call_comme_id": "xyz"
Ā Ā 
}
{
Ā  "call-comme-id": "ABC"
Ā Ā 
}

Step2 : Use the filed mapper processor to rename the fields.

Ā 

Ā 

Ā 

Your pipeline should look like below .

Ā 

Ā 

Ā 

cant install library. please help me

Userlevel 5
Badge +1

Ā 

Userlevel 5
Badge +1

@realmatchaĀ 

Ā 

Please find attached the pipeline and try to implement in your pipeline and i hope it will solve your issues without any error.

Ā 

Ā 

Userlevel 5
Badge +1

@realmatchaĀ 

Ā 

we need quote for the fields but you need to filter out the fields for which you are trying to rename if the field name exists in your record else no need to anything.

I will provide you the work around for your case . You just try that and i hope it will help.

i have replaced it but still error

use quotation after a slashĀ 

example:Ā  Ā  Ā  Ā  Ā  Ā /ā€™call_outcome_idā€™

here`s each one of the processor details

Userlevel 4
Badge

you will have to select each processor and show the properties and screenshot

i have replaced it but still error

can you please screenshot what is filled in each processor?

Userlevel 4
Badge

Remove the quotes for source and target both.

Userlevel 4
Badge

@realmatchaĀ 

I can see that in your rename, you are using /ā€™call-comme_idā€™Ā 

Remove the quotes and try.

Userlevel 5
Badge +1

@realmatchaĀ 

You can add filter like below based on the field and it will resolve your issues.

Ā 

Ā 

Userlevel 5
Badge +1

@realmatchaĀ 

Ā 

May know if all row contains the column name or not , if it contains then it will rename it else throw error.

You can add a check that ifĀ Ā call-outcomme_id is not null then rename it else no need to do anything.

Ā 

The error is because of the column name is missing for many rows and we are trying rename it .

I've tried but it's still an error, you can see what each processor contains

Userlevel 5
Badge +1

@realmatchaĀ 

Ā 

Please try like below .

Ā 

Ā 

but it gives syntax error. can you please provide and example how to do proper "Field Rename"
Userlevel 5
Badge +1

@realmatchaĀ 

The error seems like the column name is not matching with your destination table name.

Kindly try to rename the column name by using ā€œField Renameā€ processor and check if it avoid the issue.


com.streamsets.pipeline.stage.lib.hive.exceptions.HiveStageCheckedException: HIVE_30 - Invalid column nameĀ call-outcomme_id

Userlevel 5
Badge +1

@realmatchaĀ 

kindly provide error details, so i can help you on it.

Reply