как избежать задержки запроса данных в ящике

версия ящика: 1.1.3 после вставки данных в ящик я отправляю ключ в activemq для немедленного запроса этих данных, но, к сожалению, каждый раз это не удавалось, поэтому я приостанавливаю поток на 2000 мс, он работал, поэтому я думаю, что кластеру нужно некоторое время для синхронизации данных вот crate.yaml:

psql.enabled: true
psql.port: 33892
prepareThreshold: 0

http.max_content_length: 150mb
indices.store.throttle.max_bytes_per_sec: 150mb
threadpool.bulk.type: fixed
threadpool.bulk.size: 128
threadpool.bulk.queue_size: 5000

cluster.name: EIn_Cluster
node.name: dscn1
index.number_of_replicas: 2
path.conf: /home/hadmin/crate/config
path.data: /home/hadmin/data/crate
path.work: /home/hadmin/data/crate/tmp
path.logs: /home/hadmin/data/crate/logs
path.plugins: /home/hadmin/crate/plugins
blobs.path: /home/hadmin/data/crate/crate_blob_data/disk
network.host: 192.168.13.50
gateway.recover_after_nodes: 3
discovery.zen.minimum_master_nodes: 3
gateway.expected_nodes: 3
discovery.zen.ping.timeout: 10s
discovery.zen.fd.ping_interval: 10s
#transport.tcp.port: 4399
discovery.zen.ping.unicast.hosts:
  - dscn1:4300
  - dscn2:4300
  - dscn3:4300

это связано с настройкой нескольких зон? или я пропускаю какие-то настройки? как этого избежать

спасибо


person MayI    schedule 15.05.2017    source источник
comment
Это кластер из 3 узлов, я думаю, это не имеет никакого отношения к зоне   -  person MayI    schedule 15.05.2017


Ответы (1)


Поскольку ящик в конечном итоге непротиворечив, не все вставленные документы сразу доступны для запроса. Доступность новых/измененных документов зависит от различных факторов, самым важным из которых является настроенный refresh_interval (см. https://crate.io/docs/reference/sql/reference/create_table.html#sql-ref-refresh-interval). Но имейте в виду, что уменьшение этого значения приведет к снижению производительности приема.

Вы также можете принудительно обновить с помощью команды refresh table, см. https://crate.io/docs/reference/sql/refresh.html, что является рекомендуемым способом, если вставка не происходит постоянно (например, обновление после завершения вставки перед выполнением следующего оператора).

person Sebastian Utz    schedule 15.05.2017
comment
обратите внимание, что доступ к отдельным записям по первичному ключу будет работать немедленно. согласованность чтения после записи - person Jodok Batlogg; 16.05.2017