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

[ https://issues.apache.org/jira/browse/BEAM-3858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418409#comment-16418409 ] huangjianhuang commented on BEAM-3858: -- [~jbonofre] any suggestion? > Data from JdbcIO.read() cannot

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

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

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352010#comment-16352010 ] huangjianhuang commented on BEAM-3414: -- [~kenn] Is jstorm-runner released? [Official

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16352008#comment-16352008 ] huangjianhuang commented on BEAM-3414: -- [~aljoscha] thanks, can it be fixed this month? Our project

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16342837#comment-16342837 ] huangjianhuang commented on BEAM-3414: -- [~kenn] [~aljoscha] are you still fixing this issue? I‘m

[jira] [Issue Comment Deleted] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjianhuang updated BEAM-3414: - Comment: was deleted (was: Thanks for help. Does this bug appear in other Runner? Or can you give

[jira] [Commented] (BEAM-3423) Distinct.withRepresentativeValueFn throws CoderException "cannot encode null KV"

[ https://issues.apache.org/jira/browse/BEAM-3423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16319609#comment-16319609 ] huangjianhuang commented on BEAM-3423: -- [~kenn] thx. yes, it does work fine without early firings.

[jira] [Comment Edited] (BEAM-3423) Distinct.withRepresentativeValueFn with EventTime Trigger throws Exceptions

[ https://issues.apache.org/jira/browse/BEAM-3423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315057#comment-16315057 ] huangjianhuang edited comment on BEAM-3423 at 1/7/18 4:05 AM: -- [~kenn] sorry,

[jira] [Commented] (BEAM-3423) Distinct.withRepresentativeValueFn with EventTime Trigger throws Exceptions

[ https://issues.apache.org/jira/browse/BEAM-3423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16315057#comment-16315057 ] huangjianhuang commented on BEAM-3423: -- [~kenn] sorry, I cant understand what you mentioned "relevant

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16314517#comment-16314517 ] huangjianhuang commented on BEAM-3414: -- Thanks for help. Does this bug appear in other Runner? Or can

[jira] [Created] (BEAM-3423) Distinct.withRepresentativeValueFn with EventTime Trigger throws Exceptions

huangjianhuang created BEAM-3423: Summary: Distinct.withRepresentativeValueFn with EventTime Trigger throws Exceptions Key: BEAM-3423 URL: https://issues.apache.org/jira/browse/BEAM-3423 Project:

[jira] [Commented] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

[ https://issues.apache.org/jira/browse/BEAM-3414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16312593#comment-16312593 ] huangjianhuang commented on BEAM-3414: -- the trigger would never fire after 06:34:55.505 if i didnot

[jira] [Created] (BEAM-3414) AfterProcessingTime trigger issue with Flink Runner

huangjianhuang created BEAM-3414: Summary: AfterProcessingTime trigger issue with Flink Runner Key: BEAM-3414 URL: https://issues.apache.org/jira/browse/BEAM-3414 Project: Beam Issue Type:

[jira] [Closed] (BEAM-3390) unable to serialize org.apache.beam.sdk.io.jdbc.JdbcIO$Read$ReadFn

[ https://issues.apache.org/jira/browse/BEAM-3390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huangjianhuang closed BEAM-3390. Resolution: Not A Problem Fix Version/s: 2.1.0 sorry, it is my mistake, not an issue. i put

[jira] [Created] (BEAM-3390) unable to serialize org.apache.beam.sdk.io.jdbc.JdbcIO$Read$ReadFn

huangjianhuang created BEAM-3390: Summary: unable to serialize org.apache.beam.sdk.io.jdbc.JdbcIO$Read$ReadFn Key: BEAM-3390 URL: https://issues.apache.org/jira/browse/BEAM-3390 Project: Beam

[jira] [Created] (BEAM-3002) Unable to provide a Coder for org.apache.hadoop.hbase.client.Mutation

huangjianhuang created BEAM-3002: Summary: Unable to provide a Coder for org.apache.hadoop.hbase.client.Mutation Key: BEAM-3002 URL: https://issues.apache.org/jira/browse/BEAM-3002 Project: Beam

[jira] [Commented] (BEAM-2995) can't read/write hdfs in Flink CLUSTER(Standalone)

[ https://issues.apache.org/jira/browse/BEAM-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16184216#comment-16184216 ] huangjianhuang commented on BEAM-2995: -- yes, i've read BEAM-2457 before, and tried what you suggested

[jira] [Commented] (BEAM-2995) can't read/write hdfs in Flink CLUSTER(Standalone)

[ https://issues.apache.org/jira/browse/BEAM-2995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16183553#comment-16183553 ] huangjianhuang commented on BEAM-2995: -- by the way, my pom.xml is: {code:java} com.joe

[jira] [Created] (BEAM-2995) can't read/write hdfs in Flink CLUSTER(Standalone)

huangjianhuang created BEAM-2995: Summary: can't read/write hdfs in Flink CLUSTER(Standalone) Key: BEAM-2995 URL: https://issues.apache.org/jira/browse/BEAM-2995 Project: Beam Issue Type: