[jira] [Created] (FLINK-13045) Move Scala expression DSL to flink-table-api-scala

Timo Walther created FLINK-13045: Summary: Move Scala expression DSL to flink-table-api-scala Key: FLINK-13045 URL: https://issues.apache.org/jira/browse/FLINK-13045 Project: Flink Issue Type

[jira] [Created] (FLINK-13078) Add a type parser utility

Timo Walther created FLINK-13078: Summary: Add a type parser utility Key: FLINK-13078 URL: https://issues.apache.org/jira/browse/FLINK-13078 Project: Flink Issue Type: Sub-task Comp

[jira] [Created] (FLINK-13191) Add a simplified UDF type extraction

Timo Walther created FLINK-13191: Summary: Add a simplified UDF type extraction Key: FLINK-13191 URL: https://issues.apache.org/jira/browse/FLINK-13191 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13262) Add documentation for the new Table & SQL API type system

Timo Walther created FLINK-13262: Summary: Add documentation for the new Table & SQL API type system Key: FLINK-13262 URL: https://issues.apache.org/jira/browse/FLINK-13262 Project: Flink Iss

[jira] [Created] (FLINK-13264) Remove planner class clashes for planner type inference lookups

Timo Walther created FLINK-13264: Summary: Remove planner class clashes for planner type inference lookups Key: FLINK-13264 URL: https://issues.apache.org/jira/browse/FLINK-13264 Project: Flink

[jira] [Created] (FLINK-13273) Allow switching planners in SQL Client

Timo Walther created FLINK-13273: Summary: Allow switching planners in SQL Client Key: FLINK-13273 URL: https://issues.apache.org/jira/browse/FLINK-13273 Project: Flink Issue Type: New Featur

[jira] [Created] (FLINK-13335) Align the SQL DDL with FLIP-37

Timo Walther created FLINK-13335: Summary: Align the SQL DDL with FLIP-37 Key: FLINK-13335 URL: https://issues.apache.org/jira/browse/FLINK-13335 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13350) Distinguish between temporary tables and persisted tables

Timo Walther created FLINK-13350: Summary: Distinguish between temporary tables and persisted tables Key: FLINK-13350 URL: https://issues.apache.org/jira/browse/FLINK-13350 Project: Flink Iss

[jira] [Created] (FLINK-13385) Align Hive data type mapping with FLIP-37

Timo Walther created FLINK-13385: Summary: Align Hive data type mapping with FLIP-37 Key: FLINK-13385 URL: https://issues.apache.org/jira/browse/FLINK-13385 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13400) Remove Hive and Hadoop dependencies from SQL Client

Timo Walther created FLINK-13400: Summary: Remove Hive and Hadoop dependencies from SQL Client Key: FLINK-13400 URL: https://issues.apache.org/jira/browse/FLINK-13400 Project: Flink Issue Typ

[jira] [Created] (FLINK-13419) TableEnvironment.explain() has side-effects on ExecutionConfig

Timo Walther created FLINK-13419: Summary: TableEnvironment.explain() has side-effects on ExecutionConfig Key: FLINK-13419 URL: https://issues.apache.org/jira/browse/FLINK-13419 Project: Flink

[jira] [Created] (FLINK-13429) SQL Client end-to-end test fails on Travis

Timo Walther created FLINK-13429: Summary: SQL Client end-to-end test fails on Travis Key: FLINK-13429 URL: https://issues.apache.org/jira/browse/FLINK-13429 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13458) ThreadLocalCache clashes for Blink planner

Timo Walther created FLINK-13458: Summary: ThreadLocalCache clashes for Blink planner Key: FLINK-13458 URL: https://issues.apache.org/jira/browse/FLINK-13458 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-13463) SQL VALUES might fail for Blink planner

Timo Walther created FLINK-13463: Summary: SQL VALUES might fail for Blink planner Key: FLINK-13463 URL: https://issues.apache.org/jira/browse/FLINK-13463 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13466) Rename Batch/StreamTableSourceFactory methods for avoiding name clashes

