[ https://issues.apache.org/jira/browse/SAMZA-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bharath Kumarasubramanian resolved SAMZA-2299. ---------------------------------------------- Resolution: Fixed > StreamTableJoin Operator should invoke user join function only once > ------------------------------------------------------------------- > > Key: SAMZA-2299 > URL: https://issues.apache.org/jira/browse/SAMZA-2299 > Project: Samza > Issue Type: Bug > Reporter: Bharath Kumarasubramanian > Assignee: Bharath Kumarasubramanian > Priority: Major > Time Spent: 40m > Remaining Estimate: 0h > > In StreamTableJoinOperator, we currently invoke the user join function again > with null record if the first call to join function returns a null. This is > not desirable in use cases for anti-join where subsequent invocation of join > function could result in different results. > > {code:java} > Optional.ofNullable(value) > .map(val -> (R) KV.of(key, val) > .map(record -> joinOpSpec.getJoinFn().apply(message, record)) > .orElseGet(() -> joinOpSpec.getJoinFn().apply(message, null)); // this is > the additional invocation that happens if the previous invocation returns a > null{code} -- This message was sent by Atlassian JIRA (v7.6.14#76016)