Resultados de la búsqueda a petición "distributed"
¿Cómo maneja la balsa la confirmación de entradas de la anterior?
En balsapapel [https://raft.github.io/raft.pdf]sección 5.4.2 Si un líder falla antes de cometer una entrada, los futuros líderes intentarán terminar de replicar la entrada. Sin embargo, un líder no puede concluir de inmediato que una entrada de ...
En C #, si 2 procesos leen y escriben en el mismo archivo, ¿cuál es la mejor manera de evitar excepciones de bloqueo de procesos?
Con el siguiente código de lectura de archivo: using (FileStream fileStream = new FileStream(fileName, FileMode.Open, FileAccess.Read, FileShare.None)) { using (TextReader tr = new StreamReader(fileStream)) { string fileContents = ...
Spark Streaming Recuento acumulado de palabras
Este es un programa de transmisión por chispa escrito en scala. Cuenta la cantidad de palabras de un socket en cada 1 segundo. El resultado sería el recuento de palabras, por ejemplo, el recuento de palabras del tiempo 0 al 1, y el recuento de ...
¿Existe un caso de uso para la recepción sin bloqueo cuando tengo hilos?
Sé que la recepción sin bloqueo no se usa tanto en el paso de mensajes, pero aún así, una cierta intuición me dice que es necesaria. Tomemos, por ejemplo, las aplicaciones guiadas por eventos GUI, necesita alguna forma de esperar un mensaje sin ...
El bloqueo proporcionado no es válido. O el bloqueo expiró o el mensaje ya se eliminó de la cola
Estoy usando una cola de bus de servicio azul de Microsoft para procesar los cálculos y mi programa funciona bien durante unas horas, pero luego empiezo a recibir esta excepción para cada mensaje que proceso a partir de ese momento. No tengo idea ...
caché de clave / valor tipo memcached que usa RAM y disco [cerrado]
Tengo una aplicación web de Java que hace uso de back-end de un servicio web de terceros. Llamar al servicio web crea latencia, lo cual es importante evitar siempre que sea posible. Además, mi aplicación solo tiene permitido realizar una cierta ...
Emulación de desconexiones de red para probar localmente la partición distribuida de aplicaciones
Tengo varias instancias de una aplicación distribuida que se ejecuta en el host local; cada instancia se comunica con otros a través de ciertos puertos, todas las instancias juntas forman un conjunto. (En realidad estoy hablando de ZooKeeper ...
FileNotFoundException cuando se usa la caché distribuida de Hadoop
esta vez, alguien debería volver a repetir que estoy luchando con ejecutar mi código usando cahe distribuido. Ya tengo los archivos en hdfs pero cuando ejecuto este código: import java.awt.image.BufferedImage; import ...
¿Cómo se distribuye Erlang escalable?
Parte A: Erlang tiene muchas historias de éxito sobre la ejecución de agentes concurrentes, p. Los millones de chats simultáneos en Facebook. Son millones de agentes, pero por supuesto no son millones de CPU en una red. Tengo problemas para ...
Qué registros de procesos distribuidos están disponibles para Erlang?
Me gustaría compilar una lista razonablemente completa de bibliotecas de registro de procesos distribuidos para Erlang. ales bibliotecas necesitan soportar operaciones básicas comoregister_name(Pid, Name) ywhereis_name(Name) (e ...