Timo Walther created FLINK-13466: Summary: Rename Batch/StreamTableSourceFactory methods for avoiding name clashes Key: FLINK-13466 URL: https://issues.apache.org/jira/browse/FLINK-13466 Project: Flin

[jira] [Created] (FLINK-13600) TableEnvironment.connect() is not usable

Timo Walther created FLINK-13600: Summary: TableEnvironment.connect() is not usable Key: FLINK-13600 URL: https://issues.apache.org/jira/browse/FLINK-13600 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-13649) Improve error message when job submission was not successful

Timo Walther created FLINK-13649: Summary: Improve error message when job submission was not successful Key: FLINK-13649 URL: https://issues.apache.org/jira/browse/FLINK-13649 Project: Flink

[jira] [Created] (FLINK-13691) Remove deprecated query config

Timo Walther created FLINK-13691: Summary: Remove deprecated query config Key: FLINK-13691 URL: https://issues.apache.org/jira/browse/FLINK-13691 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-32466) Invalid input strategy for CONCAT allows BINARY strings

Timo Walther created FLINK-32466: Summary: Invalid input strategy for CONCAT allows BINARY strings Key: FLINK-32466 URL: https://issues.apache.org/jira/browse/FLINK-32466 Project: Flink Issue

[jira] [Created] (FLINK-32470) SqlValidateException should be exposed as ValidationException

Timo Walther created FLINK-32470: Summary: SqlValidateException should be exposed as ValidationException Key: FLINK-32470 URL: https://issues.apache.org/jira/browse/FLINK-32470 Project: Flink

[jira] [Created] (FLINK-32613) Disable check for single rowtime attribute for sinks

Timo Walther created FLINK-32613: Summary: Disable check for single rowtime attribute for sinks Key: FLINK-32613 URL: https://issues.apache.org/jira/browse/FLINK-32613 Project: Flink Issue Ty

[jira] [Created] (FLINK-32657) Revert upgrading ExecNode versions for StateMetadata

Timo Walther created FLINK-32657: Summary: Revert upgrading ExecNode versions for StateMetadata Key: FLINK-32657 URL: https://issues.apache.org/jira/browse/FLINK-32657 Project: Flink Issue Ty

[jira] [Created] (FLINK-32689) Insufficient validation for table.local-time-zone

Timo Walther created FLINK-32689: Summary: Insufficient validation for table.local-time-zone Key: FLINK-32689 URL: https://issues.apache.org/jira/browse/FLINK-32689 Project: Flink Issue Type:

[jira] [Created] (FLINK-33028) FLIP-348: Make expanding behavior of virtual metadata columns configurable

Timo Walther created FLINK-33028: Summary: FLIP-348: Make expanding behavior of virtual metadata columns configurable Key: FLINK-33028 URL: https://issues.apache.org/jira/browse/FLINK-33028 Project: F

[jira] [Created] (FLINK-33169) Window TVFs don't consider column expansion

Timo Walther created FLINK-33169: Summary: Window TVFs don't consider column expansion Key: FLINK-33169 URL: https://issues.apache.org/jira/browse/FLINK-33169 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-33182) Allow metadata columns in NduAnalyzer with ChangelogNormalize

Timo Walther created FLINK-33182: Summary: Allow metadata columns in NduAnalyzer with ChangelogNormalize Key: FLINK-33182 URL: https://issues.apache.org/jira/browse/FLINK-33182 Project: Flink

[jira] [Created] (FLINK-33183) Enable metadata columns in NduAnalyzer with retract if non-virtual

Timo Walther created FLINK-33183: Summary: Enable metadata columns in NduAnalyzer with retract if non-virtual Key: FLINK-33183 URL: https://issues.apache.org/jira/browse/FLINK-33183 Project: Flink

[jira] [Created] (FLINK-33447) Avoid CompiledPlan recompilation during loading

