[ https://issues.apache.org/jira/browse/FLINK-22610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369319#comment-17369319 ]
LIU Xiao commented on FLINK-22610: ---------------------------------- I've done some testing, removing "<include>...</include>" can solve our probelm. [patch|https://github.com/Zor-X-L/flink/commit/12ca124453da38b1681e49fce2bc94794f0a819f] > The test-jar and test-source-jar of flink-connector-kafka should include all > classes > ------------------------------------------------------------------------------------ > > Key: FLINK-22610 > URL: https://issues.apache.org/jira/browse/FLINK-22610 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.13.0, 1.12.3 > Reporter: LIU Xiao > Priority: Minor > > The test-jar of old kafka connector (flink-connector-kafka-base and > flink-connector-kafka-0.11) includes convenient utility classes > (KafkaTestEnvironment and KafkaTestEnvironmentImpl, etc.) to start an > embedded kafka in unit test, and we used the utility classes to build some > test cases for our project. > Now the utility classes other than KafkaTestEnvironmentImpl seem to be gone > in test-jar of new kafka connector (flink-connector-kafka), and I find that > is because they are not included in the configuration of maven-jar-plugin in > pom.xml: > {code:xml} > ... > <plugin> > <groupId>org.apache.maven.plugins</groupId> > <artifactId>maven-jar-plugin</artifactId> > <executions> > <execution> > <goals> > <goal>test-jar</goal> > </goals> > <configuration> > <includes> > <include>**/KafkaTestEnvironmentImpl*</include> > <include>META-INF/LICENSE</include> > <include>META-INF/NOTICE</include> > </includes> > </configuration> > </execution> > </executions> > </plugin> > ... > {code} > This configuration seems to be inherited from flink-connector-kafka-0.11, but > actually the configuration of flink-connector-kafka-base should be used: > {code:xml} > ... > <plugin> > <artifactId>maven-jar-plugin</artifactId> > <executions> > <execution> > <goals> > <goal>test-jar</goal> > </goals> > </execution> > </executions> > </plugin> > ... > {code} > The test-source-jar has similar problem: > {code:xml} > ... > <plugin> > <groupId>org.apache.maven.plugins</groupId> > <artifactId>maven-source-plugin</artifactId> > <executions> > <execution> > <id>attach-test-sources</id> > <goals> > <goal>test-jar-no-fork</goal> > </goals> > <configuration> > <archive> > <!-- Globally exclude maven metadata, because it may > accidentally bundle files we don't intend to --> > <addMavenDescriptor>false</addMavenDescriptor> > </archive> > <includes> > <include>**/KafkaTestEnvironmentImpl*</include> > <include>META-INF/LICENSE</include> > <include>META-INF/NOTICE</include> > </includes> > </configuration> > </execution> > </executions> > </plugin> > ... > {code} > I think it should be: > {code:xml} > ... > <plugin> > <groupId>org.apache.maven.plugins</groupId> > <artifactId>maven-source-plugin</artifactId> > <executions> > <execution> > <id>attach-test-sources</id> > <goals> > <goal>test-jar-no-fork</goal> > </goals> > <configuration> > <archive> > <!-- Globally exclude maven metadata, because it may > accidentally bundle files we don't intend to --> > <addMavenDescriptor>false</addMavenDescriptor> > </archive> > </configuration> > </execution> > </executions> > </plugin> > ... > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)