Tag: AMAZON-KINESIS
Estoy trabajando con la aplicación Kinesis usando Flink 1.11, pero obtengo el siguiente error al iniciar mi aplicación: java.util.concurrent.TimeoutException: El heartbeat del TaskManager con id 421563c271e57acb4592f9d447d45b42 ha excedido el tiempo de espera. at org.apache.flink.runtime.resourcemanager.ResourceManager$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(ResourceManager.java:1202) at org.apache.flink.runtime.heartbeat.HeartbeatMonitorImpl.run(HeartbeatMonitorImpl.java:109) at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:402) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:195) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) . . . Read more
Estoy evaluando diferentes servicios de streaming/messaging para utilizar como un bus de eventos. Una de las dimensiones que estoy considerando es la garantía de orden proporcionada por cada uno de los servicios. Dos de las opciones que estoy explorando son AWS Kinesis y Kafka y a un alto nivel, según . . . Read more
Estoy utilizando el siguiente código para descargar el clip. He recibido correctamente la respuesta y estoy intentando descargar el video pero no puedo lograrlo. const completeUrl = url + “/getClip”; const res = await client.post(completeUrl, params, { headers: { “Content-Type”: “video/mp4”, “X-Amz-Target”: “CodeBuild_20161006.StartBuild”, }, }); console.log(“axios signedRquest es “, res); . . . Read more
Tenemos una plantilla SAM de AWS Lambda que ocasionalmente falla durante la creación/actualización del stack de CloudFormation debido a: Se proporcionó una solicitud inválida: Se recibió una excepción mientras se leía desde el flujo proporcionado. Se superó la tasa para el fragmento shardId-000000000000 En la plantilla SAM, se adjuntan 10 . . . Read more
Actualmente estoy desarrollando una aplicación web en ReactJS, donde un usuario puede grabar una sesión con su webcam y transmitirla a la infraestructura de AWS. Me encontré con Amazon Kinesis Video Streams con WebRTC. Al crear un canal de señalización, un usuario puede transmitir esos datos al modelo maestro y . . . Read more