[
https://issues.apache.org/jira/browse/FLINK-3311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15327219#comment-15327219
]
ASF GitHub Bot commented on FLINK-3311:
---------------------------------------
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/1771
The merging will probably be a bit delayed because there are some memory
issues:
```
-------------------------------------------------------
T E S T S
-------------------------------------------------------
Running
org.apache.flink.streaming.connectors.cassandra.CassandraConnectorTest
06/13/2016 11:12:22 Job execution switched to status RUNNING.
06/13/2016 11:12:22 Source: Collection Source -> Sink: Unnamed(1/1)
switched to SCHEDULED
06/13/2016 11:12:22 Source: Collection Source -> Sink: Unnamed(1/1)
switched to DEPLOYING
06/13/2016 11:12:23 Source: Collection Source -> Sink: Unnamed(1/1)
switched to RUNNING
06/13/2016 11:12:27 Source: Collection Source -> Sink: Unnamed(1/1)
switched to FINISHED
06/13/2016 11:12:27 Job execution switched to status FINISHED.
Exception: java.lang.OutOfMemoryError thrown from the
UncaughtExceptionHandler in thread "CompactionExecutor:2"
Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 150.02 sec
- in org.apache.flink.streaming.connectors.cassandra.CassandraConnectorTest
Exception: java.lang.OutOfMemoryError thrown from the
UncaughtExceptionHandler in thread "main"
Exception: java.lang.OutOfMemoryError thrown from the
UncaughtExceptionHandler in thread "CompactionExecutor:5"
Exception: java.lang.OutOfMemoryError thrown from the
UncaughtExceptionHandler in thread "CompactionExecutor:4"
Exception: java.lang.OutOfMemoryError thrown from the
UncaughtExceptionHandler in thread "HintedHandoffManager:1"
Exception: java.lang.OutOfMemoryError thrown from the
UncaughtExceptionHandler in thread "CompactionExecutor:7"
==============================================================================
Maven produced no output for 300 seconds.
==============================================================================
==============================================================================
The following Java processes are running (JPS)
==============================================================================
2956 Launcher
98454 Jps
97148 surefirebooter7601064672285446339.jar
==============================================================================
Printing stack trace of Java process 2956
==============================================================================
2016-06-13 11:28:23
Full thread dump Java HotSpot(TM) 64-Bit Server VM (24.76-b04 mixed mode):
```
I will take care of them!
> Add a connector for streaming data into Cassandra
> -------------------------------------------------
>
> Key: FLINK-3311
> URL: https://issues.apache.org/jira/browse/FLINK-3311
> Project: Flink
> Issue Type: New Feature
> Components: Streaming Connectors
> Reporter: Robert Metzger
> Assignee: Andrea Sella
>
> We had users in the past asking for a Flink+Cassandra integration.
> It seems that there is a well-developed java client for connecting into
> Cassandra: https://github.com/datastax/java-driver (ASL 2.0)
> There are also tutorials out there on how to start a local cassandra instance
> (for the tests):
> http://prettyprint.me/prettyprint.me/2010/02/14/running-cassandra-as-an-embedded-service/index.html
> For the data types, I think we should support TupleX types, and map standard
> java types to the respective cassandra types.
> In addition, it seems that there is a object mapper from datastax to store
> POJOs in Cassandra (there are annotations for defining the primary key and
> types)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
