diff --git a/flink-batch-connectors/flink-avro/pom.xml b/flink-batch-connectors/flink-avro/pom.xml index 6162d3e2c6767..c4f7ac6485741 100644 --- a/flink-batch-connectors/flink-avro/pom.xml +++ b/flink-batch-connectors/flink-avro/pom.xml @@ -43,14 +43,6 @@ under the License. provided - - - org.apache.flink - flink-clients_2.10 - ${project.version} - provided - - org.apache.avro avro @@ -64,6 +56,13 @@ under the License. test-jar test + + + org.apache.flink + flink-clients_2.10 + ${project.version} + test + org.apache.flink diff --git a/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceExample.java b/flink-streaming-connectors/flink-connector-twitter/src/test/java/org/apache/flink/streaming/connectors/twitter/examples/TwitterFilterSourceExample.java similarity index 74% rename from flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceExample.java rename to flink-streaming-connectors/flink-connector-twitter/src/test/java/org/apache/flink/streaming/connectors/twitter/examples/TwitterFilterSourceExample.java index 43cb179ebc249..a30e40d19049d 100644 --- a/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterFilterSourceExample.java +++ b/flink-streaming-connectors/flink-connector-twitter/src/test/java/org/apache/flink/streaming/connectors/twitter/examples/TwitterFilterSourceExample.java @@ -1,12 +1,13 @@ /* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, @@ -15,11 +16,12 @@ * limitations under the License. */ -package org.apache.flink.streaming.connectors.twitter; +package org.apache.flink.streaming.connectors.twitter.examples; import org.apache.flink.streaming.api.datastream.DataStream; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.streaming.connectors.json.JSONParseFlatMap; +import org.apache.flink.streaming.connectors.twitter.TwitterFilterSource; import org.apache.flink.util.Collector; /** diff --git a/flink-streaming-connectors/flink-connector-twitter/src/test/resources/twitter.properties b/flink-streaming-connectors/flink-connector-twitter/src/test/resources/twitter.properties new file mode 100644 index 0000000000000..1ca4143bd39a4 --- /dev/null +++ b/flink-streaming-connectors/flink-connector-twitter/src/test/resources/twitter.properties @@ -0,0 +1,19 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +secret=*** +consumerSecret=*** +token=***-*** +consumerKey=***