Timo Walther created FLINK-33447: Summary: Avoid CompiledPlan recompilation during loading Key: FLINK-33447 URL: https://issues.apache.org/jira/browse/FLINK-33447 Project: Flink Issue Type: S

[jira] [Created] (FLINK-33494) FLIP-376: Add DISTRIBUTED BY clause

Timo Walther created FLINK-33494: Summary: FLIP-376: Add DISTRIBUTED BY clause Key: FLINK-33494 URL: https://issues.apache.org/jira/browse/FLINK-33494 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33495) Add catalog and connector ability API and validation

Timo Walther created FLINK-33495: Summary: Add catalog and connector ability API and validation Key: FLINK-33495 URL: https://issues.apache.org/jira/browse/FLINK-33495 Project: Flink Issue Ty

[jira] [Created] (FLINK-33496) Expose DISTRIBUTED BY clause via parser

Timo Walther created FLINK-33496: Summary: Expose DISTRIBUTED BY clause via parser Key: FLINK-33496 URL: https://issues.apache.org/jira/browse/FLINK-33496 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33497) Update the Kafka connector to support DISTRIBUTED BY clause

Timo Walther created FLINK-33497: Summary: Update the Kafka connector to support DISTRIBUTED BY clause Key: FLINK-33497 URL: https://issues.apache.org/jira/browse/FLINK-33497 Project: Flink

[jira] [Created] (FLINK-33666) MergeTableLikeUtil uses different constraint name than Schema

Timo Walther created FLINK-33666: Summary: MergeTableLikeUtil uses different constraint name than Schema Key: FLINK-33666 URL: https://issues.apache.org/jira/browse/FLINK-33666 Project: Flink

[jira] [Created] (FLINK-33784) CatalogStoreFactory can not be configured via StreamExecutionEnvironment

Timo Walther created FLINK-33784: Summary: CatalogStoreFactory can not be configured via StreamExecutionEnvironment Key: FLINK-33784 URL: https://issues.apache.org/jira/browse/FLINK-33784 Project: Fli

[jira] [Created] (FLINK-15915) Bump Jackson to 2.10.1 in flink-table-planner

Timo Walther created FLINK-15915: Summary: Bump Jackson to 2.10.1 in flink-table-planner Key: FLINK-15915 URL: https://issues.apache.org/jira/browse/FLINK-15915 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15958) Fully support RAW types in the API

Timo Walther created FLINK-15958: Summary: Fully support RAW types in the API Key: FLINK-15958 URL: https://issues.apache.org/jira/browse/FLINK-15958 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16021) DescriptorProperties.putTableSchema does not include constraints

Timo Walther created FLINK-16021: Summary: DescriptorProperties.putTableSchema does not include constraints Key: FLINK-16021 URL: https://issues.apache.org/jira/browse/FLINK-16021 Project: Flink

[jira] [Created] (FLINK-16047) Blink planner produces wrong aggregate results with state clean up

Timo Walther created FLINK-16047: Summary: Blink planner produces wrong aggregate results with state clean up Key: FLINK-16047 URL: https://issues.apache.org/jira/browse/FLINK-16047 Project: Flink

[jira] [Created] (FLINK-16258) Update test utilities to FLIP-65

Timo Walther created FLINK-16258: Summary: Update test utilities to FLIP-65 Key: FLINK-16258 URL: https://issues.apache.org/jira/browse/FLINK-16258 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16261) Avoid unnecessary casting in TypeInferenceOperandChecker

Timo Walther created FLINK-16261: Summary: Avoid unnecessary casting in TypeInferenceOperandChecker Key: FLINK-16261 URL: https://issues.apache.org/jira/browse/FLINK-16261 Project: Flink Issu

[jira] [Created] (FLINK-16314) Revisit FlinkTypeFactory

Timo Walther created FLINK-16314: Summary: Revisit FlinkTypeFactory Key: FLINK-16314 URL: https://issues.apache.org/jira/browse/FLINK-16314 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-16336) Support new type inference for temporal table functions

