当前位置: 首页 > 知识库问答 >
问题:

带有Apache Flink 1.5的Apache Bean 2.4.0

冯宏恺
2023-03-14

是否有一个地方我们可以快速引用和查看Apache beam和运行时环境(Flink、Spark等)之间的版本兼容性。我正在艰难地学习它:(.不确定我的问题有多少是由版本错误造成的。

目前我正在使用Beam 2.4.0并查看flink runner pom(https://search.maven.org/#artifactdetails%7corg.html" target="_blank">apache.Beam%7cbeam-runners-flink2.11%7c2.4.0%7cjar),它使用flink 1.4.0 jars。因此,我假设Apache Beam2.4.0可以与Apache Flink1.4.0一起工作。这样的解释正确吗?

共有1个答案

微生弘
2023-03-14

Flink 1.4.0与Beam 2.4.0兼容。找出兼容性的一个简单方法是检查父pom.xml的Beam发布版本,并查看它是用哪个Flink版本测试的。注意,这并不意味着它与其他Flink Verion不兼容。它可能是也可能不是,你需要找出或询问某人在Beam社区。

 类似资料:
  • 现在我的问题是,如何在自定义的而不是自定义的中重写方法?我没有在这里公布我的代码,因为它与链接的代码本质上是相同的,只是我需要为子创建一个自定义的来代替,这样它就可以按照“pptang”的答案所述进行正确的度量。 否则,有没有比在第二个RecyclerView中使用1个RecyclerView更好的方法?只能有1个RecyclerView使用上述列表和每个中唯一项的网格填充活动/片段吗?

  • 问题内容: 两者之间到底有什么区别 和 第一个只是加快字段初始化速度的捷径吗?有性能方面的考虑吗? 问题答案: 第二种形式总是创建一个空的地图。 第一种形式是地图文字的特殊情况。地图文字允许创建 非空 地图: 现在,您的(通用)示例: 是没有初始值(键/值对)的地图文字。它完全等同于: 此外,这是为地图指定初始容量(大于初始分配的元素数量)的唯一方法。例: 将创建一个地图,该地图具有足够的空间来容

  • 问题内容: 查看量角器文档,我发现有一个选项可以不使用Selenium服务器使用flag 来运行量角器。 使用硒服务器和不使用硒服务器运行量角器测试之间的区别是什么,除了后者仅支持Chrome,Firefox? 问题答案: 首先,目前,您有 5种不同的内置选项/方式来连接浏览器驱动程序 : 指定在本地启动Selenium独立服务器 指定连接到正在运行的硒服务器(本地或远程) 设置并连接到Sauce

  • 代码: 上下文:尝试在JavaScript中使用 编辑: 完整代码: 编辑: 无法获取

  • 在GlassFish Server开源版本3.1中部署。1(构建12): 引起原因:java.security.PrivilegedActionExcema:com.sun.xml.bind.v2.runtime.IllegalAnnotationsExceptions: 1个IllegalAnnotationExceptions的计数没有ObjectFactory与@XmlElementDecl

  • 问题内容: 我正在尝试制作一个支持cookie的URLConnection。根据文档,我可以使用: 我无法使此代码正常工作,然后我看到这仅适用于API 9(2.3)。但是,在较旧的模拟器中使用CookieManager不会出现错误,CookieManager存在,但是无法构造。有什么方法可以使此版本适用于早期版本?我试过了: 但这不起作用。 问题答案: 我能够使用Ian Brown的CookieM

  • 问题内容: 情况:像在纸牌游戏中一样,画一堆纸牌。堆好。 为实现此目的,我将结合使用接口的自定义实现。使用自定义LayoutManager的原因是堆栈方向各不相同,有时纸牌彼此完全覆盖,有时彼此覆盖,而对于LayoutManager来说,此逻辑似乎是一项好工作,因为这基本上归结为设置布局的位置。牌。 因此,负责设置堆栈中所有组件的X和Y坐标。在另一方面是负责他们的z坐标(通过其层)。 向组件添加组

  • 问题内容: 我是初次使用Hibernate和Java。我收到以下异常。我在网上找到的有关此错误的信息似乎没有帮助。有任何想法吗?例外: 被称为的地方: 映射到数据库表的类: 谢谢, 谭 问题答案: 尝试在文件中的下添加元素。 我在JPA / EntityManager上所做的工作还不止这些,所以我不知道是否有添加整个程序包的方法。AFAIK在使用时,必须直接指定每个持久类。