Описание тега distributed-cache

Используйте этот тег для вопросов, связанных с DistributedCache; средство, предоставляемое платформой Map-Reduce для кэширования файлов (текста, архивов, jar-файлов и т. д.), необходимых приложениям.
1 ответ

FileNotFoundException при использовании DistributedCache для доступа к MapFile

Я использую hadoop cdf4.7 запустить в режиме пряжи. В MapFile есть hdfs://test1:9100/user/tagdict_builder_output/part-00000и у него есть два файла index а также data Я использовал следующий код, чтобы добавить его в distribCache: Configuration conf …
1 ответ

Что такое SlidingExpiration Timespan в Dache?

Что такое SlidingExpiration Временной интервал в методе AddOrUpdate в Dache, точно?Это лучше использовать SlidingExpiration или же AbsoluteExpiration, Я имею в виду, в чем различия?
1 ответ

Jar распределенного кэша в classpath, но получает ClassNotFoundException

Используя HBaseTestingUtility, я бы запустил мини-кластер. testUtil = new HBaseTestingUtility(configuration); testUtil.startMiniCluster(); и предоставить мою банку для размещения в classpath DistributedCache final String aJarResourcePath = Thread.cu…
13 фев '16 в 00:16
0 ответов

Распределенный кеш с Pig и Python

Я знаю, что есть много ресурсов для использования распределенного кэша в сценариях Pig с Java-udfs. Но я не нашел ничего такого, что могло бы объяснить то же самое с помощью python udfs. Кроме того, я не нашел подробного объяснения использования рас…
30 июл '15 в 07:26
1 ответ

Hazelcast SlowOperationDetector для идентификации операций с временем выполнения менее 1 секунды

У меня есть сценарий использования производительности, по которому мне нужно определить определенные process() звонки в EntryProcessor что занимает более 300 миллисекунд. Я пытался использовать SlowOperationDetector со следующей конфигурацией. <!…
3 ответа

Повторное использование файлов в распределенном кэше Hadoop

Мне интересно, если кто-то может объяснить, как распределенный кеш работает в Hadoop. Я выполняю задание много раз, и после каждого запуска я замечаю, что размер папки локального распределенного кэша на каждом узле увеличивается. Есть ли способ для …
30 авг '13 в 17:18
1 ответ

Распределенный кеш с Hazelcast

Я хочу проверить функциональность распределенного кэширования с помощью Hazelcast с Hibernate. Hazelcast предоставил интеграцию с Hibernate для кэша второго уровня. Как мы можем проверить функциональность распределенного кэша hazelcast с помощью Hib…
30 июн '14 в 06:09
1 ответ

Распределенный кэш пряжи, без картографа / редуктора

Я не могу получить доступ к файлам в распределенном кеше в hadoop 2.6. Ниже приведен фрагмент кода. Я пытаюсь разместить файл pattern.properties, который в args[0] в распределенном кеше пряжи Configuration conf1 = new Configuration(); Job job = Job.…
1 ответ

Чтение файла внутри драйвера Hadoop

Можно ли прочитать файл в распределенном кеше внутри драйвера Hadoop? Я реализовал инструмент Inteface, и я использую -files для добавления файла в распределенный кеш. Или этот файл будет скопирован в распределенный кеш после того, как я начну свою …
11 авг '15 в 20:13
1 ответ

Карта мира HazelCast со слушателем

С Hazelcast, я предполагаю, что общий сценарий состоит в том, что потребители хотят знать о текущем состоянии мира (то, что когда-либо в настоящее время находится на карте), а затем обновляются, ничего не потеряв между ними. Представьте себе сценари…
27 апр '17 в 10:10
1 ответ

Как hazelcast выполняет вытеснение записи карты, с точки зрения ее потоковой модели?

Я это понимаю <min-eviction-check-millis> в конфигурации hazelcast определяет минимальное время в миллисекундах, которое должно пройти перед проверкой, является ли раздел этой карты выполнимым или нет. Таким образом, в течение каждого настроен…
1 ответ

Hadoop NoClassDefFoundError при добавлении внешнего Jar

Я пытаюсь запустить задание MapReduce на Hadoop с помощью внешнего Jar-файла. Я добавил банку в HDFS, используя copyFromLocal в /user/hduser/lib/, В моем основном методе я добавляю Jar в DistributedCache. Однако, когда я запускаю программу MapReduce…
1 ответ

Ошибка службы распределенного кэша

Я установил Automation Anywhere controlroom и при входе в систему я получаю сообщение об ошибке: "Служба распределенного кэша имеет проблемы. Пожалуйста, свяжитесь с администратором" Как я могу отладить / исправить это?
12 дек '17 в 09:11
0 ответов

Распределенный кэш SharePoint выдает ошибки "Ссылка на объект не установлена ​​на экземпляр объекта"

Я возвращаюсь к вам по вопросу, для которого я действительно не могу найти никаких решений, несмотря на то, что потратил несколько дней на то, чтобы безуспешно протестировать решения с разных сайтов. У меня проблема с распределенным кешем SharePoint…
01 фев '19 в 08:07
2 ответа

Hadoop: Когда метод настройки вызывается в редукторе?

Насколько я понимаю, задача сокращения состоит из трех этапов. Shuffle, Sort и фактическое сокращение вызова. Поэтому обычно в выводе задания hadoop мы видим что-то вроде: карта 0% уменьшает 0%, карта 20% уменьшает 0% .,, карта на 90% уменьшает на 1…
08 дек '14 в 18:49
1 ответ

Redis 3.0 для приложения.NET

Могу ли я использовать Redis 3.0 для своего веб-сайта ASP.NET? Redis 3.0 как распределенный кэш в Linux и мой сайт в ASP.NET 4.5, имеет ли это смысл?
21 сен '15 в 19:43
1 ответ

Доступ к распределенному кешу в Pig StoreFunc

Я просмотрел все остальные темы по этой теме и до сих пор не нашел ответа... Проще говоря, я хочу получить доступ к распределенному кешу hadoop из Pig StoreFunc, а НЕ из UDF напрямую. Соответствующие строки кода PIG: DEFINE CustomStorage KeyValStora…
28 авг '14 в 18:08
1 ответ

Hadoop DistributedCache - FileNotFound

Я пытаюсь поместить файл в распределенный кеш. Для этого я вызываю свой класс драйвера, используя опцию -files, что-то вроде: hadoop jar job.jar my.driver.class -files MYFILE input output getCacheFiles() и getLocalCacheFiles() возвращать массивы URI…
1 ответ

Распределенная блокировка Hazelcast с использованием nodejs

У меня кластерный сервер Hazelcast работает на 172.30.56.60, 61, 62 (то есть) [ Member { address: Address { host: '172.30.56.60', port: 5701, type: 4 }, uuid: 'bd6428f0-e888-453f-872f-6fe8296d751d', isLiteMember: false, attributes: {} }, Member { ad…
0 ответов

Как решить проблему параллелизма при переименовании папки в hdfs и загрузке в Dist Cache в hadoop

У меня есть случай, когда я меняю папку для ввода, переименовывая папку ввода во временную папку, а затем переименовывая целевую папку в папку ввода. Тем временем кто-то загружает все файлы из этой входной папки в распределенный кеш. Как это повлияе…
22 сен '17 в 10:52