You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/04/08 14:47:06 UTC
[camel] 01/09: CAMEL-17763: cleanup unused exceptions in camel-flink
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit e126865a0456db0a752bde6db7080b6f7a0332d3
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri Apr 8 15:36:22 2022 +0200
CAMEL-17763: cleanup unused exceptions in camel-flink
---
.../test/java/org/apache/camel/component/flink/FlinkProducerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-flink/src/test/java/org/apache/camel/component/flink/FlinkProducerTest.java b/components/camel-flink/src/test/java/org/apache/camel/component/flink/FlinkProducerTest.java
index a7f38106d4b..46856e8b908 100644
--- a/components/camel-flink/src/test/java/org/apache/camel/component/flink/FlinkProducerTest.java
+++ b/components/camel-flink/src/test/java/org/apache/camel/component/flink/FlinkProducerTest.java
@@ -198,7 +198,7 @@ public class FlinkProducerTest extends CamelTestSupport {
template.sendBodyAndHeader(flinkDataStreamUri, null, FlinkConstants.FLINK_DATASTREAM_CALLBACK_HEADER,
new VoidDataStreamCallback() {
@Override
- public void doOnDataStream(DataStream ds, Object... payloads) throws Exception {
+ public void doOnDataStream(DataStream ds, Object... payloads) {
ds.writeAsText(output.getAbsolutePath());
}
});