[jira] [Commented] (FLINK-18788) Refactor sql-client based the proposed interfaces of FLIP-84

[ https://issues.apache.org/jira/browse/FLINK-18788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313640#comment-17313640 ] Jark Wu commented on FLINK-18788: - Have all the tasks been completed? Could we close this [~godfreyhe]?

[jira] [Updated] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16799: Fix Version/s: 1.14.0 > add hive partition limit when read from hive >

[jira] [Updated] (FLINK-16799) add hive partition limit when read from hive

[ https://issues.apache.org/jira/browse/FLINK-16799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16799: Fix Version/s: (was: 1.13.0) > add hive partition limit when read from hive >

[jira] [Updated] (FLINK-21286) Support BUCKET for flink sql CREATE TABLE

[ https://issues.apache.org/jira/browse/FLINK-21286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21286: Fix Version/s: (was: 1.13.0) > Support BUCKET for flink sql CREATE TABLE >

[jira] [Updated] (FLINK-21247) flink iceberg table map cannot convert to datastream

[ https://issues.apache.org/jira/browse/FLINK-21247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21247: Fix Version/s: (was: 1.12.3) (was: 1.13.0) > flink iceberg table map cannot

[jira] [Updated] (FLINK-21281) Support DELETE FROM for flink sql

[ https://issues.apache.org/jira/browse/FLINK-21281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21281: Fix Version/s: (was: 1.13.0) > Support DELETE FROM for flink sql >

[jira] [Updated] (FLINK-15585) Improve function identifier string in plan digest

[ https://issues.apache.org/jira/browse/FLINK-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15585: Fix Version/s: (was: 1.13.0) 1.14.0 > Improve function identifier string in plan

[jira] [Commented] (FLINK-16776) Support schema evolution for Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313639#comment-17313639 ] Jark Wu commented on FLINK-16776: - Do we already finished this issue? Could we close this? > Support

[jira] [Updated] (FLINK-16776) Support schema evolution for Hive tables

[ https://issues.apache.org/jira/browse/FLINK-16776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16776: Fix Version/s: (was: 1.13.0) 1.14.0 > Support schema evolution for Hive tables >

[jira] [Updated] (FLINK-17909) Add a TestCatalog to hold the serialized meta data to uncover more potential bugs

[ https://issues.apache.org/jira/browse/FLINK-17909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17909: Fix Version/s: (was: 1.13.0) > Add a TestCatalog to hold the serialized meta data to uncover more

[jira] [Updated] (FLINK-15678) Optimize producing primary key without row number in special Top 1

[ https://issues.apache.org/jira/browse/FLINK-15678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15678: Fix Version/s: (was: 1.13.0) > Optimize producing primary key without row number in special Top 1 >

[jira] [Updated] (FLINK-18711) Trim the blank space for TableOptions

[ https://issues.apache.org/jira/browse/FLINK-18711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18711: Fix Version/s: (was: 1.13.0) > Trim the blank space for TableOptions >

[jira] [Closed] (FLINK-18791) Simplify the logic of SqlCommandParser and CliClient

[ https://issues.apache.org/jira/browse/FLINK-18791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18791. --- Resolution: Fixed Fixed by FLINK-21463. > Simplify the logic of SqlCommandParser and CliClient >

[jira] [Updated] (FLINK-19038) It doesn't support to call Table.limit() continuously

[ https://issues.apache.org/jira/browse/FLINK-19038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19038: Fix Version/s: (was: 1.13.0) 1.14.0 > It doesn't support to call Table.limit()

[jira] [Updated] (FLINK-19722) Pushdown Watermark to SourceProvider (new Source)

[ https://issues.apache.org/jira/browse/FLINK-19722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19722: Fix Version/s: (was: 1.13.0) 1.14.0 > Pushdown Watermark to SourceProvider (new

[jira] [Updated] (FLINK-19659) Array type supports equals and not_equals operator when element types are different but castable

[ https://issues.apache.org/jira/browse/FLINK-19659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19659: Fix Version/s: (was: 1.13.0) 1.14.0 > Array type supports equals and not_equals

[jira] [Updated] (FLINK-20026) Jdbc connector support regular expression

[ https://issues.apache.org/jira/browse/FLINK-20026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20026: Fix Version/s: (was: 1.13.0) > Jdbc connector support regular expression >

[jira] [Commented] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313635#comment-17313635 ] Jark Wu commented on FLINK-13015: - Change the fix version to 1.14.0 since we already reached feature

[jira] [Updated] (FLINK-13015) Create validators, strategies and transformations required for porting logical expressions

[ https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13015: Fix Version/s: (was: 1.13.0) 1.14.0 > Create validators, strategies and

[jira] [Updated] (FLINK-20036) Join Has NoUniqueKey when using mini-batch

[ https://issues.apache.org/jira/browse/FLINK-20036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20036: Fix Version/s: (was: 1.13.0) 1.14.0 > Join Has NoUniqueKey when using mini-batch >

[jira] [Updated] (FLINK-16143) Turn on more date time functions of blink planner

[ https://issues.apache.org/jira/browse/FLINK-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16143: Fix Version/s: (was: 1.13.0) 1.14.0 > Turn on more date time functions of blink

[jira] [Comment Edited] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313628#comment-17313628 ] Caizhi Weng edited comment on FLINK-22047 at 4/2/21, 6:52 AM: -- Hi [~hayden

[jira] [Updated] (FLINK-15553) Create table ddl support comment after computed column

[ https://issues.apache.org/jira/browse/FLINK-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15553: Fix Version/s: (was: 1.13.0) 1.14.0 > Create table ddl support comment after

[jira] [Updated] (FLINK-15556) Add a switch for PushProjectIntoTableSourceScanRule

[ https://issues.apache.org/jira/browse/FLINK-15556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15556: Fix Version/s: (was: 1.13.0) > Add a switch for PushProjectIntoTableSourceScanRule >

[jira] [Updated] (FLINK-19363) Code of split method grows beyond 64 KB

[ https://issues.apache.org/jira/browse/FLINK-19363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19363: Fix Version/s: (was: 1.13.0) 1.14.0 > Code of split method grows beyond 64 KB >

[jira] [Updated] (FLINK-17856) Adds the feature of monitoring directory changes for FileSystem table source connector

[ https://issues.apache.org/jira/browse/FLINK-17856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17856: Fix Version/s: (was: 1.13.0) > Adds the feature of monitoring directory changes for FileSystem table

[jira] [Commented] (FLINK-20787) Improve the Table API to make it usable

[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313634#comment-17313634 ] Jark Wu commented on FLINK-20787: - Change the fix version to 1.14.0 since we already reached feature

[jira] [Updated] (FLINK-19541) Improve hiveConfDir for HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-19541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19541: Fix Version/s: (was: 1.13.0) > Improve hiveConfDir for HiveCatalog >

[jira] [Updated] (FLINK-20787) Improve the Table API to make it usable

[ https://issues.apache.org/jira/browse/FLINK-20787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20787: Fix Version/s: (was: 1.13.0) 1.14.0 > Improve the Table API to make it usable >

[jira] [Commented] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313633#comment-17313633 ] Jark Wu commented on FLINK-12352: - Change the fix version to 1.14.0 since we already reached feature

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12352: Fix Version/s: (was: 1.13.0) 1.14.0 > [FLIP-36] [Phase 1] Support cache() /

[jira] [Updated] (FLINK-21058) Add SHOW PARTITION syntax support for flink

[ https://issues.apache.org/jira/browse/FLINK-21058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21058: Fix Version/s: (was: 1.13.0) > Add SHOW PARTITION syntax support for flink >

[jira] [Updated] (FLINK-20091) Introduce avro.ignore-parse-errors for AvroRowDataDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-20091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20091: Fix Version/s: (was: 1.13.0) 1.14.0 > Introduce avro.ignore-parse-errors for

[jira] [Closed] (FLINK-21183) Support watermark for Hive streaming source

[ https://issues.apache.org/jira/browse/FLINK-21183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21183. --- Fix Version/s: (was: 1.13.0) Resolution: Duplicate > Support watermark for Hive streaming source

[jira] [Updated] (FLINK-20487) Support to consume retractions for window aggregate operator

[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20487: Fix Version/s: (was: 1.13.0) 1.14.0 > Support to consume retractions for window

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21634: Fix Version/s: 1.14.0 > ALTER TABLE statement enhancement > - > >

[jira] [Updated] (FLINK-16466) Group by on event time should produce insert only result

[ https://issues.apache.org/jira/browse/FLINK-16466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16466: Fix Version/s: (was: 1.13.0) 1.14.0 > Group by on event time should produce insert

[jira] [Updated] (FLINK-16332) Support un-ordered mode for async lookup join

[ https://issues.apache.org/jira/browse/FLINK-16332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16332: Fix Version/s: (was: 1.13.0) > Support un-ordered mode for async lookup join >

[jira] [Updated] (FLINK-18508) Dynamic source supports statistics and parallelism report

[ https://issues.apache.org/jira/browse/FLINK-18508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18508: Fix Version/s: (was: 1.13.0) > Dynamic source supports statistics and parallelism report >

[jira] [Commented] (FLINK-22047) Could not find FLINSHED Flink job and can't submit job

[ https://issues.apache.org/jira/browse/FLINK-22047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313628#comment-17313628 ] Caizhi Weng commented on FLINK-22047: - Hi [~hayden zhou], in which mode are you running Flink jobs?

[jira] [Updated] (FLINK-15734) Support spill in batch hash window aggregation

[ https://issues.apache.org/jira/browse/FLINK-15734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15734: Fix Version/s: (was: 1.13.0) > Support spill in batch hash window aggregation >

[jira] [Updated] (FLINK-17398) Filesystem support flexible path reading

[ https://issues.apache.org/jira/browse/FLINK-17398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17398: Fix Version/s: (was: 1.13.0) > Filesystem support flexible path reading >

[jira] [Updated] (FLINK-18346) Support partition pruning for lookup table source

[ https://issues.apache.org/jira/browse/FLINK-18346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18346: Fix Version/s: (was: 1.13.0) > Support partition pruning for lookup table source >

[jira] [Updated] (FLINK-19719) [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces

[ https://issues.apache.org/jira/browse/FLINK-19719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19719: Fix Version/s: (was: 1.13.0) > [umbrella] FLIP-146: Improve new TableSource and TableSink interfaces

[jira] [Updated] (FLINK-16165) NestedLoopJoin fallback to HashJoin when build records number is very large

[ https://issues.apache.org/jira/browse/FLINK-16165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16165: Fix Version/s: (was: 1.13.0) > NestedLoopJoin fallback to HashJoin when build records number is very

[jira] [Updated] (FLINK-21464) Support ADD JAR command in sql client

[ https://issues.apache.org/jira/browse/FLINK-21464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21464: Fix Version/s: (was: 1.13.0) 1.14.0 > Support ADD JAR command in sql client >

[jira] [Updated] (FLINK-20670) Support query hints for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-20670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20670: Fix Version/s: (was: 1.13.0) > Support query hints for Flink SQL > -

[jira] [Updated] (FLINK-15419) Validate SQL syntax not need to depend on connector jar

[ https://issues.apache.org/jira/browse/FLINK-15419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15419: Fix Version/s: (was: 1.13.0) > Validate SQL syntax not need to depend on connector jar >

[jira] [Closed] (FLINK-19062) Improve alter table DDL

[ https://issues.apache.org/jira/browse/FLINK-19062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19062. --- Fix Version/s: (was: 1.13.0) Resolution: Duplicate > Improve alter table DDL >

[jira] [Updated] (FLINK-16323) Support to join a static table in streaming mode

[ https://issues.apache.org/jira/browse/FLINK-16323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16323: Fix Version/s: (was: 1.13.0) 1.14.0 > Support to join a static table in streaming

[jira] [Updated] (FLINK-15498) Using HiveCatalog in TPC-DS e2e

[ https://issues.apache.org/jira/browse/FLINK-15498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15498: Fix Version/s: (was: 1.13.0) > Using HiveCatalog in TPC-DS e2e > --- > >

[GitHub] [flink] gaoyunhaii commented on pull request #15466: [FLINK-22003][checkpointing] Prevent checkpoint from starting if any Source isn't running

gaoyunhaii commented on pull request #15466: URL: https://github.com/apache/flink/pull/15466#issuecomment-812354194 Very thanks @rkhachatryan for the fix! The PR looks good to me. It seems the test `DefaultSchdulerTest#failGlobalWhenRestoringStateFails` fails due to the change, but

[jira] [Updated] (FLINK-19103) The PushPartitionIntoTableSourceScanRule will lead a performance problem when there are still many partitions after pruning

[ https://issues.apache.org/jira/browse/FLINK-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19103: Fix Version/s: (was: 1.13.0) 1.14.0 > The PushPartitionIntoTableSourceScanRule

[jira] [Updated] (FLINK-19366) [umbrella] Migrate Filesystem and Hive to new source interface

[ https://issues.apache.org/jira/browse/FLINK-19366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19366: Fix Version/s: (was: 1.13.0) > [umbrella] Migrate Filesystem and Hive to new source interface >

[jira] [Updated] (FLINK-18605) Refactor Descriptor API (TableEnvironment#connect)

[ https://issues.apache.org/jira/browse/FLINK-18605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18605: Fix Version/s: (was: 1.13.0) > Refactor Descriptor API (TableEnvironment#connect) >

[jira] [Updated] (FLINK-20562) Support ExplainDetails for EXPLAIN sytnax

[ https://issues.apache.org/jira/browse/FLINK-20562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20562: Fix Version/s: (was: 1.13.0) 1.14.0 > Support ExplainDetails for EXPLAIN sytnax >

[GitHub] [flink] wuchong closed pull request #8738: [FLINK-12845][sql-client] Execute multiple statements in command line…

wuchong closed pull request #8738: URL: https://github.com/apache/flink/pull/8738 -- 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. For queries about this service, please

[jira] [Updated] (FLINK-18778) Support the SupportsProjectionPushDown interface for LookupTableSource

[ https://issues.apache.org/jira/browse/FLINK-18778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18778: Fix Version/s: (was: 1.13.0) > Support the SupportsProjectionPushDown interface for LookupTableSource

[jira] [Closed] (FLINK-12845) Execute multiple statements in command line or sql script file

[ https://issues.apache.org/jira/browse/FLINK-12845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12845. --- Assignee: (was: Zhenghua Gao) Resolution: Fixed This has been supported by FLINK-12828. >

[jira] [Updated] (FLINK-17767) Add offset support for TUMBLE, HOP, SESSION group windows

[ https://issues.apache.org/jira/browse/FLINK-17767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17767: Fix Version/s: (was: 1.13.0) > Add offset support for TUMBLE, HOP, SESSION group windows >

[jira] [Closed] (FLINK-16534) Support specify savepoint path when submitting sql job through sql client

[ https://issues.apache.org/jira/browse/FLINK-16534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16534. --- Resolution: Fixed This should been supported by FLINK-21462. > Support specify savepoint path when

[jira] [Updated] (FLINK-21634) ALTER TABLE statement enhancement

[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21634: Fix Version/s: (was: 1.13.0) > ALTER TABLE statement enhancement > -

[jira] [Closed] (FLINK-16441) Allow users to override flink-conf parameters from SQL CLI environment

[ https://issues.apache.org/jira/browse/FLINK-16441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16441. --- Assignee: (was: Gyula Fora) Resolution: Fixed This should has been supported by FLINK-21462. >

[jira] [Updated] (FLINK-16627) Support only generate non-null values when serializing into JSON

[ https://issues.apache.org/jira/browse/FLINK-16627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16627: Fix Version/s: (was: 1.13.0) > Support only generate non-null values when serializing into JSON >

[jira] [Updated] (FLINK-15801) Timestamp extractor created from properties does not work for some physical fields

[ https://issues.apache.org/jira/browse/FLINK-15801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15801: Fix Version/s: (was: 1.10.4) (was: 1.11.4) (was: 1.13.0)

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313622#comment-17313622 ] Guowei Ma commented on FLINK-22085: ---

[jira] [Updated] (FLINK-16294) Support to create non-existed table in database automatically when writing data to JDBC connector

[ https://issues.apache.org/jira/browse/FLINK-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16294: Fix Version/s: (was: 1.13.0) > Support to create non-existed table in database automatically when

[jira] [Updated] (FLINK-20110) Support 'merge' method for first_value and last_value UDAF

[ https://issues.apache.org/jira/browse/FLINK-20110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20110: Fix Version/s: (was: 1.13.0) 1.14.0 > Support 'merge' method for first_value and

[jira] [Closed] (FLINK-16889) Support converting BIGINT to TIMESTAMP for TO_TIMESTAMP function

[ https://issues.apache.org/jira/browse/FLINK-16889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16889. --- Fix Version/s: (was: 1.13.0) Resolution: Fixed This is supported in FLINK-21622 by introducing

[jira] [Updated] (FLINK-16528) Support Limit push down for Kafka streaming sources

[ https://issues.apache.org/jira/browse/FLINK-16528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16528: Fix Version/s: (was: 1.13.0) > Support Limit push down for Kafka streaming sources >

[jira] [Updated] (FLINK-12256) Implement Confluent Schema Registry Catalog

[ https://issues.apache.org/jira/browse/FLINK-12256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12256: Fix Version/s: (was: 1.13.0) > Implement Confluent Schema Registry Catalog >

[jira] [Updated] (FLINK-16824) FLIP-132 Temporal Table DDL and Temporal Table Join

[ https://issues.apache.org/jira/browse/FLINK-16824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16824: Fix Version/s: (was: 1.13.0) > FLIP-132 Temporal Table DDL and Temporal Table Join >

[jira] [Updated] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14055: Fix Version/s: (was: 1.13.0) > Add advanced function DDL syntax "USING JAR/FILE/ACHIVE" >

[jira] [Updated] (FLINK-16833) Make JDBCDialect pluggable for JDBC SQL connector

[ https://issues.apache.org/jira/browse/FLINK-16833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-16833: Fix Version/s: (was: 1.13.0) > Make JDBCDialect pluggable for JDBC SQL connector >

[jira] [Updated] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18202: Fix Version/s: (was: 1.13.0) 1.14.0 > Introduce Protobuf format >

[jira] [Updated] (FLINK-9477) FLIP-90: Support SQL 2016 JSON functions in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-9477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-9477: --- Fix Version/s: (was: 1.13.0) 1.14.0 > FLIP-90: Support SQL 2016 JSON functions in

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Implement streaming window join operator

flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 93b9b3d8dac2c3ecd13e3e3ede46f4a73263e34d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15396: [FLINK-21008][coordination] Register a shutdown supplier in the SignalHandler for ClusterEntrypoint

flinkbot edited a comment on pull request #15396: URL: https://github.com/apache/flink/pull/15396#issuecomment-808861897 ## CI report: * 042e3561842ddbd363c4198ba2fc46ed2b8f6790 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15247: [FLINK-21833][Table SQL / Runtime] TemporalRowTimeJoinOperator.java will lead to the state expansion by short-life-cycle & huge RowDa

flinkbot edited a comment on pull request #15247: URL: https://github.com/apache/flink/pull/15247#issuecomment-800773807 ## CI report: * edea56a09944bb33e1e944de4daa5bbec751df21 Azure:

[jira] [Assigned] (FLINK-21305) Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice

[ https://issues.apache.org/jira/browse/FLINK-21305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21305: --- Assignee: Jark Wu > Fix Cumulative and Hopping window should accumulate late events belonging to

[jira] [Updated] (FLINK-21305) Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice

[ https://issues.apache.org/jira/browse/FLINK-21305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21305: Summary: Fix Cumulative and Hopping window should accumulate late events belonging to the cleaned slice

[jira] [Assigned] (FLINK-21746) flink sql fields in row access error about scalarfunction

[ https://issues.apache.org/jira/browse/FLINK-21746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21746: --- Assignee: Shengkai Fang (was: Jark Wu) > flink sql fields in row access error about

[jira] [Closed] (FLINK-15137) Improve schema derivation for Avro format

[ https://issues.apache.org/jira/browse/FLINK-15137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-15137. --- Resolution: Won't Fix > Improve schema derivation for Avro format >

[jira] [Closed] (FLINK-19612) Support CUMULATE window table function in planner

[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-19612. --- Resolution: Fixed Fixed by FLINK-19608. > Support CUMULATE window table function in planner >

[jira] [Assigned] (FLINK-14414) Support string serializable for SymbolType

[ https://issues.apache.org/jira/browse/FLINK-14414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14414: --- Assignee: (was: Jark Wu) > Support string serializable for SymbolType >

[jira] [Updated] (FLINK-18822) [umbrella] Improve and complete Change Data Capture formats

[ https://issues.apache.org/jira/browse/FLINK-18822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18822: Labels: (was: pull-request-available) > [umbrella] Improve and complete Change Data Capture formats >

[jira] [Closed] (FLINK-13271) Add documentation for all the new features of blink planner

[ https://issues.apache.org/jira/browse/FLINK-13271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13271. --- Fix Version/s: (was: 1.9.4) Resolution: Fixed > Add documentation for all the new features of

[jira] [Updated] (FLINK-18758) Many data types do not work in debezium format

[ https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-18758: Fix Version/s: (was: 1.13.0) > Many data types do not work in debezium format >

[jira] [Closed] (FLINK-13357) Add documentation for PartitionableTableSource and PartitionableTableSink

[ https://issues.apache.org/jira/browse/FLINK-13357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13357. --- Fix Version/s: (was: 1.9.4) Resolution: Won't Fix > Add documentation for

[jira] [Closed] (FLINK-13520) Add documentation for the different behavior of row count sliding window in blink planner

[ https://issues.apache.org/jira/browse/FLINK-13520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13520. --- Resolution: Won't Fix > Add documentation for the different behavior of row count sliding window in >

[jira] [Closed] (FLINK-13358) Add documentation for InputFormatTableSource and OutputFormatTableSink

[ https://issues.apache.org/jira/browse/FLINK-13358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13358. --- Fix Version/s: (was: 1.9.4) Resolution: Won't Fix > Add documentation for InputFormatTableSource

[jira] [Closed] (FLINK-14320) [FLIP-66] Support Time Attribute in SQL DDL

[ https://issues.apache.org/jira/browse/FLINK-14320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14320. --- Resolution: Fixed > [FLIP-66] Support Time Attribute in SQL DDL >

[jira] [Updated] (FLINK-14621) Do not generate watermark assigner operator if no time attribute operations on rowtime

[ https://issues.apache.org/jira/browse/FLINK-14621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14621: Parent: (was: FLINK-14320) Issue Type: New Feature (was: Sub-task) > Do not generate

[jira] [Assigned] (FLINK-22104) SqlClientTest.testExecuteSqlFile fail

[ https://issues.apache.org/jira/browse/FLINK-22104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-22104: -- Assignee: Shengkai Fang > SqlClientTest.testExecuteSqlFile fail >

[jira] [Updated] (FLINK-22104) SqlClientTest.testExecuteSqlFile fail

[ https://issues.apache.org/jira/browse/FLINK-22104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-22104: --- Fix Version/s: 1.13.0 > SqlClientTest.testExecuteSqlFile fail >

[jira] [Closed] (FLINK-14323) Serialize Expression to String and parse String to Expression

[ https://issues.apache.org/jira/browse/FLINK-14323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14323. --- Resolution: Won't Fix > Serialize Expression to String and parse String to Expression >

[jira] [Closed] (FLINK-14473) Support nested field as the rowtime attribute

[ https://issues.apache.org/jira/browse/FLINK-14473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-14473. --- Resolution: Won't Fix > Support nested field as the rowtime attribute >

[jira] [Assigned] (FLINK-11961) Clear up and refactor code generation of scalar functions and operators

[ https://issues.apache.org/jira/browse/FLINK-11961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-11961: --- Assignee: (was: Jark Wu) > Clear up and refactor code generation of scalar functions and

[jira] [Created] (FLINK-22104) SqlClientTest.testExecuteSqlFile fail

Guowei Ma created FLINK-22104: - Summary: SqlClientTest.testExecuteSqlFile fail Key: FLINK-22104 URL: https://issues.apache.org/jira/browse/FLINK-22104 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-22103) testNumberOfBuiltinFunctions fail

[ https://issues.apache.org/jira/browse/FLINK-22103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-22103: Fix Version/s: 1.13.0 > testNumberOfBuiltinFunctions fail > - > >

<    1   2   3   4   >