检查我是否用所有密钥正确接收流
我有以下场景：假设有20个传感器向我发送流式提要。我对流应用了一个keyBy（sensorID）并执行了一些操作，如平均等。这是实现的，并且运行良好（使用Flink Java API）。
一开始一切都很顺利，所有的传感器都在给我发送信号。在一段时间后，可能会有几个传感器开始出现故障，我开始从它们那里得到不正常的数据源，例如，我从18个传感器接收数据源，但2个传感器长时间不向我发送数据源。
有人使用flink-streaming/模式实现了这样的场景吗？有什么建议请。
共有1个答案
您可以在技术上使用processfunction和计时器。
您可以简单地为每个记录注册定时器，然后在接收到数据时重置它。如果您安排计时器在5分钟的处理时间后运行，这基本上意味着如果您还没有收到数据，它将调用函数ontimer，您可以从该函数发出一些警报。可以为已发出的警报重新注册计时器，以允许发出严重性更高的警报。
请注意，只有在最初所有传感器工作正常的情况下，这才会起作用。具体地说，它只会针对至少看到过一次的密钥发出警报。但从你的描述看来这会解决你的问题。
-
检查指定的ID是否存有对称密钥。 调用： web3.shh.hasSymKey(id, [callback]) 参数： id：String - 密钥ID，由shh.newSymKey()、 shh.addSymKey()或shh.generateSymKeyFromPassword()返回 callback：Function - 可选的回调函数，其第一个参数为错误对象，第二个参数为返回结果 返回
-
所以，我从服务器上获得了一些JSON值，但我不知道是否会有一个特定的字段。 比如： 有时，会有一个额外的字段，如： 我想检查名为“club”的字段是否存在，这样在解析时我就不会得到 组织。json。JSONException:俱乐部没有价值
-
检查whisper节点的私钥是否匹配给定的ID。 调用： web3.shh.hasKeyPair(id, [callback]) 参数： id：String - 密钥对ID，由shh.newKeyPair()和shh.addPrivateKey()返回 callback：Function - 可选的回调函数，其第一个参数为错误对象，第二个参数为结果 返回值： Boolean - 如果节点密钥对匹
-
问题内容： 我有一堆字符，想删除所有不是’＃’‘的字符。“ E”和“ G”。 我试图用这个： 但是遇到了不兼容类型的问题。 问题答案：
-
null 什么做法更好，更“真实”？我喜欢第一个，但再次，不确定我该如何选择Epsilon。
-
我正在自动化一些涉及android keytool和jarsigner的东西。该工具获取一个密钥存储库、密钥存储库的密码、别名和别名/密钥的密码，我正在尝试找到一种方法来显式检查为别名/密钥提供的密码是否正确。 有什么想法吗？而且，我需要在没有要签名的jar文件的情况下检查它--在我的上下文中获取该文件是很长的，所以我希望早一点而不是晚一点中止。