[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r194921655 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r194921578 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r194920693 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r193901095 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r193899502 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r193899502 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r193865469 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r191919502 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r191030350 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java

[GitHub] jerrypeng commented on a change in pull request #1845: Functions schema integration

jerrypeng commented on a change in pull request #1845: Functions schema integration URL: https://github.com/apache/incubator-pulsar/pull/1845#discussion_r191030390 ## File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java