[jira] [Comment Edited] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-07-30 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561536#comment-16561536 ] Rick Lin edited comment on BEAM-4632 at 7/30/18 8:16 AM: - Hi [~aromanenko], For

[jira] [Comment Edited] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-07-30 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561536#comment-16561536 ] Rick Lin edited comment on BEAM-4632 at 7/30/18 7:00 AM: - Hi [~aromanenko], For

[jira] [Comment Edited] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-07-30 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561536#comment-16561536 ] Rick Lin edited comment on BEAM-4632 at 7/30/18 7:00 AM: - Hi [~aromanenko], For

[jira] [Comment Edited] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-07-30 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561540#comment-16561540 ] Rick Lin edited comment on BEAM-4632 at 7/30/18 6:56 AM: - By the way, my

[jira] [Commented] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-07-30 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561540#comment-16561540 ] Rick Lin commented on BEAM-4632: By the way, my configuration setting of kafka broker is:   {code:java}

[jira] [Commented] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-07-30 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16561536#comment-16561536 ] Rick Lin commented on BEAM-4632: Hi [~aromanenko], For the last question, i only change settings of the

[jira] [Comment Edited] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-27 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524674#comment-16524674 ] Rick Lin edited comment on BEAM-4632 at 6/27/18 7:04 AM: - Dear [~aromanenko], I

[jira] [Commented] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-27 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524674#comment-16524674 ] Rick Lin commented on BEAM-4632: Dear [~aromanenko], I have tried running my project with Spark runner

[jira] [Updated] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-27 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-4632: --- Attachment: error UnboundedDataset.java 81(0) has different number of partitions.JPG > KafkaIO seems to fail

[jira] [Comment Edited] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-27 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524523#comment-16524523 ] Rick Lin edited comment on BEAM-4632 at 6/27/18 6:25 AM: - Dear all, Thanks very

[jira] [Commented] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-26 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16524523#comment-16524523 ] Rick Lin commented on BEAM-4632: Dear all, Thanks very much for your attention to this problem.   Hi

[jira] [Updated] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-26 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-4632: --- Attachment: .withMaxNumRecords(50).JPG > KafkaIO seems to fail on streaming mode over spark runner >

[jira] [Updated] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-26 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-4632: --- Attachment: DB_table_kafkabeamdata_count.JPG > KafkaIO seems to fail on streaming mode over spark runner >

[jira] [Updated] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-26 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-4632: --- Attachment: the error GeneratedMessageV3.JPG > KafkaIO seems to fail on streaming mode over spark runner >

[jira] [Updated] (BEAM-4632) KafkaIO seems to fail on streaming mode over spark runner

2018-06-26 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-4632: --- Attachment: the error GeneratedMessageV3.JPG > KafkaIO seems to fail on streaming mode over spark runner >

[jira] [Updated] (BEAM-4631) kafkIO should run the streaming mode over spark runner

2018-06-24 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-4631: --- Summary: kafkIO should run the streaming mode over spark runner (was: kafkIO should be the streaming mode

[jira] [Created] (BEAM-4632) kafkIO should be the streaming mode over spark runner

2018-06-23 Thread Rick Lin (JIRA)
Rick Lin created BEAM-4632: -- Summary: kafkIO should be the streaming mode over spark runner Key: BEAM-4632 URL: https://issues.apache.org/jira/browse/BEAM-4632 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-4631) kafkIO should be the streaming mode over spark runner

2018-06-23 Thread Rick Lin (JIRA)
Rick Lin created BEAM-4631: -- Summary: kafkIO should be the streaming mode over spark runner Key: BEAM-4631 URL: https://issues.apache.org/jira/browse/BEAM-4631 Project: Beam Issue Type: Bug

[jira] [Created] (BEAM-3770) The problem of kafkaIO sdk for data latency

2018-03-01 Thread Rick Lin (JIRA)
Rick Lin created BEAM-3770: -- Summary: The problem of kafkaIO sdk for data latency Key: BEAM-3770 URL: https://issues.apache.org/jira/browse/BEAM-3770 Project: Beam Issue Type: Improvement

[jira] [Created] (BEAM-3210) The problem about the use of waitUntilFinish() in DirectRunner

2017-11-16 Thread Rick Lin (JIRA)
Rick Lin created BEAM-3210: -- Summary: The problem about the use of waitUntilFinish() in DirectRunner Key: BEAM-3210 URL: https://issues.apache.org/jira/browse/BEAM-3210 Project: Beam Issue Type:

[jira] [Commented] (BEAM-3073) Connect to Apache ignite via JdbcIO sdk

2017-10-20 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16212248#comment-16212248 ] Rick Lin commented on BEAM-3073: Hi, In my opinion: * The JDBC driver, org.apache.ignite.IgniteJdbcDriver,

[jira] [Commented] (BEAM-3073) Connect to Apache ignite via JdbcIO sdk

2017-10-19 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16212010#comment-16212010 ] Rick Lin commented on BEAM-3073: Hi, Apache Ignite is similar to Redis or Hazelcast (in-memory key-value

[jira] [Comment Edited] (BEAM-3073) Connect to Apache ignite via JdbcIO sdk

2017-10-18 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208867#comment-16208867 ] Rick Lin edited comment on BEAM-3073 at 10/18/17 7:02 AM: -- There are details about

[jira] [Commented] (BEAM-3073) Connect to Apache ignite via JdbcIO sdk

2017-10-18 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16208867#comment-16208867 ] Rick Lin commented on BEAM-3073: There are details about my run environment *OS:* Distributor ID: Ubuntu

[jira] [Updated] (BEAM-3073) Connect to Apache ignite via JdbcIO sdk

2017-10-17 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-3073: --- Description: Hi all, {color:#14892c}I tried to connect Apache Ignite(In-memory) via the beam's

[jira] [Created] (BEAM-3073) Connect to Apache ignite via JdbcIO sdk

2017-10-17 Thread Rick Lin (JIRA)
Rick Lin created BEAM-3073: -- Summary: Connect to Apache ignite via JdbcIO sdk Key: BEAM-3073 URL: https://issues.apache.org/jira/browse/BEAM-3073 Project: Beam Issue Type: New Feature

[jira] [Updated] (BEAM-2952) How to use KV.OrderByKey

2017-10-17 Thread Rick Lin (JIRA)
[ https://issues.apache.org/jira/browse/BEAM-2952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rick Lin updated BEAM-2952: --- Priority: Minor (was: Major) > How to use KV.OrderByKey > > > Key:

[jira] [Created] (BEAM-2952) How to use KV.OrderByKey

2017-09-12 Thread Rick Lin (JIRA)
Rick Lin created BEAM-2952: -- Summary: How to use KV.OrderByKey Key: BEAM-2952 URL: https://issues.apache.org/jira/browse/BEAM-2952 Project: Beam Issue Type: New Feature Components: