Atualizar aplicativos Java - Managed Service for Apache Flink
flink-connector-kinesisOutros conectores afetados

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Atualizar aplicativos Java

Siga os procedimentos abaixo para atualizar os aplicativos Java:

Se o aplicativo usa flink-connector-kinesis:

O conector Kinesis usa sombreamento para empacotar algumas dependências, incluindo a AWS SDK, no jarro do conector. Para atualizar a AWS SDK versão, use o procedimento a seguir para substituir essas classes sombreadas:

Maven

  1. Adicione o conector Kinesis e os AWS SDK módulos necessários como dependências do projeto.

  2. Configure maven-shade-plugin:

    1. Adicione um filtro para excluir AWS SDK classes sombreadas ao copiar o conteúdo do jar do conector Kinesis.

    2. Adicione uma regra de realocação para mover AWS SDK classes atualizadas para o pacote, o que é esperado pelo conector Kinesis.

    pom.xml 

    <project>
    ...    
    <dependencies>
        ...
        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kinesis</artifactId>
            <version>1.15.4</version>
        </dependency>
        
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>kinesis</artifactId>
            <version>2.20.144</version>
        </dependency>
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>netty-nio-client</artifactId>
            <version>2.20.144</version>
        </dependency>
        <dependency>
            <groupId>software.amazon.awssdk</groupId>
            <artifactId>sts</artifactId>
            <version>2.20.144</version>
        </dependency>
        ...
    </dependencies>
    ...
    <build>
        ...
        <plugins>
            ...
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-shade-plugin</artifactId>
                <version>3.1.1</version>
                <executions>
                    <execution>
                        <phase>package</phase>
                        <goals>
                            <goal>shade</goal>
                        </goals>
                        <configuration>
                            ...
                            <filters>
                                ...
                                <filter>
                                    <artifact>org.apache.flink:flink-connector-kinesis</artifact>
                                    <excludes>
                                        <exclude>org/apache/flink/kinesis/shaded/software/amazon/awssdk/**</exclude>
                                        <exclude>org/apache/flink/kinesis/shaded/org/reactivestreams/**</exclude>
                                        <exclude>org/apache/flink/kinesis/shaded/io/netty/**</exclude>
                                        <exclude>org/apache/flink/kinesis/shaded/com/typesafe/netty/**</exclude>
                                    </excludes>
                                </filter>
                                ...
                            </filters>
                            <relocations>
                                ...
                                <relocation>
                                    <pattern>software.amazon.awssdk</pattern>
                                    <shadedPattern>org.apache.flink.kinesis.shaded.software.amazon.awssdk</shadedPattern>
                                </relocation>
                                <relocation>
                                    <pattern>org.reactivestreams</pattern>
                                    <shadedPattern>org.apache.flink.kinesis.shaded.org.reactivestreams</shadedPattern>
                                </relocation>
                                <relocation>
                                    <pattern>io.netty</pattern>
                                    <shadedPattern>org.apache.flink.kinesis.shaded.io.netty</shadedPattern>
                                </relocation>
                                <relocation>
                                    <pattern>com.typesafe.netty</pattern>
                                    <shadedPattern>org.apache.flink.kinesis.shaded.com.typesafe.netty</shadedPattern>
                                </relocation>
                                ...
                            </relocations>
                           ...
                        </configuration>
                    </execution>
                </executions>
            </plugin>
            ...
        </plugins>
        ... 
    </build>
</project>
Gradle

  1. Adicione o conector Kinesis e os AWS SDK módulos necessários como dependências do projeto.

  2. Ajuste a shadowJar configuração:

    1. Exclua AWS SDK classes sombreadas ao copiar o conteúdo do jar do conector Kinesis.

    2. Realoque AWS SDK as classes atualizadas para um pacote esperado pelo conector Kinesis.

    build.gradle

    ...
dependencies {
    ...
    flinkShadowJar("org.apache.flink:flink-connector-kinesis:1.15.4")
    
    flinkShadowJar("software.amazon.awssdk:kinesis:2.20.144")
    flinkShadowJar("software.amazon.awssdk:sts:2.20.144")
    flinkShadowJar("software.amazon.awssdk:netty-nio-client:2.20.144")
    ...
}
...
shadowJar {
    configurations = [project.configurations.flinkShadowJar]

    exclude("software/amazon/kinesis/shaded/software/amazon/awssdk/**/*")
    exclude("org/apache/flink/kinesis/shaded/org/reactivestreams/**/*.class")
    exclude("org/apache/flink/kinesis/shaded/io/netty/**/*.class")
    exclude("org/apache/flink/kinesis/shaded/com/typesafe/netty/**/*.class")
    
    relocate("software.amazon.awssdk", "org.apache.flink.kinesis.shaded.software.amazon.awssdk")
    relocate("org.reactivestreams", "org.apache.flink.kinesis.shaded.org.reactivestreams")
    relocate("io.netty", "org.apache.flink.kinesis.shaded.io.netty")
    relocate("com.typesafe.netty", "org.apache.flink.kinesis.shaded.com.typesafe.netty")
}
...

Se o aplicativo usar outro conector afetado:

Para atualizar a AWS SDK versão, ela deve ser aplicada na configuração de compilação do projeto. SDK

Maven

Adicione a AWS SDK lista de materiais (BOM) à seção de gerenciamento de dependências do pom.xml arquivo para impor a SDK versão para o projeto.

pom.xml

<project>
    ...    
    <dependencyManagement>
        <dependencies>
            ...
            <dependency>
                <groupId>software.amazon.awssdk</groupId>
                <artifactId>bom</artifactId>
                <version>2.20.144</version>
                <scope>import</scope>
                <type>pom</type>
            </dependency>
            ...
        </dependencies>
    </dependencyManagement>
    ...
</project>
Gradle

Adicione a dependência da plataforma na AWS SDK lista de materiais (BOM) para impor a SDK versão para o projeto. Isso requer o Gradle 5.0 ou mais recente:

build.gradle

...
dependencies {
    ...
    flinkShadowJar(platform("software.amazon.awssdk:bom:2.20.144"))
    ...
}
...