(flink-connector-pulsar) annotated tag v4.1.0 updated (595992b -> a20ed06)
This is an automated email from the ASF dual-hosted git repository. leonard pushed a change to annotated tag v4.1.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git *** WARNING: tag v4.1.0 was modified! *** from 595992b (commit) to a20ed06 (tag) tagging 595992bad42ce5f3c45b603287924b38819aa8c3 (commit) by Leonard Xu on Thu Dec 28 15:05:08 2023 +0800 - Log - v4.1.0 -BEGIN PGP SIGNATURE- iHUEABYKAB0WIQRbL2YIcyOJrrZzMfWxl+HxEImYrQUCZY0eJQAKCRCxl+HxEImY reTnAP9bGBhXPolC80099kjTwcP6ArJIIDWaZfz1HUxOTmpOCQD7B1bnfLPlR1gY jghVicsdueNtuNcLMEmuxViVwFif9Ag= =Ox3A -END PGP SIGNATURE- --- No new revisions were added by this update. Summary of changes:
svn commit: r66349 - /dev/flink/flink-connector-pulsar-4.1.0-rc1/ /release/flink/flink-connector-pulsar-4.1.0/
Author: leonard Date: Thu Dec 28 07:03:35 2023 New Revision: 66349 Log: Release flink-connector-pulsar 4.1.0 Added: release/flink/flink-connector-pulsar-4.1.0/ - copied from r66348, dev/flink/flink-connector-pulsar-4.1.0-rc1/ Removed: dev/flink/flink-connector-pulsar-4.1.0-rc1/
(flink-connector-jdbc) branch dependabot/maven/com.google.guava-guava-32.0.0-jre deleted (was 4ec67cb1)
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a change to branch dependabot/maven/com.google.guava-guava-32.0.0-jre in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git was 4ec67cb1 [FLINK-33953] Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
(flink-connector-jdbc) branch main updated: [FLINK-33953] Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre. This closes #81
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git The following commit(s) were added to refs/heads/main by this push: new 32c1ca4e [FLINK-33953] Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre. This closes #81 32c1ca4e is described below commit 32c1ca4e21eb360fc1c51bcafd21f42ff322c258 Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> AuthorDate: Wed Dec 27 16:25:33 2023 +0100 [FLINK-33953] Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre. This closes #81 Bumps [com.google.guava:guava](https://github.com/google/guava) from 31.1-jre to 33.0.0-jre. - [Release notes](https://github.com/google/guava/releases) - [Commits](https://github.com/google/guava/commits) --- updated-dependencies: - dependency-name: com.google.guava:guava dependency-type: direct:production ... Signed-off-by: dependabot[bot] Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> --- pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pom.xml b/pom.xml index 5d72a384..993735b3 100644 --- a/pom.xml +++ b/pom.xml @@ -329,7 +329,7 @@ under the License. com.google.guava guava -31.1-jre +33.0.0-jre
(flink-connector-elasticsearch) branch dependabot/maven/flink-connector-elasticsearch-base/org.elasticsearch-elasticsearch-7.17.14 deleted (was 6e42d85)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/flink-connector-elasticsearch-base/org.elasticsearch-elasticsearch-7.17.14 in repository https://gitbox.apache.org/repos/asf/flink-connector-elasticsearch.git was 6e42d85 Bump org.elasticsearch:elasticsearch The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
(flink) branch master updated: [FLINK-27851][table-planner] Support to access source pks through MiniBatchAssigner
This is an automated email from the ASF dual-hosted git repository.
ron pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new dd16a4c07b2 [FLINK-27851][table-planner] Support to access source pks
through MiniBatchAssigner
dd16a4c07b2 is described below
commit dd16a4c07b2f8c96740fb522cb54cfd1d5a5e835
Author: xuyang
AuthorDate: Tue May 31 16:31:37 2022 +0800
[FLINK-27851][table-planner] Support to access source pks through
MiniBatchAssigner
This closes #19850
---
.../plan/metadata/FlinkRelMdUniqueKeys.scala | 8
.../plan/metadata/FlinkRelMdUpsertKeys.scala | 10 -
.../planner/plan/stream/sql/join/JoinTest.xml | 33 ++
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 3 ++
.../plan/metadata/FlinkRelMdUniqueKeysTest.scala | 5 +++
.../plan/metadata/FlinkRelMdUpsertKeysTest.scala | 5 +++
.../planner/plan/stream/sql/join/JoinTest.scala| 50 ++
7 files changed, 112 insertions(+), 2 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala
index ad63bd58e76..e171925351d 100644
---
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala
+++
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala
@@ -112,6 +112,14 @@ class FlinkRelMdUniqueKeys private extends
MetadataHandler[BuiltInMetadata.Uniqu
getProjectUniqueKeys(projects, input, mq, ignoreNulls)
}
+ def getUniqueKeys(
+ rel: StreamPhysicalMiniBatchAssigner,
+ mq: RelMetadataQuery,
+ ignoreNulls: Boolean): JSet[ImmutableBitSet] = {
+
+mq.getUniqueKeys(rel.getInput, ignoreNulls)
+ }
+
private def getProjectUniqueKeys(
projects: JList[RexNode],
input: RelNode,
diff --git
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUpsertKeys.scala
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUpsertKeys.scala
index 386dea8c38b..358862826a2 100644
---
a/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUpsertKeys.scala
+++
b/flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUpsertKeys.scala
@@ -22,7 +22,7 @@ import
org.apache.flink.table.planner.plan.metadata.FlinkMetadata.UpsertKeys
import org.apache.flink.table.planner.plan.nodes.calcite.{Expand, Rank,
WatermarkAssigner, WindowAggregate}
import
org.apache.flink.table.planner.plan.nodes.physical.batch.{BatchPhysicalGroupAggregateBase,
BatchPhysicalOverAggregate, BatchPhysicalWindowAggregateBase}
import
org.apache.flink.table.planner.plan.nodes.physical.common.CommonPhysicalLookupJoin
-import
org.apache.flink.table.planner.plan.nodes.physical.stream.{StreamPhysicalChangelogNormalize,
StreamPhysicalDeduplicate, StreamPhysicalDropUpdateBefore,
StreamPhysicalGlobalGroupAggregate, StreamPhysicalGroupAggregate,
StreamPhysicalGroupWindowAggregate, StreamPhysicalIntervalJoin,
StreamPhysicalLocalGroupAggregate, StreamPhysicalOverAggregate}
+import org.apache.flink.table.planner.plan.nodes.physical.stream._
import org.apache.flink.table.planner.plan.schema.IntermediateRelTable
import org.apache.flink.table.planner.plan.utils.FlinkRexUtil
@@ -30,7 +30,7 @@ import com.google.common.collect.ImmutableSet
import org.apache.calcite.plan.hep.HepRelVertex
import org.apache.calcite.plan.volcano.RelSubset
import org.apache.calcite.rel.{RelDistribution, RelNode, SingleRel}
-import org.apache.calcite.rel.core.{Aggregate, Calc, Exchange, Filter, Join,
JoinInfo, JoinRelType, Project, SetOp, Sort, TableScan, Window}
+import org.apache.calcite.rel.core._
import org.apache.calcite.rel.metadata._
import org.apache.calcite.rex.{RexNode, RexUtil}
import org.apache.calcite.util.{Bug, ImmutableBitSet, Util}
@@ -114,6 +114,12 @@ class FlinkRelMdUpsertKeys private extends
MetadataHandler[UpsertKeys] {
ImmutableSet.of(ImmutableBitSet.of(rel.uniqueKeys.map(Integer.valueOf).toList))
}
+ def getUpsertKeys(
+ rel: StreamPhysicalMiniBatchAssigner,
+ mq: RelMetadataQuery): JSet[ImmutableBitSet] = {
+FlinkRelMetadataQuery.reuseOrCreate(mq).getUpsertKeys(rel.getInput)
+ }
+
def getUpsertKeys(
rel: StreamPhysicalDropUpdateBefore,
mq: RelMetadataQuery): JSet[ImmutableBitSet] = {
diff --git
a/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/stream/sql/join/JoinTest.xml
b/flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/plann
(flink-connector-jdbc) branch dependabot/maven/flink-connector-jdbc/org.apache.derby-derby-10.17.1.0 deleted (was 5be01162)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/flink-connector-jdbc/org.apache.derby-derby-10.17.1.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git was 5be01162 Bump org.apache.derby:derby in /flink-connector-jdbc The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
(flink-connector-jdbc) branch dependabot/maven/com.google.guava-guava-32.0.0-jre updated (30e2d116 -> 4ec67cb1)
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a change to branch dependabot/maven/com.google.guava-guava-32.0.0-jre in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git discard 30e2d116 Bump com.google.guava:guava from 31.1-jre to 32.0.0-jre add f8de82b4 [FLINK-33787][jdbc] Java 17 support for jdbc connector add e6645995 [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 add be5150b3 [FLINK-33329 ] Bump org.apache.commons:commons-compress from 1.23.0 to 1.24.0. This closes #84 add 4ec67cb1 [FLINK-33953] Bump com.google.guava:guava from 31.1-jre to 33.0.0-jre This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (30e2d116) \ N -- N -- N refs/heads/dependabot/maven/com.google.guava-guava-32.0.0-jre (4ec67cb1) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .github/workflows/push_pr.yml | 9 ++- .github/workflows/weekly.yml | 7 ++ flink-connector-jdbc/pom.xml | 4 .../connector/jdbc/table/JdbcTablePlanTest.java| 28 ++ pom.xml| 7 -- 5 files changed, 47 insertions(+), 8 deletions(-)
(flink-connector-jdbc) branch dependabot/maven/org.apache.commons-commons-compress-1.24.0 deleted (was f024ecac)
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a change to branch dependabot/maven/org.apache.commons-commons-compress-1.24.0 in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git was f024ecac Bump org.apache.commons:commons-compress from 1.23.0 to 1.24.0 The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
(flink-connector-jdbc) branch main updated (e6645995 -> be5150b3)
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git from e6645995 [FLINK-33883][jdbc] Bump CI flink version on flink-connector-jdbc to support flink 1.19 add be5150b3 [FLINK-33329 ] Bump org.apache.commons:commons-compress from 1.23.0 to 1.24.0. This closes #84 No new revisions were added by this update. Summary of changes: pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
