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)