Timo Walther created FLINK-16336: Summary: Support new type inference for temporal table functions Key: FLINK-16336 URL: https://issues.apache.org/jira/browse/FLINK-16336 Project: Flink Issue

[jira] [Created] (FLINK-16344) Preserve nullability for nested types

Timo Walther created FLINK-16344: Summary: Preserve nullability for nested types Key: FLINK-16344 URL: https://issues.apache.org/jira/browse/FLINK-16344 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16679) Investigate more efficient outer join plans

Timo Walther created FLINK-16679: Summary: Investigate more efficient outer join plans Key: FLINK-16679 URL: https://issues.apache.org/jira/browse/FLINK-16679 Project: Flink Issue Type: Impro

[jira] [Created] (FLINK-16779) Support RAW types through the stack

Timo Walther created FLINK-16779: Summary: Support RAW types through the stack Key: FLINK-16779 URL: https://issues.apache.org/jira/browse/FLINK-16779 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16835) Replace TableConfig with Configuration

Timo Walther created FLINK-16835: Summary: Replace TableConfig with Configuration Key: FLINK-16835 URL: https://issues.apache.org/jira/browse/FLINK-16835 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-16987) Add new table source and sink interfaces

Timo Walther created FLINK-16987: Summary: Add new table source and sink interfaces Key: FLINK-16987 URL: https://issues.apache.org/jira/browse/FLINK-16987 Project: Flink Issue Type: New Feat

[jira] [Created] (FLINK-16988) Add core table source/sink interfaces

Timo Walther created FLINK-16988: Summary: Add core table source/sink interfaces Key: FLINK-16988 URL: https://issues.apache.org/jira/browse/FLINK-16988 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16989) Support ScanTableSource in planner

Timo Walther created FLINK-16989: Summary: Support ScanTableSource in planner Key: FLINK-16989 URL: https://issues.apache.org/jira/browse/FLINK-16989 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16990) Support LookupTableSource in planner

Timo Walther created FLINK-16990: Summary: Support LookupTableSource in planner Key: FLINK-16990 URL: https://issues.apache.org/jira/browse/FLINK-16990 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16991) Support DynamicTableSink in planner

Timo Walther created FLINK-16991: Summary: Support DynamicTableSink in planner Key: FLINK-16991 URL: https://issues.apache.org/jira/browse/FLINK-16991 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16992) Add ability interfaces for table source/sink

Timo Walther created FLINK-16992: Summary: Add ability interfaces for table source/sink Key: FLINK-16992 URL: https://issues.apache.org/jira/browse/FLINK-16992 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-16993) Support SupportsComputedColumnPushDown in planner

Timo Walther created FLINK-16993: Summary: Support SupportsComputedColumnPushDown in planner Key: FLINK-16993 URL: https://issues.apache.org/jira/browse/FLINK-16993 Project: Flink Issue Type:

[jira] [Created] (FLINK-16994) Support SupportsWatermarkPushDown in planner

Timo Walther created FLINK-16994: Summary: Support SupportsWatermarkPushDown in planner Key: FLINK-16994 URL: https://issues.apache.org/jira/browse/FLINK-16994 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-16995) Add new data structure interfaces in table-common

Timo Walther created FLINK-16995: Summary: Add new data structure interfaces in table-common Key: FLINK-16995 URL: https://issues.apache.org/jira/browse/FLINK-16995 Project: Flink Issue Type:

[jira] [Created] (FLINK-16996) Refactor planner and connectors to use new data structures

Timo Walther created FLINK-16996: Summary: Refactor planner and connectors to use new data structures Key: FLINK-16996 URL: https://issues.apache.org/jira/browse/FLINK-16996 Project: Flink Is

[jira] [Created] (FLINK-16997) Add new factory interfaces and utilities

Timo Walther created FLINK-16997: Summary: Add new factory interfaces and utilities Key: FLINK-16997 URL: https://issues.apache.org/jira/browse/FLINK-16997 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-16998) Add a changeflag to Row type

