huangjianhuang created BEAM-3858: ------------------------------------ Summary: Data from JdbcIO.read() cannot pass to next transform on ApexRunner Key: BEAM-3858 URL: https://issues.apache.org/jira/browse/BEAM-3858 Project: Beam Issue Type: Bug Components: io-java-jdbc, runner-apex Affects Versions: 2.3.0 Environment: ubuntu16.04 Reporter: huangjianhuang Assignee: Jean-Baptiste Onofré
{code:java} 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(" "); } })); } {code} On DirectRunner or FlinkRunner, screen shows: {code:java} maprow maprow maprow ?? ?? ?? {code} however on ApexRunner, screen only shows: {code:java} maprow maprow maprow {code} -- This message was sent by Atlassian JIRA (v7.6.3#76005)