[
https://issues.apache.org/jira/browse/SAMZA-87?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Riccomini reopened SAMZA-87:
----------------------------------
This commit appears to have broken trunk:
{noformat}
$ ./gradlew -PscalaVersion=2.8.1 clean publishToMavenLocal
The TaskContainer.add() method has been deprecated and is scheduled to be
removed in Gradle 2.0. Please use the create() method instead.
:samza-api:clean
:samza-core_2.8.1:clean
:samza-kafka_2.8.1:clean
:samza-kv_2.8.1:clean
:samza-serializers_2.8.1:clean
:samza-shell:clean
:samza-test_2.8.1:clean
:samza-yarn_2.8.1:clean
:samza-api:generatePomFileForMavenJavaPublication
:samza-api:compileJava
:samza-api:processResources UP-TO-DATE
:samza-api:classes
:samza-api:jar
:samza-api:publishMavenJavaPublicationToMavenLocal
Uploading: org/apache/samza/samza-api/0.7.0/samza-api-0.7.0.jar to repository
remote at file:/Users/criccomi/.m2/repository/
Transferring 42K from remote
Uploaded 42K
:samza-api:publishToMavenLocal
:samza-core_2.8.1:generatePomFileForMavenJavaPublication
:samza-core_2.8.1:compileJava UP-TO-DATE
:samza-core_2.8.1:compileScala
[ant:scalac]
/Users/criccomi/Code/incubator-samza/samza-core/src/main/scala/org/apache/samza/system/chooser/TieredPriorityChooser.scala:89:
warning: method sort in class List is deprecated: use `sortWith' instead
[ant:scalac] .sort(_ > _)
[ant:scalac] ^
[ant:scalac] one warning found
:samza-core_2.8.1:processResources UP-TO-DATE
:samza-core_2.8.1:classes
:samza-core_2.8.1:jar
:samza-core_2.8.1:publishMavenJavaPublicationToMavenLocal
Uploading: org/apache/samza/samza-core_2.8.1/0.7.0/samza-core_2.8.1-0.7.0.jar
to repository remote at file:/Users/criccomi/.m2/repository/
Transferring 583K from remote
Uploaded 583K
:samza-core_2.8.1:publishToMavenLocal
:samza-kafka_2.8.1:generatePomFileForMavenJavaPublication
:samza-serializers_2.8.1:compileJava UP-TO-DATE
:samza-serializers_2.8.1:compileScala
:samza-serializers_2.8.1:processResources UP-TO-DATE
:samza-serializers_2.8.1:classes
:samza-serializers_2.8.1:jar
:samza-kafka_2.8.1:compileJava UP-TO-DATE
:samza-kafka_2.8.1:compileScala
/Users/criccomi/Code/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:73:
error: not found: type DefaultFetchSimpleConsumer
val sc = new DefaultFetchSimpleConsumer(host, port, timeout, bufferSize,
clientID) {
^
/Users/criccomi/Code/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/GetOffset.scala:90:
error: not found: type DefaultFetchSimpleConsumer
def getNextOffset(sc: DefaultFetchSimpleConsumer, tp: TopicAndPartition,
lastCheckpointedOffset: String): Long = {
^
/Users/criccomi/Code/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:122:
error: value close is not a member of AnyRef{val fetchSize: Int}
simpleConsumer.close()
^
/Users/criccomi/Code/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala:134:
error: value defaultFetch is not a member of AnyRef{val fetchSize: Int}
val response: FetchResponse =
simpleConsumer.defaultFetch(nextOffsets.filterKeys(messageSink.needsMoreMessages(_)).toList:
_*)
^
/Users/criccomi/Code/incubator-samza/samza-kafka/src/main/scala/org/apache/samza/system/kafka/GetOffset.scala:54:
error: not found: type DefaultFetchSimpleConsumer
private def useLastCheckpointedOffset(sc: DefaultFetchSimpleConsumer, last:
String, tp: TopicAndPartition): Option[Long] = {
^
5 errors found
{noformat}
> BrokerProxy doesn't properly handle offset out of range exceptions
> ------------------------------------------------------------------
>
> Key: SAMZA-87
> URL: https://issues.apache.org/jira/browse/SAMZA-87
> Project: Samza
> Issue Type: Bug
> Affects Versions: 0.7.0
> Reporter: Jakob Homan
> Assignee: Jakob Homan
> Priority: Critical
> Fix For: 0.7.0
>
> Attachments: SAMZA-87-2.patch, SAMZA-87-3.patch, SAMZA-87-4.patch,
> SAMZA-87.patch
>
>
> Currently BrokerProxy will throw an exception for offset out of range from
> Kafka but does not get a new offset, instead going into an infinite loop of
> sadness.
--
This message was sent by Atlassian JIRA
(v6.1#6144)