Timo Walther created FLINK-16998: Summary: Add a changeflag to Row type Key: FLINK-16998 URL: https://issues.apache.org/jira/browse/FLINK-16998 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-16999) Data structure should cover all conversions declared in logical types

Timo Walther created FLINK-16999: Summary: Data structure should cover all conversions declared in logical types Key: FLINK-16999 URL: https://issues.apache.org/jira/browse/FLINK-16999 Project: Flink

[jira] [Created] (FLINK-17000) Type information in sources should cover all data structures

Timo Walther created FLINK-17000: Summary: Type information in sources should cover all data structures Key: FLINK-17000 URL: https://issues.apache.org/jira/browse/FLINK-17000 Project: Flink

[jira] [Created] (FLINK-17030) Add primary key syntax to DDL

Timo Walther created FLINK-17030: Summary: Add primary key syntax to DDL Key: FLINK-17030 URL: https://issues.apache.org/jira/browse/FLINK-17030 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17158) Watermark strategy property cannot be expressed in YAML

Timo Walther created FLINK-17158: Summary: Watermark strategy property cannot be expressed in YAML Key: FLINK-17158 URL: https://issues.apache.org/jira/browse/FLINK-17158 Project: Flink Issue

[jira] [Created] (FLINK-17189) Table with processing time attribute can not be read from Hive catalog

Timo Walther created FLINK-17189: Summary: Table with processing time attribute can not be read from Hive catalog Key: FLINK-17189 URL: https://issues.apache.org/jira/browse/FLINK-17189 Project: Flink

[jira] [Created] (FLINK-17190) SQL client does not support views that reference a table from DDL

Timo Walther created FLINK-17190: Summary: SQL client does not support views that reference a table from DDL Key: FLINK-17190 URL: https://issues.apache.org/jira/browse/FLINK-17190 Project: Flink

[jira] [Created] (FLINK-17370) Ensure deterministic type inference extraction

Timo Walther created FLINK-17370: Summary: Ensure deterministic type inference extraction Key: FLINK-17370 URL: https://issues.apache.org/jira/browse/FLINK-17370 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-17373) Support the NULL type for function calls

Timo Walther created FLINK-17373: Summary: Support the NULL type for function calls Key: FLINK-17373 URL: https://issues.apache.org/jira/browse/FLINK-17373 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14437) Drop the legacy planner

Timo Walther created FLINK-14437: Summary: Drop the legacy planner Key: FLINK-14437 URL: https://issues.apache.org/jira/browse/FLINK-14437 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-14438) Fix RowTypeInfo.equals()

Timo Walther created FLINK-14438: Summary: Fix RowTypeInfo.equals() Key: FLINK-14438 URL: https://issues.apache.org/jira/browse/FLINK-14438 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-14903) Relax structured types constraints

Timo Walther created FLINK-14903: Summary: Relax structured types constraints Key: FLINK-14903 URL: https://issues.apache.org/jira/browse/FLINK-14903 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-14904) Rename ANY type to RAW type

Timo Walther created FLINK-14904: Summary: Rename ANY type to RAW type Key: FLINK-14904 URL: https://issues.apache.org/jira/browse/FLINK-14904 Project: Flink Issue Type: Sub-task Co

[jira] [Created] (FLINK-14967) Add a utility for creating data types via reflection

Timo Walther created FLINK-14967: Summary: Add a utility for creating data types via reflection Key: FLINK-14967 URL: https://issues.apache.org/jira/browse/FLINK-14967 Project: Flink Issue Ty

[jira] [Created] (FLINK-14983) Add interfaces for input type inference

Timo Walther created FLINK-14983: Summary: Add interfaces for input type inference Key: FLINK-14983 URL: https://issues.apache.org/jira/browse/FLINK-14983 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-15009) Add a utility for creating type inference logic via reflection

Timo Walther created FLINK-15009: Summary: Add a utility for creating type inference logic via reflection Key: FLINK-15009 URL: https://issues.apache.org/jira/browse/FLINK-15009 Project: Flink

