Yeah, they were called out explicitly in SAMZA-161:
https://issues.apache.org/jira/browse/SAMZA-161?focusedCommentId=13915424&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-13915424
The suggestion from Scala for 2.10 doesn't exist in 2.9.


On Tue, Mar 25, 2014 at 7:06 PM, <[email protected]> wrote:

> Hi Devs, does anybody if we have a JIRA to address the below warnings that
> present themselves in the compileScala task in BrokerProxy?
>
> If not I will create one.
>
> /home/steve/samza-workspace/incubator-samza/samza-kafka/
> src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:68:
> warning: trait ConcurrentMap in package mutable is deprecated: Use
> `scala.collection.concurrent.Map` instead.
>   val nextOffsets:mutable.ConcurrentMap[TopicAndPartition, Long] = new
> ConcurrentHashMap[TopicAndPartition, Long]()
>                           ^
> /home/steve/samza-workspace/incubator-samza/samza-kafka/
> src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:68:
> warning: method mapAsScalaDeprecatedConcurrentMap in trait
> LowPriorityWrapAsScala is deprecated: Use `mapAsScalaConcurrentMap`
> instead, and use `concurrent.Map` instead of `ConcurrentMap`.
>   val nextOffsets:mutable.ConcurrentMap[TopicAndPartition, Long] = new
> ConcurrentHashMap[TopicAndPartition, Long]()
>                                                                    ^
> /home/steve/samza-workspace/incubator-samza/samza-kafka/
> src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:68:
> warning: trait ConcurrentMap in package mutable is deprecated: Use
> `scala.collection.concurrent.Map` instead.
>   val nextOffsets:mutable.ConcurrentMap[TopicAndPartition, Long] = new
> ConcurrentHashMap[TopicAndPartition, Long]()
>       ^
> /home/steve/samza-workspace/incubator-samza/samza-kafka/
> src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:92:
> warning: method asJavaConcurrentMap in trait WrapAsJava is deprecated: Use
> `concurrent.Map` instead of `ConcurrentMap`.
>     if (nextOffsets.containsKey(tp)) {
>         ^
> /home/steve/samza-workspace/incubator-samza/samza-kafka/
> src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:114:
> warning: method asJavaConcurrentMap in trait WrapAsJava is deprecated: Use
> `concurrent.Map` instead of `ConcurrentMap`.
>     if (nextOffsets.containsKey(tp)) {
>
>
> Steve
>
>

Reply via email to