[BEAM-3858] Data from JdbcIO.read() cannot pass to next transform on ApexRunner

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Affects Version/s: 2.3.0
• Fix Version/s: Missing
• Component/s: runner-apex
• Environment: ubuntu16.04
• Assignee: Unassigned
• Reporter: huangjianhuang
• Created: 15/Mar/18 03:17
• Updated: 13/Jan/22 21:52
• Resolved: 15/May/21 17:58

Description

public static void testJDBCRead(Pipeline pipeline) {
    System.out.println("in testJDBCRead()");
    pipeline.apply(JdbcIO.<String>read()
            .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(
                    "com.mysql.jdbc.Driver", "jdbc:mysql://localhost:3307/libra")
                    .withUsername("root")
                    .withPassword("123456"))
            .withQuery("SELECT * FROM o_flow_account_login limit 3")
            .withCoder(StringUtf8Coder.of())
            .withRowMapper(new JdbcIO.RowMapper<String>() {
                public String mapRow(ResultSet resultSet) throws Exception {
                    System.out.println("maprow");
                    return "tmp";
                }
            })

    )

            .apply(ParDo.of(new DoFn<String, String>() {
                        @ProcessElement
                        public void process(ProcessContext context) {
                            System.out.println("??");
                            context.output(" ");
                        }
                    }));
}

On DirectRunner or FlinkRunner, screen shows:

maprow
maprow
maprow
??
??
??

however on ApexRunner, screen only shows:

maprow
maprow
maprow