《apache》专题

我有这个. htaccess 但是apache给我写了这样一封信： 安全：警告。需要将“%{tx.allowed_methods}”与“REQUEST_METHOD”匹配。[文件/modsecurity/modsecurity_crs_30_http_policy.conf”][line“31”][id“960032”][rev“2”][msg”方法不被策略所允许”][data“GET”][sev

在某些场景中，Apache Flink似乎无法很好地处理具有相同时间戳的两个事件。 根据文档，水印t表示任何新事件的时间戳都将严格大于t。除非您完全放弃两个事件具有相同时间戳的可能性，否则您将无法安全地发出t的水印。强制使用不同的时间戳还将系统每秒可处理的事件数限制为1000。 这真的是Apache Flink中的一个问题还是有解决方法？ 对于那些希望使用具体示例的人，我的用例是为事件时间顺序流构

我正在使用POI 3.8使用Java创建Excel工作表 我已经成功地使用Prashant Jadhav在如何使用Apache poi在Java中创建超链接到其他工作表上的过滤器中解释的方法创建了超链接？ 不过我想设置屏幕提示以及 我试过了 但是没有用。 这有可能吗？ 谢谢！

我想使用Flink的事件时间戳，并计划实现一个简单的emitWatermark，即系统。currentTimeInMillis-10秒。我的理解是，翻滚窗口将触发start\u time window\u间隔10秒。因此，如果事件晚于水印到达，则会删除这些事件。 有没有办法将Flink丢弃的所有事件写入S3这样的接收器？

在我的应用程序中，我使用Apache POI 3.8进行XLS文件处理。 现在我想迁移到Apache POI 3.9最新和稳定的版本。我已经添加了JAR文件poi-3.9-20121203。并删除了与POI 3.8相关的jar。 但似乎在3.9版本中，WorkbookFactory类已被删除。 那么，如何在Apache POI 3.9中使用WorkbookFactory创建工作簿呢？ 我提取了JA

我可以在Apache POI中为单元格设置超链接，但我不知道如何将超链接放入图像中（我正在使用XSSF） 以下是放置单元格超链接的功能： 下面是将图像放入指定单元格的函数： = 提前感谢！

我试图了解Apache FLink中Windows和Watermark生成之间的依赖关系，我在下面的示例中出现错误： 这里的时间戳是一个长的，我们可以从Kafka源中检索到，应该是：a，4 C，8，其中C是类别，5是时间戳。 每当我发送事件时，数据流都会打印，但不会使用窗口打印这些事件（打印（“Windows”）。此外，如果我收到一个事件A，12，然后生成了一个水印（在10秒内），那么我有C，2，

使用翻滚窗口的apache flink应用程序遇到问题。窗口大小是10秒，我希望每隔10秒有一个resultSet数据流。然而，当最新窗口的结果集总是延迟时，除非我将更多数据推送到源流。 例如，如果我在“01:33:40.0”和“01:34:00.0”之间将多条记录推送到源流，然后停止查看日志，则不会发生任何事情。 我在“01:37:XX”上再次推送一些数据，然后将在“01:33:40.0”和“0

任何人都知道如何使用时间偏移进行翻滚窗口-窗口大小为一天，时间偏移基于时区以小时为单位。 我找到了使用DataStream API执行此操作的示例，想知道如何使用Table API/SQL实现它。 下面是我使用DataStream API的代码。 提前谢谢。

上下文：我正在研究的项目处理定期（1分钟）生成的时间戳文件，并将其实时摄取到一系列级联窗口操作符中。文件的时间戳指示事件时间，因此我不需要依赖文件创建时间。每个窗口的处理结果被发送到一个接收器，该接收器将数据存储在多个表中。 我正在尝试想出一个解决方案来处理实时进程可能出现的停机时间。输入文件是独立生成的，因此在Flink解决方案严重停机的情况下，我想摄取和处理丢失的文件，就好像它们是由同一进程摄

我很难理解水印和允许迟到的概念。 以下是[邮件存档]的摘录|https://www.mail-archive.com/user@Flink。阿帕奇。组织/msg08758。html]这谈到了水印，但我还有几个问题。以下是引用的示例： 假设您有一个，具有2分钟的绑定和10分钟的翻转窗口，从12:00开始到12:10结束： 如果您具有以下流序列： 不允许迟到 当窗口操作符接收到<代码> 允许迟到3分钟

我是Apache Flink的新手，我正在尝试使用Flink CEP动态评估流中的模式。我正在尝试查找执行以下操作的用户登录、addtocart和注销，并且能够检测到模式，但是如果我定义了多个模式，例如登录，注销，则无法检测到模式 下面是我的代码 动作类 模式类 主类 如果我给出一个模式来评估它的输出，如下所示 如果我试图给多个模式进行评估，如下面所示，它不是评估第二个模式，而是建议我如何评估多个

我正在实现一个用例，其中不同的物理设备正在发送事件，并且由于网络/电源问题，在flink source接收事件时可能会有延迟。flink作业中的一个操作符是模式操作符，并且有一些特定的模式是时间敏感的，所以我使用事件时间特性。但是，当来自特定设备的事件出现不可预测的延迟时，问题就会出现，这会导致这些事件被丢弃（因为我无法真正定义允许延迟的静态绑定）。 由于我使用的是基于源设备ID的KeyedStr

我正在尝试过滤所有临时事件 输入是一个文本文件，由输入函数解析为流，输入文件的内容包括：- 第一个值是Rack_id第二个是温度 我在input stream和WarnigsStream上都发布了print（），如下所示 现在，问题来了，Flink CEP的输出如下所示 正如我们所看到的，第一个复杂事件（机架id=1和温度=98.0））以相同的顺序打印，但在此之后，所有其他复杂事件都具有温度 提前

我正试图用Apache Flink构建一个CEP系统来关联事件。其中一个要求是能够在运行时为异常检测添加新模式，而不会丢失系统可用性。你知道我该怎么做吗？ 例如，如果我有一个安全事件流（例如访问、身份验证）和一个用于检测异常的模式（例如， 问候。