[jira] [Created] (FLINK-15149) Merge InputTypeStrategy and InputTypeValidator

Timo Walther created FLINK-15149: Summary: Merge InputTypeStrategy and InputTypeValidator Key: FLINK-15149 URL: https://issues.apache.org/jira/browse/FLINK-15149 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-15162) Merge Java and Scala ClosureCleaner

Timo Walther created FLINK-15162: Summary: Merge Java and Scala ClosureCleaner Key: FLINK-15162 URL: https://issues.apache.org/jira/browse/FLINK-15162 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15281) Map Flink's TypeInference to Calcite's interfaces

Timo Walther created FLINK-15281: Summary: Map Flink's TypeInference to Calcite's interfaces Key: FLINK-15281 URL: https://issues.apache.org/jira/browse/FLINK-15281 Project: Flink Issue Type:

[jira] [Created] (FLINK-15331) Create a table from a changelog

Timo Walther created FLINK-15331: Summary: Create a table from a changelog Key: FLINK-15331 URL: https://issues.apache.org/jira/browse/FLINK-15331 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-15336) Support temporal table function outer joins

Timo Walther created FLINK-15336: Summary: Support temporal table function outer joins Key: FLINK-15336 URL: https://issues.apache.org/jira/browse/FLINK-15336 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-15487) Expose the new type inference for scalar functions

Timo Walther created FLINK-15487: Summary: Expose the new type inference for scalar functions Key: FLINK-15487 URL: https://issues.apache.org/jira/browse/FLINK-15487 Project: Flink Issue Type

[jira] [Created] (FLINK-15572) Function DDL is not compliant with FLIP-64

Timo Walther created FLINK-15572: Summary: Function DDL is not compliant with FLIP-64 Key: FLINK-15572 URL: https://issues.apache.org/jira/browse/FLINK-15572 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-15600) Further relax the UDF constraints for Java classes

Timo Walther created FLINK-15600: Summary: Further relax the UDF constraints for Java classes Key: FLINK-15600 URL: https://issues.apache.org/jira/browse/FLINK-15600 Project: Flink Issue Type

[jira] [Created] (FLINK-15612) Implement a DataTypeLookup

Timo Walther created FLINK-15612: Summary: Implement a DataTypeLookup Key: FLINK-15612 URL: https://issues.apache.org/jira/browse/FLINK-15612 Project: Flink Issue Type: Sub-task Com

[jira] [Created] (FLINK-15635) Allow passing a ClassLoader to EnvironmentSettings

Timo Walther created FLINK-15635: Summary: Allow passing a ClassLoader to EnvironmentSettings Key: FLINK-15635 URL: https://issues.apache.org/jira/browse/FLINK-15635 Project: Flink Issue Type

[jira] [Created] (FLINK-15802) Expose the new type inference for table functions

Timo Walther created FLINK-15802: Summary: Expose the new type inference for table functions Key: FLINK-15802 URL: https://issues.apache.org/jira/browse/FLINK-15802 Project: Flink Issue Type:

[jira] [Created] (FLINK-15803) Expose the new type inference for aggregate functions

Timo Walther created FLINK-15803: Summary: Expose the new type inference for aggregate functions Key: FLINK-15803 URL: https://issues.apache.org/jira/browse/FLINK-15803 Project: Flink Issue T

[jira] [Created] (FLINK-15804) Support the new type inference in Scala Table API functions

Timo Walther created FLINK-15804: Summary: Support the new type inference in Scala Table API functions Key: FLINK-15804 URL: https://issues.apache.org/jira/browse/FLINK-15804 Project: Flink

[jira] [Created] (FLINK-9361) Changing refresh interval in changelog mode leads to exception

Timo Walther created FLINK-9361: --- Summary: Changing refresh interval in changelog mode leads to exception Key: FLINK-9361 URL: https://issues.apache.org/jira/browse/FLINK-9361 Project: Flink I

[jira] [Created] (FLINK-9391) Support UNNEST in Table API

