I am doing an evaluation and am having real problems with the dbjoin joiner.
I have a input stream and wish to join to a table to get some more values.
I can do this with a reader and a hash join but wanted to try out the dbjoin.
I have 2 columns too join on ref_date and rating_tariff_id. I select these as the join criteria and set up the transform.
I assume the input field names for the join have to be identical to the field names in the oracle table for the join to work?
the error I get when I run the graph is as follows
Node DBJOIN0 finished with status: ERROR caused by: java.sql.SQLException: Invalid column index with field 'RATING_TARIFF_ID'
ERROR [WatchDog] - Node DBJOIN0 error details:
If I change the join to use ref_date then the error is repeated but showing ref_date rather than rating tariff_id.
Any help apprieciated.
I have a input stream and wish to join to a table to get some more values.
I can do this with a reader and a hash join but wanted to try out the dbjoin.
I have 2 columns too join on ref_date and rating_tariff_id. I select these as the join criteria and set up the transform.
I assume the input field names for the join have to be identical to the field names in the oracle table for the join to work?
the error I get when I run the graph is as follows
Node DBJOIN0 finished with status: ERROR caused by: java.sql.SQLException: Invalid column index with field 'RATING_TARIFF_ID'
ERROR [WatchDog] - Node DBJOIN0 error details:
If I change the join to use ref_date then the error is repeated but showing ref_date rather than rating tariff_id.
Any help apprieciated.
-
sorry all
I have read the user manual and found ... where fname=? and lname=?
The moral of the story is rtm. -
Yes, RTM is a good practice :wink:
For others, who don't read a manual:Fields listed in a joinKey attribute refer to the the columns specified in where clause of sql query set in sqlQuery attribute
Please sign in to leave a comment.
Comments 2