[
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
[
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
[
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
[
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
[
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}
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
>
[
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
>
[
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
>
[
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
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
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
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
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:
[
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,
[
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
[
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
[
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
[
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
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
[
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:
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:
28 matches
Mail list logo