aIbrahiim commented on issue #39049: URL: https://github.com/apache/beam/issues/39049#issuecomment-4766836351
I added the same lz4 capability resolution to sdks/java/testing/nexmark/build.gradle #39055 as PR #38961 already used and Flink 2.x uses at.yawk.lz4:lz4-java, Kafka still wants org.lz4:lz4-java, and gradle was failing on that conflict when resolving the gradleRun classpath and the change tells gradle to prefer Flink at.yawk.lz4 version but result was PostCommit Java Nexmark Flink passed 3 out of 4 jobs after this change so the lz4 dependency issue looks fixed. what still failed the 4th job as batch Java Nexmark (streaming=false, no SQL) on Flink 2.2. https://github.com/apache/beam/actions/runs/27937889835/job/82663903667?pr=39055 It fails on Query 6 (AVERAGE_SELLING_PRICE_BY_SELLER) with a TimestampCombiner error in WinningBids / AuctionOrBidWindow. Query 9 uses the same code, so it would likely fail too and this looks separate from the lz4 fix and it showed up after #38980 moved this workflow from Flink 1.19/1.20 to 2.2 so I think there are two options: - Skip queries 6 and 9 in the Nexmark Flink workflow if possible - OR revert this workflow back to Flink 1.20 until Flink 2.2 works with WinningBids. @Abacn -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
