beam
beam copied to clipboard
apache
Apache Beam is a unified programming model for Batch and Streaming data processing.
[](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) You can trigger a rebase of this PR by commenting `@dependabot rebase`. [//]: # (dependabot-automerge-start) [//]: # (dependabot-automerge-end) --- Dependabot commands and options You can trigger Dependabot...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
### What happened? *Behavior observed:* When control-clicking on a Java class name that goes between modules, I noticed it often went to a decompiled class file rather than the source....
**Please** add a meaningful description for your change here Related to : https://github.com/apache/beam/issues/31118 Upon utilizing the Beam SQL within our pipeline, we encountered a noteworthy exception. It appears that when...
### What happened? Upon utilizing the Beam SQL within our pipeline, we encountered a noteworthy exception. It appears that when the input row encompasses fields of iterable types, the process...
### What would you like to happen? The current implementation of [close()](https://github.com/apache/beam/blob/f303d6ae7ebe4c5b2e1af5e29840317a6ce0d691/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/errorhandling/ErrorHandler.java#L144) of PTransformErrorHandler adds several transforms to the pipeline without providing an option to customize their names. These transforms...
### What needs to happen? After #30789 we can remove support for Flink 1.14 and review code to do cleanup of unneeded version specific code in `runners/flink//src`. ### Issue Priority...
### What would you like to happen? ### [Flink Runner] Question **Description** Our organization is in the process of updating our Flink clusters to the latest version, Flink 1.18. We...
Unable to read data from informix non-logged database due to connection error problem caused by setAutoCommit statement [https://www.ibm.com/docs/en/informix-servers/12.10?topic=SSGU8G_12.1.0/com.ibm.jdbc_pg.doc/ids_jdbc_non_logged_database.html]. Caused by: java.sql.SQLException: Transactions not supported com.informix.util.IfxErrMsg.buildExceptionWithMessage(IfxErrMsg.java:421) com.informix.util.IfxErrMsg.buildException(IfxErrMsg.java:396) com.informix.util.IfxErrMsg.getSQLException(IfxErrMsg.java:378) com.informix.jdbc.IfxSqliConnect.setAutoCommit(IfxSqliConnect.java:2185) org.apache.commons.dbcp2.DelegatingConnection.setAutoCommit(DelegatingConnection.java:801) org.apache.commons.dbcp2.DelegatingConnection.setAutoCommit(DelegatingConnection.java:801)...
### What happened? It's a bug in the implemenation of SyntheticUnboundedSource class. By default, it splits the data to some number of bundles and lost records number in write streaming...
### What happened? Affecting beam_PreCommit_Java_GCP_IO_Direct, e.g.: https://ci-beam.apache.org/view/PostCommit/job/beam_PreCommit_Java_GCP_IO_Direct_Cron/1121/testReport/junit/org.apache.beam.sdk.io.gcp.spanner/SpannerReadIT/testReadWithDataBoost/ Error message: ``` org.apache.beam.sdk.Pipeline$PipelineExecutionException: com.google.cloud.spanner.SpannerException: PERMISSION_DENIED: io.grpc.StatusRuntimeException: PERMISSION_DENIED: This instance (projects/apache-beam-testing/instances/beam-test) is not allowed to use DataBoost at this time. Please contact [email protected]...
