[flink-web] branch asf-site updated: [hotfix][docs] Add aliases for moved pages
This is an automated email from the ASF dual-hosted git repository. martijnvisser pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/flink-web.git The following commit(s) were added to refs/heads/asf-site by this push: new 5741e9063 [hotfix][docs] Add aliases for moved pages 5741e9063 is described below commit 5741e9063924ff2ae0ab7b781985e68636ea2462 Author: rmoff AuthorDate: Thu Oct 12 14:49:26 2023 +0100 [hotfix][docs] Add aliases for moved pages --- docs/content.zh/how-to-contribute/getting-help.md | 2 ++ docs/content.zh/what-is-flink/community.md| 2 ++ docs/content.zh/what-is-flink/powered-by.md | 2 ++ docs/content.zh/what-is-flink/roadmap.md | 2 ++ docs/content.zh/what-is-flink/security.md | 2 ++ docs/content.zh/what-is-flink/use-cases.md| 2 ++ docs/content/how-to-contribute/getting-help.md| 2 ++ docs/content/what-is-flink/community.md | 2 ++ docs/content/what-is-flink/powered-by.md | 2 ++ docs/content/what-is-flink/roadmap.md | 2 ++ docs/content/what-is-flink/security.md| 2 ++ docs/content/what-is-flink/use-cases.md | 3 +++ 12 files changed, 25 insertions(+) diff --git a/docs/content.zh/how-to-contribute/getting-help.md b/docs/content.zh/how-to-contribute/getting-help.md index c67069a35..48df75c46 100644 --- a/docs/content.zh/how-to-contribute/getting-help.md +++ b/docs/content.zh/how-to-contribute/getting-help.md @@ -2,6 +2,8 @@ title: 获取帮助 bookCollapseSection: false weight: 25 +aliases: +- /getting-help.html ---
[flink-connector-aws] branch main updated: [FLINK-32399][Connectors/Kinesis] Update shading configuration for Kinesis SQL connector to support maven 3.8.6+
This is an automated email from the ASF dual-hosted git repository. hong pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/flink-connector-aws.git The following commit(s) were added to refs/heads/main by this push: new 66826b7 [FLINK-32399][Connectors/Kinesis] Update shading configuration for Kinesis SQL connector to support maven 3.8.6+ 66826b7 is described below commit 66826b786dadf163dcca2279dc6b79c1a169521e Author: Aleksandr Pilipenko AuthorDate: Tue Jun 20 21:48:58 2023 +0100 [FLINK-32399][Connectors/Kinesis] Update shading configuration for Kinesis SQL connector to support maven 3.8.6+ --- .../flink-connector-kinesis-e2e-tests/pom.xml | 22 -- .../flink-sql-connector-kinesis/pom.xml| 13 - .../flink/connectors/kinesis/PackagingITCase.java | 15 +-- 3 files changed, 29 insertions(+), 21 deletions(-) diff --git a/flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/pom.xml b/flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/pom.xml index 0fcd759..2149419 100644 --- a/flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/pom.xml +++ b/flink-connector-aws-e2e-tests/flink-connector-kinesis-e2e-tests/pom.xml @@ -34,12 +34,6 @@ under the License. jar - - - - - - org.apache.flink flink-connector-kinesis @@ -83,6 +77,22 @@ under the License. org.apache.flink flink-test-utils-junit + + +com.fasterxml.jackson.core +jackson-databind +test + + +com.fasterxml.jackson.datatype +jackson-datatype-jsr310 +test + + +com.fasterxml.jackson.datatype +jackson-datatype-jdk8 +test + diff --git a/flink-connector-aws/flink-sql-connector-kinesis/pom.xml b/flink-connector-aws/flink-sql-connector-kinesis/pom.xml index b507151..ed086bb 100644 --- a/flink-connector-aws/flink-sql-connector-kinesis/pom.xml +++ b/flink-connector-aws/flink-sql-connector-kinesis/pom.xml @@ -67,7 +67,16 @@ under the License. -*:* +com.google.guava:guava + commons-codec:commons-codec +commons-io:commons-io + commons-lang:commons-lang + commons-logging:commons-logging + org.apache.commons:commons-lang3 + org.apache.flink:flink-connector-base + org.apache.flink:flink-connector-kinesis + org.apache.flink:flink-connector-kinesis-streams +joda-time:joda-time
[flink-connector-hbase] branch main updated: [FLINK-33250][Connector/HBase] Remove dependency on `flink-shaded`. This closes #27
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-hbase.git
The following commit(s) were added to refs/heads/main by this push:
new 5e81d4b [FLINK-33250][Connector/HBase] Remove dependency on
`flink-shaded`. This closes #27
5e81d4b is described below
commit 5e81d4b788bb0b5c8a9f0115723a30a0754ab97a
Author: MartijnVisser
AuthorDate: Thu Oct 12 15:37:11 2023 +0200
[FLINK-33250][Connector/HBase] Remove dependency on `flink-shaded`. This
closes #27
* [FLINK-33250][Connector/HBase] Remove direct dependency on `flink-shaded`
and refactor tests to use regular Java
---
.../connector/hbase2/HBaseConnectorITCase.java | 14
.../HBaseRowDataAsyncLookupFunctionTest.java | 8 +++
.../connector/hbase/util/HBaseTableSchema.java | 25 +-
pom.xml| 1 -
4 files changed, 23 insertions(+), 25 deletions(-)
diff --git
a/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
b/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
index fbd7b2c..c00b83a 100644
---
a/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
+++
b/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/HBaseConnectorITCase.java
@@ -40,8 +40,6 @@ import org.apache.flink.types.Row;
import org.apache.flink.types.RowKind;
import org.apache.flink.util.CollectionUtil;
-import org.apache.flink.shaded.guava30.com.google.common.collect.Lists;
-
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.util.Bytes;
import org.junit.ClassRule;
@@ -51,7 +49,10 @@ import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
+import java.util.Spliterator;
+import java.util.Spliterators;
import java.util.stream.Collectors;
+import java.util.stream.StreamSupport;
import static org.apache.flink.table.api.Expressions.$;
import static org.junit.Assert.assertEquals;
@@ -385,7 +386,10 @@ public class HBaseConnectorITCase extends HBaseTestBase {
TableResult tableResult3 = batchEnv.executeSql(query);
List result =
-Lists.newArrayList(tableResult3.collect()).stream()
+StreamSupport.stream(
+Spliterators.spliteratorUnknownSize(
+tableResult3.collect(),
Spliterator.ORDERED),
+false)
.map(Row::toString)
.sorted()
.collect(Collectors.toList());
@@ -470,7 +474,9 @@ public class HBaseConnectorITCase extends HBaseTestBase {
+ " FOR SYSTEM_TIME AS OF src.proc as h ON src.a =
h.rowkey";
Iterator collected = tEnv.executeSql(dimJoinQuery).collect();
List result =
-Lists.newArrayList(collected).stream()
+StreamSupport.stream(
+Spliterators.spliteratorUnknownSize(collected,
Spliterator.ORDERED),
+false)
.map(Row::toString)
.sorted()
.collect(Collectors.toList());
diff --git
a/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunctionTest.java
b/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunctionTest.java
index 312041f..98ec481 100644
---
a/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunctionTest.java
+++
b/flink-connector-hbase-2.2/src/test/java/org/apache/flink/connector/hbase2/source/HBaseRowDataAsyncLookupFunctionTest.java
@@ -25,16 +25,14 @@ import
org.apache.flink.table.connector.source.lookup.LookupOptions;
import org.apache.flink.table.data.RowData;
import org.apache.flink.table.types.DataType;
-import org.apache.flink.shaded.guava30.com.google.common.collect.Lists;
-
import org.junit.Test;
import java.util.ArrayList;
import java.util.Collection;
+import java.util.Collections;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.CountDownLatch;
-import java.util.stream.Collectors;
import static org.apache.flink.table.api.DataTypes.BIGINT;
import static org.apache.flink.table.api.DataTypes.DOUBLE;
@@ -74,8 +72,8 @@ public class HBaseRowDataAsyncLookupFunctionTest extends
HBaseTestBase {
assertTrue(result.size() < rowkeys.length);
latch.await();
lookupFunction.close();
-List sortResult =
-
Lists.newArrayList(result).stream().sorted().collect(Collectors.toList());
+List
[flink] branch master updated (35a2257af5d -> 71c407a0b94)
This is an automated email from the ASF dual-hosted git repository. chesnay pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git from 35a2257af5d [FLINK-33248] Fix error message for CURRENT_WATERMARK without arguments add 71c407a0b94 [FLINK-33199][tests] Use fully qualified class names instead of Class objects in ArchitectureTests No new revisions were added by this update. Summary of changes: .../architecture/common/JavaFieldPredicates.java | 57 ++--- .../flink/architecture/common/Predicates.java | 93 +++--- .../src/test/java/PredicatesTest.java | 48 +++ .../flink/architecture/rules/TableApiRules.java| 8 +- .../flink-architecture-tests-test/pom.xml | 18 - .../flink/architecture/rules/ITCaseRules.java | 57 - 6 files changed, 202 insertions(+), 79 deletions(-) create mode 100644 flink-architecture-tests/flink-architecture-tests-base/src/test/java/PredicatesTest.java
[flink] branch dependabot/maven/flink-connectors/flink-sql-connector-hive-3.1.3/org.apache.calcite-calcite-core-1.32.0 deleted (was e27438e3267)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/flink-connectors/flink-sql-connector-hive-3.1.3/org.apache.calcite-calcite-core-1.32.0 in repository https://gitbox.apache.org/repos/asf/flink.git was e27438e3267 Bump org.apache.calcite:calcite-core 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-33248] Fix error message for CURRENT_WATERMARK without arguments
This is an automated email from the ASF dual-hosted git repository.
dwysakowicz 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 35a2257af5d [FLINK-33248] Fix error message for CURRENT_WATERMARK
without arguments
35a2257af5d is described below
commit 35a2257af5d0cf9e671460b9770f1363b7a3d60c
Author: bvarghese1
AuthorDate: Wed Oct 11 15:20:30 2023 -0700
[FLINK-33248] Fix error message for CURRENT_WATERMARK without arguments
- When CURRENT_WATERMARK is invoked without any arguments, it fails and
returns
an IndexOutOfBoundsException
- This commit fixes it by handling for null and empty arguments thus
returning
a standard error message similar to other functions
---
.../CurrentWatermarkInputTypeStrategy.java | 4
.../planner/runtime/stream/sql/CalcITCase.scala| 25 ++
2 files changed, 29 insertions(+)
diff --git
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategy.java
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategy.java
index 5d97eef250a..764f94339dc 100644
---
a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategy.java
+++
b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/strategies/CurrentWatermarkInputTypeStrategy.java
@@ -54,6 +54,10 @@ class CurrentWatermarkInputTypeStrategy implements
InputTypeStrategy {
CallContext callContext, boolean throwOnFailure) {
final List argumentDataTypes =
callContext.getArgumentDataTypes();
+if (argumentDataTypes == null || argumentDataTypes.isEmpty()) {
+return Optional.of(Collections.emptyList());
+}
+
final DataType dataType = argumentDataTypes.get(0);
if
(!LogicalTypeChecks.canBeTimeAttributeType(dataType.getLogicalType())) {
return callContext.fail(
diff --git
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CalcITCase.scala
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CalcITCase.scala
index 2ee99119bd6..301496e37b6 100644
---
a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CalcITCase.scala
+++
b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/CalcITCase.scala
@@ -640,6 +640,31 @@ class CalcITCase extends StreamingTestBase {
}
}
+ @Test
+ def testCurrentWatermarkWithoutAnyAttribute(): Unit = {
+val tableId = TestValuesTableFactory.registerData(Seq())
+tEnv.executeSql(s"""
+ |CREATE TABLE T (
+ | ts TIMESTAMP_LTZ(3)
+ |) WITH (
+ | 'connector' = 'values',
+ | 'data-id' = '$tableId',
+ | 'bounded' = 'true'
+ |)
+ """.stripMargin)
+
+try {
+ tEnv.sqlQuery("SELECT ts, CURRENT_WATERMARK() FROM T")
+ fail("CURRENT_WATERMARK without any attribute should have failed.");
+} catch {
+ case e: Exception =>
+assertEquals(
+ "SQL validation failed. From line 1, column 12 to line 1, column 30:
" +
+"No match found for function signature CURRENT_WATERMARK()",
+ e.getMessage)
+}
+ }
+
@Test
def testCreateTemporaryTableFromDescriptor(): Unit = {
val rows = Seq(row(42))
[flink-connector-pulsar] branch main updated: [hotfix] Extend CI timeout interval
This is an automated email from the ASF dual-hosted git repository.
tison pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-pulsar.git
The following commit(s) were added to refs/heads/main by this push:
new a026020 [hotfix] Extend CI timeout interval
a026020 is described below
commit a026020b70ed108f5e2e88a4e1f1c37a5345284b
Author: tison
AuthorDate: Thu Oct 12 14:15:16 2023 +0800
[hotfix] Extend CI timeout interval
Signed-off-by: tison
---
.github/workflows/ci.yml| 4 ++--
.github/workflows/daily.yml | 3 ++-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
index 01b5245..04c3cb4 100644
--- a/.github/workflows/ci.yml
+++ b/.github/workflows/ci.yml
@@ -45,5 +45,5 @@ jobs:
uses: apache/flink-connector-shared-utils/.github/workflows/ci.yml@ci_utils
with:
flink_version: 1.17.0
- timeout_global: 80
- timeout_test: 60
+ timeout_global: 120
+ timeout_test: 80
diff --git a/.github/workflows/daily.yml b/.github/workflows/daily.yml
index 671b231..a090664 100644
--- a/.github/workflows/daily.yml
+++ b/.github/workflows/daily.yml
@@ -46,4 +46,5 @@ jobs:
flink_version: ${{ matrix.flink_branches.flink }}
connector_branch: ${{ matrix.flink_branches.branch }}
run_dependency_convergence: false
-
+ timeout_global: 120
+ timeout_test: 80
