diff --git a/src/riak_kv_wterl_backend.erl b/src/riak_kv_wterl_backend.erl index 640779c..eab5a7b 100644 --- a/src/riak_kv_wterl_backend.erl +++ b/src/riak_kv_wterl_backend.erl @@ -103,7 +103,10 @@ start(Partition, Config) -> {ok, ConnRef} -> Table = "table:wt" ++ integer_to_list(Partition), {ok, SRef} = wterl:session_open(ConnRef), - ok = wterl:session_create(SRef, Table), + %% TODO: should check return value here, but we + %% currently get an error when the table already + %% exists, so for now we ignore it. + wterl:session_create(SRef, Table), {ok, #state{conn=ConnRef, table=Table, session=SRef,