[ https://issues.apache.org/jira/browse/BEAM-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Beam JIRA Bot reassigned BEAM-3858: ----------------------------------- Assignee: (was: Thomas Weise) > 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: runner-apex > Affects Versions: 2.3.0 > Environment: ubuntu16.04 > Reporter: huangjianhuang > Priority: P2 > Labels: stale-assigned > > {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 (v8.3.4#803005)