Logical Decoding - Execute join query

Hi all,

     

      I tried to execute a join query using SPI_execute() in logical decoding part and got inconsistent values (i am referring it as inconsistent since it is returning the old values which is present at the postgresql server start).

My data directory has to tables

I have table1 as 

and table 2 as

Then through psql client inserted a new row to table1 as:      insert into table1(3,3,3);

While decoding this insert query i am trying to execute the below query using SPI_execute 

And got only 2 rows.

I cant able to get any new rows that are inserted. Are these new values get locked somewhere?

 

Is there a way to get inserted changes?

PS:When i restart the pgsql server i can able to get those new values that are inserted/updated in previous instance.