Timo Walther created FLINK-9391: --- Summary: Support UNNEST in Table API Key: FLINK-9391 URL: https://issues.apache.org/jira/browse/FLINK-9391 Project: Flink Issue Type: New Feature Com

[jira] [Created] (FLINK-9412) Add a REST-based SQL Client Gateway

Timo Walther created FLINK-9412: --- Summary: Add a REST-based SQL Client Gateway Key: FLINK-9412 URL: https://issues.apache.org/jira/browse/FLINK-9412 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-9420) Add tests for SQL IN sub-query operator in streaming

Timo Walther created FLINK-9420: --- Summary: Add tests for SQL IN sub-query operator in streaming Key: FLINK-9420 URL: https://issues.apache.org/jira/browse/FLINK-9420 Project: Flink Issue Type:

[jira] [Created] (FLINK-9424) BlobClientSslTest does not work in all environments

Timo Walther created FLINK-9424: --- Summary: BlobClientSslTest does not work in all environments Key: FLINK-9424 URL: https://issues.apache.org/jira/browse/FLINK-9424 Project: Flink Issue Type: T

[jira] [Created] (FLINK-9520) JarFileCreator does not support Java MethodReferences

Timo Walther created FLINK-9520: --- Summary: JarFileCreator does not support Java MethodReferences Key: FLINK-9520 URL: https://issues.apache.org/jira/browse/FLINK-9520 Project: Flink Issue Type:

[jira] [Created] (FLINK-9531) Improve logging during type extraction of the Row type

Timo Walther created FLINK-9531: --- Summary: Improve logging during type extraction of the Row type Key: FLINK-9531 URL: https://issues.apache.org/jira/browse/FLINK-9531 Project: Flink Issue Type

[jira] [Created] (FLINK-9556) Scala TypeAnalyzer does not consider ResultTypeQueryable

Timo Walther created FLINK-9556: --- Summary: Scala TypeAnalyzer does not consider ResultTypeQueryable Key: FLINK-9556 URL: https://issues.apache.org/jira/browse/FLINK-9556 Project: Flink Issue Ty

[jira] [Created] (FLINK-9568) Wrong error handling for batch input formats with invalid paths

Timo Walther created FLINK-9568: --- Summary: Wrong error handling for batch input formats with invalid paths Key: FLINK-9568 URL: https://issues.apache.org/jira/browse/FLINK-9568 Project: Flink

[jira] [Created] (FLINK-9578) Allow to define an auto watermark interval in SQL Client

Timo Walther created FLINK-9578: --- Summary: Allow to define an auto watermark interval in SQL Client Key: FLINK-9578 URL: https://issues.apache.org/jira/browse/FLINK-9578 Project: Flink Issue Ty

[jira] [Created] (FLINK-9740) Support group windows over intervals of months

Timo Walther created FLINK-9740: --- Summary: Support group windows over intervals of months Key: FLINK-9740 URL: https://issues.apache.org/jira/browse/FLINK-9740 Project: Flink Issue Type: New F

[jira] [Created] (FLINK-9765) Improve CLI responsiveness when cluster is not reachable

Timo Walther created FLINK-9765: --- Summary: Improve CLI responsiveness when cluster is not reachable Key: FLINK-9765 URL: https://issues.apache.org/jira/browse/FLINK-9765 Project: Flink Issue Ty

[jira] [Created] (FLINK-9774) Allow to pass a string-based cluster identifier to command line

Timo Walther created FLINK-9774: --- Summary: Allow to pass a string-based cluster identifier to command line Key: FLINK-9774 URL: https://issues.apache.org/jira/browse/FLINK-9774 Project: Flink

[jira] [Created] (FLINK-9775) BucketingSink E2E test fails in certain environments

Timo Walther created FLINK-9775: --- Summary: BucketingSink E2E test fails in certain environments Key: FLINK-9775 URL: https://issues.apache.org/jira/browse/FLINK-9775 Project: Flink Issue Type:

  1   2   3   4   5   6   7   >