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

["Ismaël Mejía (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ismaël Mejía reassigned BEAM-3858:
----------------------------------

    Assignee: Thomas Weise  (was: Jean-Baptiste Onofré)

> 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
>            Assignee: Thomas Weise
>            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)