Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin closed pull request #24255: [FLINK-31362][table] Upgrade Calcite version to 1.33.0 URL: https://github.com/apache/flink/pull/24255 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1843384012
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -4791,6 +4861,15 @@ TimeUnit Year() :
{ return warn(TimeUnit.YEAR); }
}
+TimeUnit Quarter() :
+{
+}
+{
+ { return TimeUnit.QUARTER; }
+|
+ { return warn(TimeUnit.QUARTER); }
Review Comment:
done
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1842560994
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -4935,103 +5031,75 @@ SqlIntervalQualifier IntervalQualifierStart() :
}
}
-/**
- * Parses time unit for CEIL and FLOOR functions.
- */
-TimeUnit TimeUnit() :
-{
-final TimeUnit unit;
-}
-{
-LOOKAHEAD(1)
-(
- { return TimeUnit.MILLISECOND; }
-|{ return TimeUnit.SECOND; }
-|{ return TimeUnit.MINUTE; }
-|{ return TimeUnit.HOUR; }
-|{ return TimeUnit.DAY; }
-|{ return TimeUnit.DOW; }
-|{ return TimeUnit.DOY; }
-|{ return TimeUnit.ISODOW; }
-|{ return TimeUnit.ISOYEAR; }
-|{ return TimeUnit.WEEK; }
-|{ return TimeUnit.MONTH; }
-|{ return TimeUnit.QUARTER; }
-|{ return TimeUnit.YEAR; }
-|{ return TimeUnit.EPOCH; }
-|{ return TimeUnit.DECADE; }
-|{ return TimeUnit.CENTURY; }
-|{ return TimeUnit.MILLENNIUM; }
-)
-|
-unit = TimeUnitIdentifier() { return unit; }
-}
-
-/**
- * Parses time unit for the EXTRACT function.
- * As for FLOOR and CEIL, but also includes NANOSECOND and MICROSECOND.
+/** Parses a built-in time unit (e.g. "YEAR")
+ * or user-defined time frame (e.g. "MINUTE15")
+ * and in each case returns a {@link SqlIntervalQualifier}.
+ *
+ * The units are used in several functions, incuding CEIL, FLOOR, EXTRACT.
+ * Includes NANOSECOND, MILLISECOND, which were previously allowed in EXTRACT
+ * but not CEIL, FLOOR.
+ *
+ * Includes {@code WEEK} and {@code WEEK(SUNDAY)} through
+ {@code WEEK(SATURDAY)}.
+ *
+ * Does not include SQL_TSI_DAY, SQL_TSI_FRAC_SECOND etc. These will be
+ * parsed as identifiers and can be resolved in the validator if they are
+ * registered as abbreviations in your time frame set.
*/
-TimeUnit TimeUnitForExtract() :
-{
+SqlIntervalQualifier TimeUnitOrName() : {
+final Span span;
+final String w;
final TimeUnit unit;
+final SqlIdentifier unitName;
}
{
-LOOKAHEAD(1)
+LOOKAHEAD(2)
+ { return new SqlIntervalQualifier(TimeUnit.NANOSECOND, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MICROSECOND,
null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MILLISECOND,
null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.SECOND, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MINUTE, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.HOUR, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.DAY, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.DOW, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.DOY, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.ISODOW, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.ISOYEAR, null,
getPos()); }
+|{ span = span(); }
(
- { return TimeUnit.NANOSECOND; }
-|{ return TimeUnit.MICROSECOND; }
+LOOKAHEAD(2)
+ w = weekdayName() {
+return new SqlIntervalQualifier(w, span.end(this));
+}
+|
+{ return new SqlIntervalQualifier(TimeUnit.WEEK, null, getPos()); }
)
-|
-unit = TimeUnit() { return unit; }
+|{ return new SqlIntervalQualifier(TimeUnit.MONTH, null, getPos());
}
+|{ return new SqlIntervalQualifier(TimeUnit.QUARTER, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.YEAR, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.EPOCH, null, getPos());
}
+|{ return new SqlIntervalQualifier(TimeUnit.DECADE, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.CENTURY, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MILLENNIUM, null,
getPos()); }
+| unitName = SimpleIdentifier() {
+return new SqlIntervalQualifier(unitName.getSimple(),
+unitName.getParserPosition());
+}
}
-/**
- * Parses a simple identifier as a TimeUnit.
- */
-TimeUnit TimeUnitIdentifier() :
+String weekdayName() :
{
-final List names = new ArrayList();
-final List positions = new ArrayList();
}
{
-AddIdentifierSegment(names, positions) {
-TimeUnit unit = timeUnitCodes.get(names.get(0));
-if (unit != null) {
- return unit;
-}
-throw SqlUtil.newContextException(positions.get(0),
-RESOURCE.invalidDatetimeFormat(SqlIdentifier.getString(names)));
-}
+ { return "WEEK_SUNDAY"; }
Review Comment:
there is no full e2e support here yet (on Flink side)
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apac
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255: URL: https://github.com/apache/flink/pull/24255#discussion_r1842578557 ## flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/JoinDependentConditionDerivationRuleTest.xml: ## @@ -120,7 +120,7 @@ LogicalProject(a=[$0], d=[$3])
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1842568404
##
flink-table/flink-table-calcite-bridge/pom.xml:
##
@@ -45,23 +45,23 @@ under the License.
${calcite.version}
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1842560994
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -4935,103 +5031,75 @@ SqlIntervalQualifier IntervalQualifierStart() :
}
}
-/**
- * Parses time unit for CEIL and FLOOR functions.
- */
-TimeUnit TimeUnit() :
-{
-final TimeUnit unit;
-}
-{
-LOOKAHEAD(1)
-(
- { return TimeUnit.MILLISECOND; }
-|{ return TimeUnit.SECOND; }
-|{ return TimeUnit.MINUTE; }
-|{ return TimeUnit.HOUR; }
-|{ return TimeUnit.DAY; }
-|{ return TimeUnit.DOW; }
-|{ return TimeUnit.DOY; }
-|{ return TimeUnit.ISODOW; }
-|{ return TimeUnit.ISOYEAR; }
-|{ return TimeUnit.WEEK; }
-|{ return TimeUnit.MONTH; }
-|{ return TimeUnit.QUARTER; }
-|{ return TimeUnit.YEAR; }
-|{ return TimeUnit.EPOCH; }
-|{ return TimeUnit.DECADE; }
-|{ return TimeUnit.CENTURY; }
-|{ return TimeUnit.MILLENNIUM; }
-)
-|
-unit = TimeUnitIdentifier() { return unit; }
-}
-
-/**
- * Parses time unit for the EXTRACT function.
- * As for FLOOR and CEIL, but also includes NANOSECOND and MICROSECOND.
+/** Parses a built-in time unit (e.g. "YEAR")
+ * or user-defined time frame (e.g. "MINUTE15")
+ * and in each case returns a {@link SqlIntervalQualifier}.
+ *
+ * The units are used in several functions, incuding CEIL, FLOOR, EXTRACT.
+ * Includes NANOSECOND, MILLISECOND, which were previously allowed in EXTRACT
+ * but not CEIL, FLOOR.
+ *
+ * Includes {@code WEEK} and {@code WEEK(SUNDAY)} through
+ {@code WEEK(SATURDAY)}.
+ *
+ * Does not include SQL_TSI_DAY, SQL_TSI_FRAC_SECOND etc. These will be
+ * parsed as identifiers and can be resolved in the validator if they are
+ * registered as abbreviations in your time frame set.
*/
-TimeUnit TimeUnitForExtract() :
-{
+SqlIntervalQualifier TimeUnitOrName() : {
+final Span span;
+final String w;
final TimeUnit unit;
+final SqlIdentifier unitName;
}
{
-LOOKAHEAD(1)
+LOOKAHEAD(2)
+ { return new SqlIntervalQualifier(TimeUnit.NANOSECOND, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MICROSECOND,
null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MILLISECOND,
null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.SECOND, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MINUTE, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.HOUR, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.DAY, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.DOW, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.DOY, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.ISODOW, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.ISOYEAR, null,
getPos()); }
+|{ span = span(); }
(
- { return TimeUnit.NANOSECOND; }
-|{ return TimeUnit.MICROSECOND; }
+LOOKAHEAD(2)
+ w = weekdayName() {
+return new SqlIntervalQualifier(w, span.end(this));
+}
+|
+{ return new SqlIntervalQualifier(TimeUnit.WEEK, null, getPos()); }
)
-|
-unit = TimeUnit() { return unit; }
+|{ return new SqlIntervalQualifier(TimeUnit.MONTH, null, getPos());
}
+|{ return new SqlIntervalQualifier(TimeUnit.QUARTER, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.YEAR, null, getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.EPOCH, null, getPos());
}
+|{ return new SqlIntervalQualifier(TimeUnit.DECADE, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.CENTURY, null,
getPos()); }
+|{ return new SqlIntervalQualifier(TimeUnit.MILLENNIUM, null,
getPos()); }
+| unitName = SimpleIdentifier() {
+return new SqlIntervalQualifier(unitName.getSimple(),
+unitName.getParserPosition());
+}
}
-/**
- * Parses a simple identifier as a TimeUnit.
- */
-TimeUnit TimeUnitIdentifier() :
+String weekdayName() :
{
-final List names = new ArrayList();
-final List positions = new ArrayList();
}
{
-AddIdentifierSegment(names, positions) {
-TimeUnit unit = timeUnitCodes.get(names.get(0));
-if (unit != null) {
- return unit;
-}
-throw SqlUtil.newContextException(positions.get(0),
-RESOURCE.invalidDatetimeFormat(SqlIdentifier.getString(names)));
-}
+ { return "WEEK_SUNDAY"; }
Review Comment:
there is no full e2e support here yet
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1842559184
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/validate/FlinkSqlConformance.java:
##
@@ -166,4 +166,14 @@ public boolean allowQualifyingCommonColumn() {
public SqlLibrary semantics() {
return SqlConformanceEnum.DEFAULT.semantics();
}
+
+@Override
+public boolean allowCoercionStringToArray() {
+return SqlConformanceEnum.DEFAULT.allowCoercionStringToArray();
+}
+
+@Override
+public boolean isValueAllowed() {
+return SqlConformanceEnum.DEFAULT.isValueAllowed();
Review Comment:
based on tests we could enable it
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1842558180
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -6576,11 +6649,127 @@ SqlCall TimestampDiffFunctionCall() :
}
}
+/**
+ * Parses a call to BigQuery's TIMESTAMP_DIFF.
+ *
+ * The difference between TIMESTAMPDIFF and TIMESTAMP_DIFF is the ordering
of
+ * the parameters and the arrangement of the subtraction.
+ * TIMESTAMPDIFF uses (unit, timestamp1, timestamp2) with (t2 - t1), while
+ * TIMESTAMP_DIFF uses (timestamp1, timestamp2, unit) with (t1 - t2).
+ */
+SqlCall TimestampDiff3FunctionCall() :
+{
+final List args = new ArrayList();
+final Span s;
+final SqlIntervalQualifier unit;
+}
+{
+ { s = span(); }
+
+AddExpression(args, ExprContext.ACCEPT_SUB_QUERY)
+
+AddExpression(args, ExprContext.ACCEPT_SUB_QUERY)
+
+unit = TimeUnitOrName() { args.add(unit); }
+ {
+return SqlLibraryOperators.TIMESTAMP_DIFF3.createCall(s.end(this),
args);
Review Comment:
it fails with
```
No match found for function signature timestamp_diff3 ...
```
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1842186049
##
flink-table/flink-table-planner/src/main/java/org/apache/calcite/rex/RexUtil.java:
##
@@ -0,0 +1,3176 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to you under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.calcite.rex;
+
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.Iterables;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Range;
+import org.apache.calcite.DataContexts;
+import org.apache.calcite.linq4j.function.Predicate1;
+import org.apache.calcite.plan.RelOptPredicateList;
+import org.apache.calcite.plan.RelOptUtil;
+import org.apache.calcite.rel.RelCollation;
+import org.apache.calcite.rel.RelCollations;
+import org.apache.calcite.rel.RelFieldCollation;
+import org.apache.calcite.rel.core.Filter;
+import org.apache.calcite.rel.core.Join;
+import org.apache.calcite.rel.core.Project;
+import org.apache.calcite.rel.type.RelDataType;
+import org.apache.calcite.rel.type.RelDataTypeFactory;
+import org.apache.calcite.rel.type.RelDataTypeFamily;
+import org.apache.calcite.rel.type.RelDataTypeField;
+import org.apache.calcite.rex.RexTableInputRef.RelTableRef;
+import org.apache.calcite.sql.SqlAggFunction;
+import org.apache.calcite.sql.SqlKind;
+import org.apache.calcite.sql.SqlOperator;
+import org.apache.calcite.sql.fun.SqlStdOperatorTable;
+import org.apache.calcite.sql.type.SqlTypeFamily;
+import org.apache.calcite.sql.type.SqlTypeName;
+import org.apache.calcite.sql.type.SqlTypeUtil;
+import org.apache.calcite.sql.validate.SqlValidatorUtil;
+import org.apache.calcite.util.ControlFlowException;
+import org.apache.calcite.util.ImmutableBitSet;
+import org.apache.calcite.util.Litmus;
+import org.apache.calcite.util.Pair;
+import org.apache.calcite.util.RangeSets;
+import org.apache.calcite.util.Sarg;
+import org.apache.calcite.util.Util;
+import org.apache.calcite.util.mapping.Mappings;
+import org.apiguardian.api.API;
+import org.checkerframework.checker.nullness.qual.Nullable;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Set;
+import java.util.function.Predicate;
+
+import static java.util.Objects.requireNonNull;
+
+/**
+ * Default implementation of {@link org.apache.calcite.rex.RexUtil}, the class
was copied over
+ * because of current Calcite way of inferring constants from IS NOT DISTINCT
FROM clashes with
+ * filter push down.
+ *
+ * Lines 397 ~ 399, Use Calcite 1.32.0 behavior for {@link
RexUtil#gatherConstraints(Class,
Review Comment:
https://issues.apache.org/jira/browse/FLINK-36715
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1840506133
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -4581,15 +4608,24 @@ SqlLiteral DateTimeLiteral() :
}
|
{ s = span(); } p = SimpleStringLiteral() {
- return SqlParserUtil.parseDateLiteral(p, s.end(this));
+ return SqlLiteral.createUnknown("DATE", p, s.end(this));
+}
+|
+ { s = span(); } p = SimpleStringLiteral() {
+return SqlLiteral.createUnknown("DATETIME", p, s.end(this));
}
|
{ s = span(); } p = SimpleStringLiteral() {
-return SqlParserUtil.parseTimeLiteral(p, s.end(this));
+ return SqlLiteral.createUnknown("TIME", p, s.end(this));
}
|
+LOOKAHEAD(2)
{ s = span(); } p = SimpleStringLiteral() {
-return SqlParserUtil.parseTimestampLiteral(p, s.end(this));
+return SqlLiteral.createUnknown("TIMESTAMP", p, s.end(this));
+}
+|
+ { s = span(); } p =
SimpleStringLiteral() {
Review Comment:
It passes parser however fails during planning, so probably need a follow-up
task to have it fully supported in Flink
```
[ERROR] Could not execute SQL statement. Reason:
java.lang.AssertionError: Was not expecting value
'TIMESTAMP_WITH_LOCAL_TIME_ZONE' for enumeration
'org.apache.calcite.sql.type.SqlTypeName' in this context
```
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
twalthr commented on code in PR #24255:
URL: https://github.com/apache/flink/pull/24255#discussion_r1837684705
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -4581,15 +4608,24 @@ SqlLiteral DateTimeLiteral() :
}
|
{ s = span(); } p = SimpleStringLiteral() {
- return SqlParserUtil.parseDateLiteral(p, s.end(this));
+ return SqlLiteral.createUnknown("DATE", p, s.end(this));
+}
+|
+ { s = span(); } p = SimpleStringLiteral() {
+return SqlLiteral.createUnknown("DATETIME", p, s.end(this));
}
|
{ s = span(); } p = SimpleStringLiteral() {
-return SqlParserUtil.parseTimeLiteral(p, s.end(this));
+ return SqlLiteral.createUnknown("TIME", p, s.end(this));
}
|
+LOOKAHEAD(2)
{ s = span(); } p = SimpleStringLiteral() {
-return SqlParserUtil.parseTimestampLiteral(p, s.end(this));
+return SqlLiteral.createUnknown("TIMESTAMP", p, s.end(this));
+}
+|
+ { s = span(); } p =
SimpleStringLiteral() {
Review Comment:
we should update our docs that `TIMESTAMP WITH LOCAL TIME ZONE ‘1969-07-20
20:17:40’` is supported. Is that the case now? we should add a test case.
##
flink-table/flink-sql-parser/src/main/codegen/templates/Parser.jj:
##
@@ -4503,6 +4519,17 @@ SqlNode StringLiteral() :
return SqlStdOperatorTable.LITERAL_CHAIN.createCall(pos2, rands);
}
}
+|
+
Review Comment:
update docs:
https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/overview/#syntax
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/validate/FlinkSqlConformance.java:
##
@@ -166,4 +166,14 @@ public boolean allowQualifyingCommonColumn() {
public SqlLibrary semantics() {
return SqlConformanceEnum.DEFAULT.semantics();
}
+
+@Override
+public boolean allowCoercionStringToArray() {
+return SqlConformanceEnum.DEFAULT.allowCoercionStringToArray();
+}
+
+@Override
+public boolean isValueAllowed() {
+return SqlConformanceEnum.DEFAULT.isValueAllowed();
Review Comment:
check if false, but it would be fine if it is true
##
flink-table/flink-table-calcite-bridge/pom.xml:
##
@@ -45,23 +45,23 @@ under the License.
${calcite.version}
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2467401907 Current failure is not related to the PR's changes, it is a known floating issue mentioned at FLINK-36613 -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2467399357 @flinkbot run azure -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2466973517 @flinkbot run azure -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2243935706 @flinkbot run azure -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
tjbanghart commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2234140639 Hey @snuyanzin thanks for the response! Is [CALCITE-6266](https://issues.apache.org/jira/browse/CALCITE-6266) blocking? Are we ignoring some tests in Flink because of it? I'll take a look and see if we can get some traction there. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
snuyanzin commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2233691455 hi @tjbanghart thanks for reaching out rebasing PR should be pretty straightforward (I can do that on the upcoming weekend) IIRC there was mentioned somewhere that together with Calcite 1.30/1.31 https://issues.apache.org/jira/browse/CALCITE-6266 came to Flink and it would be nice to fix it as well (i think still discussable ) -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-31362][table] Upgrade Calcite version to 1.33.0 [flink]
tjbanghart commented on PR #24255: URL: https://github.com/apache/flink/pull/24255#issuecomment-2233667009 Hey there, just wondering what would need to happen to get this and the 1.34 PR merged https://github.com/apache/flink/pull/24256 Is there anything I can do to help move this along? Happy to take a stab at the merge conflicts. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
