0

Amazon Kinesis は初めてです。基本的なドキュメントと Kinesis APi を読み、Kinesis を使い始めました。そこで、ストリームを作成する小さなコードを scala で書きました。しかし、私は以下のような例外に直面しています

スレッド「メイン」の例外 java.lang.NoSuchMethodError: org.joda.time.format.DateTimeFormatter.withZoneUTC()Lorg/joda/time/format/DateTimeFormatter; com.amazonaws.auth.AWS4Signer.(AWS4Signer.java:44) で、sun.reflect.NativeConstructorAccessorImpl.newInstance0(ネイティブメソッド) で、sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) で、sun.reflect.DelegatingConstructorAccessorImpl で。 newInstance(DelegatingConstructorAccessorImpl.java:45) で java.lang.reflect.Constructor.newInstance(Constructor.java:526) で java.lang.Class.newInstance(Class.java:379) で com.amazonaws.auth.SignerFactory.createSigner (SignerFactory.java:119) com.amazonaws.auth.SignerFactory.lookupAndCreateSigner(SignerFactory.java:105) com.amazonaws.auth.

ここに私のコードがあります

def main(args: Array[String]) {
        println("Stream creation started")
        if(create(2))
            println("Stream is created successfully")
    }
    def create(shardCount: Int): Boolean = {
        val credentials = new BasicAWSCredentials(KinesisProperties.AWS_ACCESS_KEY_ID, KinesisProperties.AWS_SECRET_KEY)

        var kinesisClient: AmazonKinesisClient = new AmazonKinesisClient(credentials)
        kinesisClient.setEndpoint(KinesisProperties.KINESIS_ENDPOINT_URL,
            KinesisProperties.KINESIS_SERVICE_NAME,
            KinesisProperties.KINESIS_REGION_ID)
        val createStreamRequest = new CreateStreamRequest()
        createStreamRequest.setStreamName(KinesisProperties.myStreamName);
        createStreamRequest.setShardCount(shardCount)
        val describeStreamRequest = new DescribeStreamRequest()
        describeStreamRequest.setStreamName(KinesisProperties.myStreamName)
        try {
            Thread.sleep(120000)
        } catch {
            case e: Exception =>
        }
        var streamStatus = "not active"
        while (!streamStatus.equalsIgnoreCase("ACTIVE")) {
            try {
                Thread.sleep(1000)
            } catch {
                case e: Exception => e.printStackTrace()
            }
            try {
                val describeStreamResponse = kinesisClient.describeStream(describeStreamRequest)
                streamStatus = describeStreamResponse.getStreamDescription.getStreamStatus
            } catch {
                case e: Exception => e.printStackTrace()
            }
        }
        if (streamStatus.equalsIgnoreCase("ACTIVE"))
            true
        else
            false
    }

ここにpomファイルの私の依存関係があります

<dependency>
            <groupId>joda-time</groupId>
            <artifactId>joda-time</artifactId>
            <version>2.6</version>
        </dependency>

        <dependency>
            <groupId>com.amazonaws</groupId>
            <artifactId>amazon-kinesis-client</artifactId>
            <version>1.2.0</version>
        </dependency>
        <dependency>
            <groupId>com.amazonaws</groupId>
            <artifactId>aws-java-sdk</artifactId>
            <version>1.8.9</version>
        </dependency>
4

1 に答える 1

0

こんにちは仲間たち、joda-time jar ファイルを HADOOP_CLASSPATH に追加することで、この問題の解決策を見つけました。今、それは働いています

于 2015-01-16T12:12:09.070 に答える