2016-08-29 2 views
0

2つのバッチsym_outgoing_batchでメッセージと(この-1手段何?)node_idの1 000(コープ)は、別の-1である私が社に店から多くのデータを引き出しています。データの一部が適時にルータに送信されますが、他のものは遅延されます。次のようなメッセージは次のとおりです。 enter image description hereSymmetricDSはsym_outgoing_batch.node_id = -1

と、次のように設定ファイルは次のとおりです。

insert into sym_channel(channel_id, processing_order, max_batch_size, enabled, description) 

    values('sale_channel', 1, 1000000, 1, 'sale data from store to corp'); 

insert into sym_trigger(trigger_id, source_table_name, channel_id, last_update_time, create_time) 

    values('sale_pay_triger', 'D_T_BILL_PAY', 'sale_channel', current_timestamp, current_timestamp); 

insert into sym_router(router_id, source_node_group_id, target_node_group_id, router_type,router_expression, create_time, last_update_time) 

    values('store_2_corp_sheftnotnull', 'store', 'corp', 'bsh', 'CSHIFT_C!=null && !CSHIFT_C.equals("")',current_timestamp, current_timestamp); 

insert into sym_trigger_router(trigger_id, router_id, initial_load_order, last_update_time, create_time) 

    values('sale_pay_triger', 'store_2_corp_sheftnotnull', 1, current_timestamp, current_timestamp); 

insert into SYM_CONFLICT(CONFLICT_ID,SOURCE_NODE_GROUP_ID,TARGET_NODE_GROUP_ID,DETECT_TYPE,RESOLVE_TYPE,PING_BACK,CREATE_TIME,LAST_UPDATE_TIME) 

    values('conflict_fallback', 'corp', 'store', 'USE_PK_DATA', 'FALLBACK', 'OFF', current_timestamp, current_timestamp); 
commit; 
+0

あなたのご質問はありますか? –

+0

なぜそれが遅れてこの問題を解決する方法。 – YunShu

+0

遅れているものは? –

答えて

1

あなたが-1の平均NODE_IDを何求めている場合。これは、データがルーティングされていないことを意味します。ルーティング条件を満たすノードはありませんでした。

+0

しかし、いくつかのデータはスクリーンショットショーと同時に同じマシン上で成功しています – YunShu

関連する問題