Hi Benjamin! How do I run the test on your PR? I can try to run it to see what's going on.[ Best -P.
On Thu, May 6, 2021 at 1:46 PM Pablo Estrada <[email protected]> wrote: > Hi Benjamin! > That's strange if the Java test is working well that the Python/xlang test > would run into issues. Let me take a look at your PR and see if I can see > anything suspicious. > Best > -P. > > On Thu, May 6, 2021 at 10:49 AM Benjamin Gonzalez Delgado < > [email protected]> wrote: > >> Hi team, >> I am working on BEAM-11838[1], but I am a little stuck right now[2], my >> issue is that when I set param maxNumberOfRecords through >> ExternalTransformBuilder(L117) its sets the value correctly to the >> constructor on KafkaSourceConsumerFn (L111), but when it arrives at >> tryClaim method(L307) the value for maxNumberOfRecords is null again and it >> keeps running forever so my test never ends. >> I wonder if some of you have experience with KafkaSourceConsumerFn class >> or creating other cross-language transforms that could help. >> Any guidance on this would be appreciated. >> >> PD. The existing java test DebeziumIOMySqlConnectorIT does not have the >> same problem. >> >> [1] https://issues.apache.org/jira/browse/BEAM-11838 >> [2] https://github.com/benWize/beam/pull/12/files# >> >> >> >> >> >> >> >> >> >> *This email and its contents (including any attachments) are being sent >> toyou on the condition of confidentiality and may be protected by >> legalprivilege. Access to this email by anyone other than the intended >> recipientis unauthorized. If you are not the intended recipient, please >> immediatelynotify the sender by replying to this message and delete the >> materialimmediately from your system. Any further use, dissemination, >> distributionor reproduction of this email is strictly prohibited. Further, >> norepresentation is made with respect to any content contained in this >> email.* > >
