Описание тега rebalancing
2
ответа
Перебалансирование портфеля с учетом веса
Учитывая, что у меня есть ежемесячные веса для использования в портфеле, но я хочу перебалансировать свой портфель, скажем, ежеквартально. Как я могу создать функцию, которая вычитает веса только каждый квартал из моих первоначальных месячных весов,…
09 июл '18 в 12:52
1
ответ
Kubernetes - инициирует восстановление баланса стручков
У меня есть кластер kubernetes с несколькими настроенными узлами. Я хочу убедиться, что стручки эффективно распределены по узлам. Я объясню: Давайте предположим, что у меня есть два узла: Node 1 - 2gb ram Node 2 - 2gb ram И у меня есть эти стручки: …
31 авг '18 в 00:01
0
ответов
Код вставки красно-черного дерева
Я пытаюсь написать реализацию красно-черного дерева для своего собственного обучения, и я смотрю на это уже несколько дней. Может ли кто-нибудь помочь мне выяснить, как я могу заставить дела с двойным вращением работать правильно? Если вы замечаете …
18 июл '17 в 11:42
3
ответа
Потребительский баланс при использовании автокоммитов
Мы используем потребительский клиент kafka 0.10.2.0 со следующей конфигурацией: props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true"); props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); props.put(ConsumerConfig.AUTO_COMMIT_INTERVA…
11 фев '18 в 16:56
2
ответа
H2O - классы баланса - перекрестная проверка
Я хотел бы построить модель GBM с H2O. Мой набор данных несбалансирован, поэтому я использую параметр balance_classes. Для поиска по сетке (настройки параметров) я хотел бы использовать 5-кратную перекрестную проверку. Мне интересно, как H2O справля…
15 фев '18 в 10:32
1
ответ
Неравномерное разбиение данных в Apache Ignite 2.4 приводит к тому, что узлам не хватает памяти и происходит сбой
Среда: Apache Ignite 2.4 работает на Amazon Linux. VM составляет 16CPUs/122 ГБ оперативной памяти. Там много места. 5 узлов по 12 ГБ каждый cacheMode = PARTITIONED backups = 0 OnheapCacheEnabled = true atomicityMode = ATOMIC rebalacneMode = SYNC reb…
08 май '18 в 23:41
1
ответ
Кафка ребалансировки и подводные камни для слушателей
Я читаю "Кафку: полное руководство" и хотел бы лучше понять слушателя с перебалансировкой. Пример в книге простой использует HashMap сохранить текущие смещения, которые были обработаны и будут фиксировать текущее состояние при отзыве раздела. Мои оп…
11 апр '18 в 17:58
0
ответов
Сбой перебалансировки кластера Redis при попытке отгородиться от большого количества узлов
redis версия 3.2.10, 4.0.6 redis gem версия 3.3.3 Я вижу сбой команды rebalance при удалении слотов от узлов в кластере Redis с 60 узлами (без репликации), ошибка: ... Moving 95 slots from 172.31.5.105:6379 to 172.31.10.118:6379 ####################…
18 янв '18 в 10:22
7
ответов
Как проверить, готов ли Kafka Consumer
У меня есть политика фиксации Kafka, установленная на последние и пропущенные первые несколько сообщений. Если перед отправкой сообщений в тему ввода я поспал 20 секунд, все работает как надо. Я не уверен, что проблема в том, что потребителю требует…
03 янв '18 в 06:03
0
ответов
Функция ранжирования со свинцом (изменение баланса акций)
У меня есть следующая функция set.seed(101) RankRB <- function(x) { r <- as.xts(t(apply(-x, 1, rank, na.last = "keep"))) return(r) } который вычисляет ранжирование доходности активов (1 = наибольшая доходность) и возвращает матрицу рангов, под…
23 ноя '17 в 17:56
0
ответов
Spark-Streaming-Kafka: перебалансировка разделов после использования Assign для поиска последнего смещения
У меня есть три задания Spark Streaming, которые используют ConsumerStrategies.Assign[]() искать последнее смещение, которое было зафиксировано в базе данных. Каждое из этих заданий выполняет чтение из одного из трех разделов в теме (например, разде…
15 мар '18 в 00:54
1
ответ
Перебалансировка couchbase завершилась с ошибкой - Перебалансировка завершена с причиной {сбой, сбой}
Я настраиваю кластер. Я попытался соединить 3 узла, но пока что балансировал. Я получил ниже ошибки. Поэтому я извлек некоторую информацию из debug.log и не смог определить точную проблему. Ценю любую помощь. =========================CRASH REPORT===…
12 фев '18 в 20:17
0
ответов
Java KafkaConsumer Poll не работает - постоянно обнаруживает, отмечает и повторно присоединяется
Мой клиент KafkaConsumer не может получить записи из моего кластера Kafka, размещенного на AWS. У меня есть KafkaProducer с той же конфигурацией, что и у потребителя, и я могу успешно отправить событие в кластер Kafka. Мой потребитель непрерывно рег…
21 ноя '17 в 10:46
1
ответ
Как передать связанное с бизнес-логикой состояние между экземплярами Apache Helix?
Может ли Apache Helix сбалансировать данные между узлами? Например, я разрабатываю базу данных в памяти, где некоторые разделенные / сегментированные данные необходимо переместить на другой узел. Является ли обмен сообщениями или хранилище свойств п…
20 окт '18 в 15:20
0
ответов
Потребитель Kafka терпит неудачу при смещении и перебалансировке
У меня есть потребитель Kafka, который подписан только на одну тему. В определенный момент после правильной работы я получаю следующие сообщения в своих журналах: Line 25694: 2017-05-15 17:59:53.656 [INFO ] [MeasureConsumerExecutor] AbstractCoordina…
15 май '17 в 17:03
0
ответов
Тестирование и ребалансирование портфеля с использованием Python
Приведенный ниже код, использующий [пакет BT][1], принимает код запаса, дату начала и окончания, перебалансирует указанную частоту и добавляет результаты, прошедшие тестирование. Но я бы хотел добавить пороговое условие. То есть, например, если я уп…
13 дек '17 в 13:01
0
ответов
Кафка 0.10.1.0 проблема перебалансировки нескольких групп потребителей
В настоящее время я сталкиваюсь с проблемой восстановления баланса Кафки, которая занимает много времени и застревает, и poll() на потребителя блокируется. Я использую 3 группы потребителей Kafka для 3 различных типов шаблонов, на которые я подписыв…
27 май '17 в 17:34
2
ответа
Разъем Kafka - не может остановить перебалансировку
Я использую Kafka Connector Confluent 3.0.1 версии. Я создаю новую группу с именем new-group и в ней около 20 тем. Большинство из этих тем заняты. Но очень жаль, что когда я запускаю фреймворк коннектора, система не может остановить балансировку, ок…
03 янв '17 в 14:07
2
ответа
Почему новый сервер региона HBase не может получить назначенные регионы?
Когда я добавил новый сервер региона в кластер HBase, никакие регионы не были назначены этому новому серверу региона. Новый сервер региона теперь присутствует в веб-интерфейсе, но его номер. Области и количество запросов в секунду равны нулю в соотв…
11 май '18 в 07:26
1
ответ
Балансировщик ресурсов Service Fabric использует устаревшую сообщаемую нагрузку
Изучая балансировщик ресурсов и показатели динамической нагрузки в Service Fabric, мы столкнулись с некоторыми вопросами (Запуск devbox SDK GA 2.0.135).В обозревателе Service Fabric (портале и автономном приложении) мы видим, что балансировка выполн…
07 апр '16 в 09:47