[
https://issues.apache.org/jira/browse/BEAM-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16401085#comment-16401085
]
Jean-Baptiste Onofré commented on BEAM-3858:
--------------------------------------------
Let me investigate to identify if the issue is in the IO or actually in the
runner (in the DoFn support).
> 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é
> Priority: Major
>
> {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)
