This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit b8c93799f093e0e7707840b8b28feff3206d1b39 Author: Till Rohrmann <trohrm...@apache.org> AuthorDate: Wed Apr 24 17:59:30 2019 +0200 [hotfix] Remove ScalaTestingUtils --- .../runtime/testingUtils/ScalaTestingUtils.scala | 38 ---------------------- 1 file changed, 38 deletions(-) diff --git a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/ScalaTestingUtils.scala b/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/ScalaTestingUtils.scala deleted file mode 100644 index d4ca8f6..0000000 --- a/flink-runtime/src/test/scala/org/apache/flink/runtime/testingUtils/ScalaTestingUtils.scala +++ /dev/null @@ -1,38 +0,0 @@ -/* - * 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. - */ - -package org.apache.flink.runtime.testingUtils - -import akka.actor.ActorRef -import org.apache.flink.runtime.highavailability.HighAvailabilityServices -import org.apache.flink.runtime.instance.{ActorGateway, AkkaActorGateway} - -/** Mixing for testing utils - * - */ -trait ScalaTestingUtils { - - /** Converts an [[ActorRef]] into a new [[AkkaActorGateway]] with null leader session ID - * - * @param actor ActorRef for which the ActorGateway is constructed - * @return [[ActorGateway]] encapsulating the given [[ActorRef]] - */ - implicit def actorRef2InstanceGateway(actor: ActorRef): ActorGateway = { - new AkkaActorGateway(actor, HighAvailabilityServices.DEFAULT_LEADER_ID) - } -}