[jira] [Commented] (FLINK-24413) Casting to a CHAR() and VARCHAR() doesn't trim the string to the specified precision

[ https://issues.apache.org/jira/browse/FLINK-24413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425563#comment-17425563 ] Jark Wu commented on FLINK-24413: - I slightly favor triming to specific precision. I th

[jira] [Commented] (FLINK-24473) getString value from any datatype columns

[ https://issues.apache.org/jira/browse/FLINK-24473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425562#comment-17425562 ] Jark Wu commented on FLINK-24473: - Which line causes the cast exception ? And would be b

[jira] [Updated] (FLINK-24456) Support bounded offset in the Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-24456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24456: Component/s: Table SQL / Ecosystem Connectors / Kafka > Support bounded offset in the Kaf

[jira] [Updated] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

[ https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24448: Component/s: Table SQL / Runtime > Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTA

[jira] [Commented] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

[ https://issues.apache.org/jira/browse/FLINK-24448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17425501#comment-17425501 ] Jark Wu commented on FLINK-24448: - Which version doesn't work? > Tumbling Window Not w

[jira] [Commented] (FLINK-20895) Support LocalAggregatePushDown in Blink planner

[ https://issues.apache.org/jira/browse/FLINK-20895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419158#comment-17419158 ] Jark Wu commented on FLINK-20895: - Thanks [~iyupeng], considering there is already a pul

[jira] [Closed] (FLINK-22942) Disable upsert into syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22942. --- Release Note: Disabled UPSERT INTO statement. UPSERT INTO syntax was exposed by mistake in previous releases

[jira] [Reopened] (FLINK-22942) Disable upsert into syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reopened FLINK-22942: - > Disable upsert into syntax in Flink SQL > --- > > Key:

[jira] [Commented] (FLINK-22942) Disable upsert into syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17419038#comment-17419038 ] Jark Wu commented on FLINK-22942: - [~slinkydeveloper], you can reopen the issue and you

[jira] [Commented] (FLINK-24293) Tasks from the same job on a machine share user jar

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418944#comment-17418944 ] Jark Wu commented on FLINK-24293: - Sorry [~huntercc], I'm not familiar with Coordinator

[jira] [Commented] (FLINK-24338) Provide an interface to validate flinksql

[ https://issues.apache.org/jira/browse/FLINK-24338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418908#comment-17418908 ] Jark Wu commented on FLINK-24338: - If you want to just validate SQL sytnax, maybe you ca

[jira] [Commented] (FLINK-22942) Disable upsert into syntax in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-22942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17418382#comment-17418382 ] Jark Wu commented on FLINK-22942: - We may also need to add a release note for this, even

[jira] [Closed] (FLINK-16088) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-16088. --- Resolution: Invalid > Translate "Query Configuration" page of "Streaming Concepts" into Chinese > -

[jira] [Commented] (FLINK-16088) Translate "Query Configuration" page of "Streaming Concepts" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417112#comment-17417112 ] Jark Wu commented on FLINK-16088: - [~monster#12], sorry, this page can be removed after

[jira] [Commented] (FLINK-24306) group by index throw SqlValidatorException

[ https://issues.apache.org/jira/browse/FLINK-24306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17416057#comment-17416057 ] Jark Wu commented on FLINK-24306: - Thanks [~zlzhang0122], could you help to link the Cal

[jira] [Closed] (FLINK-24218) Translate "UNLOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24218. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 647103c7111583cdb6ab626d739cdd69ec7fdd06 >

[jira] [Closed] (FLINK-24217) Translate "LOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24217. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 6f071962479a2046933a42cad8e899131fe9d135 >

[jira] [Closed] (FLINK-24293) Tasks share

[ https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24293. --- Resolution: Invalid Please add descriptions and a meaningful title and reopen it. > Tasks share > ---

[jira] [Commented] (FLINK-24289) Load data repeatedly between different jobs

[ https://issues.apache.org/jira/browse/FLINK-24289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415397#comment-17415397 ] Jark Wu commented on FLINK-24289: - [~SpongebobZ], currently, that's impossible. > Loa

[jira] [Updated] (FLINK-24291) Decimal precision is lost when deserializing

[ https://issues.apache.org/jira/browse/FLINK-24291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24291: Description: When added the test case following into FileSystemItCaseBase: {code:java} // create table tab

[jira] [Commented] (FLINK-24289) Load data repeatedly between different jobs

[ https://issues.apache.org/jira/browse/FLINK-24289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415364#comment-17415364 ] Jark Wu commented on FLINK-24289: - Please use `StatementSet` to combine two DMLs into on

[jira] [Commented] (FLINK-24286) Flink TableEnvironment executesql on IntelliJ leads to Could not find a file system implementation for scheme 's3a'

[ https://issues.apache.org/jira/browse/FLINK-24286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17415290#comment-17415290 ] Jark Wu commented on FLINK-24286: - In IDEA, I think you need manually add the flink-s3-f

[jira] [Closed] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22275. --- Fix Version/s: (was: 1.14.0) 1.15.0 Resolution: Fixed Fixed in master: f74db4b

[jira] [Closed] (FLINK-24219) Translate "SET Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24219. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 94c507754f9328e8706e271aa3c8369472a3bfa5 >

[jira] [Closed] (FLINK-24221) Translate "JAR Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24221. --- Fix Version/s: 1.15 Resolution: Fixed Fixed in master: 0313c40260d7ba230ef0805ce61865659e57495d > T

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413950#comment-17413950 ] Jark Wu commented on FLINK-22275: - [~yittg] thanks for the updating. I will review it la

[jira] [Closed] (FLINK-24220) Translate "RESET Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24220. --- Fix Version/s: 1.15 Resolution: Fixed Fixed in master: 33641f59eccc2f87d1fca784054f304a222fcfdd > T

[jira] [Commented] (FLINK-24254) Support configuration hints for table sources and sinks

[ https://issues.apache.org/jira/browse/FLINK-24254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413881#comment-17413881 ] Jark Wu commented on FLINK-24254: - I would like to not mix them. {{OPTIONS}} is used for

[jira] [Commented] (FLINK-24247) Uniformly limit the value of ABS(offset) in all window

[ https://issues.apache.org/jira/browse/FLINK-24247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413071#comment-17413071 ] Jark Wu commented on FLINK-24247: - I think this limitation is reasonable, and makes the

[jira] [Commented] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413057#comment-17413057 ] Jark Wu commented on FLINK-22275: - [~yittg], could you rebase the pull request? I can he

[jira] [Commented] (FLINK-22071) LookupTableSource.LookupRuntimeProvider customizes parallelism

[ https://issues.apache.org/jira/browse/FLINK-22071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413035#comment-17413035 ] Jark Wu commented on FLINK-22071: - I'm fine with this. What do you think [~lzljs3620320]

[jira] [Commented] (FLINK-23747) Testing Window TVF offset

[ https://issues.apache.org/jira/browse/FLINK-23747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412994#comment-17412994 ] Jark Wu commented on FLINK-23747: - [~liliwei] feel free to open a new issue to discuss t

[jira] [Closed] (FLINK-24238) Page title missing

[ https://issues.apache.org/jira/browse/FLINK-24238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24238. --- Resolution: Duplicate > Page title missing > -- > > Key: FLINK-24238 >

[jira] [Closed] (FLINK-23836) [doc-zh]Translate "/dev/datastream/execution/execution_configuration.md" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23836. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: ff713a80d8d5adcc0f88e697a544776011bbb1be >

[jira] [Commented] (FLINK-24001) Support evaluating individual window table-valued function in runtime

[ https://issues.apache.org/jira/browse/FLINK-24001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412520#comment-17412520 ] Jark Wu commented on FLINK-24001: - >From the implementation, it seems we don't have choi

[jira] [Updated] (FLINK-24225) Define and implement UPSERT INTO semantics

[ https://issues.apache.org/jira/browse/FLINK-24225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24225: Component/s: Table SQL / API > Define and implement UPSERT INTO semantics > --

[jira] [Commented] (FLINK-24214) A submit job failure crashes the sql client

[ https://issues.apache.org/jira/browse/FLINK-24214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412321#comment-17412321 ] Jark Wu commented on FLINK-24214: - >From the stack trace, you should be using Flink vers

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412318#comment-17412318 ] Jark Wu commented on FLINK-20370: - [~lzljs3620320] there is 4th case: input is changelog

[jira] [Commented] (FLINK-20370) Result is wrong when sink primary key is not the same with query

[ https://issues.apache.org/jira/browse/FLINK-20370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412317#comment-17412317 ] Jark Wu commented on FLINK-20370: - [~lzljs3620320] could UpsertMaterialize also solve th

[jira] [Commented] (FLINK-10230) Support 'SHOW CREATE VIEW' syntax to print the query of a view

[ https://issues.apache.org/jira/browse/FLINK-10230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412313#comment-17412313 ] Jark Wu commented on FLINK-10230: - I'm fine with both SHOW CREATE TABLE and SHOW CREATE

[jira] [Closed] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24196. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 125cb70a232b6a6e52c099c6a280414e2f896ad5 >

[jira] [Comment Edited] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412293#comment-17412293 ] Jark Wu edited comment on FLINK-24195 at 9/9/21, 2:42 AM: -- Fixe

[jira] [Closed] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24195. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in maste: 7b436773fc8eda6bb5f3c01b917d15d15aa70521 > T

[jira] [Assigned] (FLINK-24219) Translate "SET Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24219: --- Assignee: wuguihu > Translate "SET Statements" page of "SQL" into Chinese > ---

[jira] [Assigned] (FLINK-24218) Translate "UNLOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24218: --- Assignee: wuguihu > Translate "UNLOAD Statements" page of "SQL" into Chinese >

[jira] [Assigned] (FLINK-24217) Translate "LOAD Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24217: --- Assignee: wuguihu > Translate "LOAD Statements" page of "SQL" into Chinese > --

[jira] [Assigned] (FLINK-24220) Translate "RESET Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24220: --- Assignee: wuguihu > Translate "RESET Statements" page of "SQL" into Chinese > -

[jira] [Assigned] (FLINK-24221) Translate "JAR Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24221: --- Assignee: wuguihu > Translate "JAR Statements" page of "SQL" into Chinese > ---

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412286#comment-17412286 ] Jark Wu commented on FLINK-24168: - +1 to only fix in master. Actually, we also not fix i

[jira] [Updated] (FLINK-17321) Support for casting collection types.

[ https://issues.apache.org/jira/browse/FLINK-17321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17321: Priority: Critical (was: Major) > Support for casting collection types. > ---

[jira] [Closed] (FLINK-24204) Failed to insert nested types using value construction functions

[ https://issues.apache.org/jira/browse/FLINK-24204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24204. --- Resolution: Duplicate > Failed to insert nested types using value construction functions >

[jira] [Commented] (FLINK-24204) Failed to insert nested types using value construction functions

[ https://issues.apache.org/jira/browse/FLINK-24204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411735#comment-17411735 ] Jark Wu commented on FLINK-24204: - [~twalthr] you are right. I close this issue then and

[jira] [Created] (FLINK-24204) Failed to insert nested types using value constructed functions

Jark Wu created FLINK-24204: --- Summary: Failed to insert nested types using value constructed functions Key: FLINK-24204 URL: https://issues.apache.org/jira/browse/FLINK-24204 Project: Flink Issue

[jira] [Updated] (FLINK-24204) Failed to insert nested types using value construction functions

[ https://issues.apache.org/jira/browse/FLINK-24204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24204: Summary: Failed to insert nested types using value construction functions (was: Failed to insert nested

[jira] [Commented] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate follows after Match because the output type does not updated after input rowtime attribute changed

[ https://issues.apache.org/jira/browse/FLINK-24168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411676#comment-17411676 ] Jark Wu commented on FLINK-24168: - I also vote for {{MATCH_ROWTIME(rowtime)}} and deprec

[jira] [Assigned] (FLINK-24195) Translate "DESCRIBE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24195: --- Assignee: wuguihu > Translate "DESCRIBE Statements" page of "SQL" into Chinese > --

[jira] [Assigned] (FLINK-24196) Translate "EXPLAIN Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24196: --- Assignee: wuguihu > Translate "EXPLAIN Statements" page of "SQL" into Chinese > ---

[jira] [Closed] (FLINK-24115) Outdated SQL Temporal Join Example

[ https://issues.apache.org/jira/browse/FLINK-24115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24115. --- Fix Version/s: 1.15.0 1.13.3 1.14.0 Resolution: Fixed Fixed in

[jira] [Updated] (FLINK-24165) Fix typo in javadoc of KeyContext class

[ https://issues.apache.org/jira/browse/FLINK-24165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24165: Summary: Fix typo in javadoc of KeyContext class (was: Comment spelling error) > Fix typo in javadoc of

[jira] [Closed] (FLINK-24165) Fix typo in javadoc of KeyContext class

[ https://issues.apache.org/jira/browse/FLINK-24165?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24165. --- Fix Version/s: 1.15.0 Assignee: jianzhang.yjz Resolution: Fixed Fixed in master: e94a3db55d5

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411108#comment-17411108 ] Jark Wu commented on FLINK-22198: - Fixed in - release-1.12: b9dc04eaf2b28b85b19fd3f53f

[jira] [Closed] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22198. --- Resolution: Fixed > KafkaTableITCase hang. > -- > > Key: FLINK-22198 >

[jira] [Closed] (FLINK-24172) Table API join documentation for Java has missing end quote after table name

[ https://issues.apache.org/jira/browse/FLINK-24172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24172. --- Resolution: Fixed Fixed in master: c13b749782d0d72647ec6d73ce1eb22b57f2be7d > Table API join documentation

[jira] [Assigned] (FLINK-24172) Table API join documentation for Java has missing end quote after table name

[ https://issues.apache.org/jira/browse/FLINK-24172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24172: --- Assignee: Mans Singh > Table API join documentation for Java has missing end quote after table name

[jira] [Updated] (FLINK-24176) Column alias in Flink-SQL is unsuccessful after converting Table to DataStream

[ https://issues.apache.org/jira/browse/FLINK-24176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24176: Component/s: Table SQL / API > Column alias in Flink-SQL is unsuccessful after converting Table to > Da

[jira] [Commented] (FLINK-23857) insert overwirite table select * from t where 1 != 1, Unable to clear table data

[ https://issues.apache.org/jira/browse/FLINK-23857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17410080#comment-17410080 ] Jark Wu commented on FLINK-23857: - [~luoyuxia] Shouldn't the above query fail if target

[jira] [Commented] (FLINK-24153) Unable to use SET command in Flink SQL Shell file submit mode

[ https://issues.apache.org/jira/browse/FLINK-24153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409536#comment-17409536 ] Jark Wu commented on FLINK-24153: - [~Nj-kol] please do not copy and paste the whole SET

[jira] [Commented] (FLINK-24153) Unable to use SET command in Flink SQL Shell file submit mode

[ https://issues.apache.org/jira/browse/FLINK-24153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409534#comment-17409534 ] Jark Wu commented on FLINK-24153: - [~twalthr] [~airblader] +1 to revert the doc changes

[jira] [Assigned] (FLINK-24146) Translate "CREATE Statements" page of "SQL" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24146: --- Assignee: wuguihu > Translate "CREATE Statements" page of "SQL" into Chinese >

[jira] [Commented] (FLINK-24141) table can't have the same name with database or catalog

[ https://issues.apache.org/jira/browse/FLINK-24141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409337#comment-17409337 ] Jark Wu commented on FLINK-24141: - [~Jocean], would be better if you can add a example t

[jira] [Closed] (FLINK-24023) the names of metrics are incomplete

[ https://issues.apache.org/jira/browse/FLINK-24023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24023. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 6d673ae199db0620fa5e5b152fe13ccfcdc992b5 >

[jira] [Commented] (FLINK-23242) Translate the page of "Handling Application Parameters" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409231#comment-17409231 ] Jark Wu commented on FLINK-23242: - Fixed in - master: 22f7feb2f390121e0f3d399709a01036

[jira] [Closed] (FLINK-23242) Translate the page of "Handling Application Parameters" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23242. --- Fix Version/s: (was: 1.13.0) 1.15.0 1.14.0 Resolution: Fixed

[jira] [Closed] (FLINK-24136) OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with NPE

[ https://issues.apache.org/jira/browse/FLINK-24136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24136. --- Resolution: Duplicate > OverAggregateITCase.testRowTimeBoundedPartitionedRangeOver test failed with > NPE >

[jira] [Assigned] (FLINK-24023) the names of metrics are incomplete

[ https://issues.apache.org/jira/browse/FLINK-24023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24023: --- Assignee: Yao Zhang > the names of metrics are incomplete > --- > >

[jira] [Commented] (FLINK-24116) PRIMARY KEY declaration on insert-only table is not validated globally

[ https://issues.apache.org/jira/browse/FLINK-24116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408679#comment-17408679 ] Jark Wu commented on FLINK-24116: - The check on Kafka insert-only source is that we foun

[jira] [Closed] (FLINK-22812) Fix hive issues in sql-connector-hive jars

[ https://issues.apache.org/jira/browse/FLINK-22812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22812. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master via ffb5781ca7be0f119c6cae20d71d1e19fcd5ad4d

[jira] [Assigned] (FLINK-22812) Fix hive issues in sql-connector-hive jars

[ https://issues.apache.org/jira/browse/FLINK-22812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-22812: --- Assignee: Rui Li > Fix hive issues in sql-connector-hive jars > ---

[jira] [Commented] (FLINK-24116) PRIMARY KEY declaration on insert-only table is not validated globally

[ https://issues.apache.org/jira/browse/FLINK-24116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408617#comment-17408617 ] Jark Wu commented on FLINK-24116: - We need to be careful here. Because primary key on bo

[jira] [Closed] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24081. --- Resolution: Fixed > OVER window throws exception when the rowtime is timestamp_ltz type > --

[jira] [Comment Edited] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407759#comment-17407759 ] Jark Wu edited comment on FLINK-24081 at 9/2/21, 7:15 AM: -- Fixe

[jira] [Commented] (FLINK-24081) OVER window throws exception when the rowtime is timestamp_ltz type

[ https://issues.apache.org/jira/browse/FLINK-24081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408609#comment-17408609 ] Jark Wu commented on FLINK-24081: - Yes [~airblader] ;) > OVER window throws exception w

[jira] [Assigned] (FLINK-24094) Support DROP PARTITION by partial partition specification

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24094: --- Assignee: luoyuxia > Support DROP PARTITION by partial partition specification > --

[jira] [Commented] (FLINK-24094) Support DROP PARTITION by partial partition specification

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408486#comment-17408486 ] Jark Wu commented on FLINK-24094: - Sure [~luoyuxia] > Support DROP PARTITION by partial

[jira] [Commented] (FLINK-24104) incorrect validation of sink schema

[ https://issues.apache.org/jira/browse/FLINK-24104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408212#comment-17408212 ] Jark Wu commented on FLINK-24104: - Partial Insert is officially supported since 1.13 via

[jira] [Closed] (FLINK-24104) incorrect validation of sink schema

[ https://issues.apache.org/jira/browse/FLINK-24104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24104. --- Resolution: Not A Problem > incorrect validation of sink schema > --- > >

[jira] [Commented] (FLINK-24103) Create time-based LAST_VALUE / FIRST_VALUE

[ https://issues.apache.org/jira/browse/FLINK-24103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408136#comment-17408136 ] Jark Wu commented on FLINK-24103: - An alternative (or more SQL standarnd compiliant way)

[jira] [Closed] (FLINK-22885) Support 'SHOW COLUMNS'.

[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22885. --- Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: 1b764ceda4ac96f719c34aaa6ffb3d1e7dbf1f4a >

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17408119#comment-17408119 ] Jark Wu commented on FLINK-24096: - Another instance: https://dev.azure.com/apache-flink

[jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24094: Fix Version/s: 1.15.0 > Support DROP PARTITION by partial partition specification > --

[jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24094: Summary: Support DROP PARTITION by partial partition specification (was: Could not execute ALTER TABLE c

[jira] [Updated] (FLINK-24094) Support DROP PARTITION by partial partition specification

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

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407917#comment-17407917 ] Jark Wu commented on FLINK-24096: - [~arvid] sounds right. It looks like there is a poten

[jira] [Commented] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407895#comment-17407895 ] Jark Wu commented on FLINK-24094: - [~leexu] does this also supported in Hive/Spark? > C

[jira] [Updated] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24094: Issue Type: New Feature (was: Bug) > Could not execute ALTER TABLE > check_rule_base_hive_catalog.test_f

[jira] [Commented] (FLINK-24094) Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31)

[ https://issues.apache.org/jira/browse/FLINK-24094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407892#comment-17407892 ] Jark Wu commented on FLINK-24094: - [~leexu] OK. I will change the title into a feature.

[jira] [Commented] (FLINK-24096) Table planner tests fails due to NPE in FailingCollectionSource.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-24096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407891#comment-17407891 ] Jark Wu commented on FLINK-24096: - {{checkpointedEmittedNums.get(checkpointId)}} may ret

[jira] [Comment Edited] (FLINK-24029) Update doc example sql field in release-1.13.2 to dept_id

[ https://issues.apache.org/jira/browse/FLINK-24029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17407876#comment-17407876 ] Jark Wu edited comment on FLINK-24029 at 9/1/21, 6:48 AM: -- Fixe

[jira] [Updated] (FLINK-24029) Fix "dept_id" typo in SQL "Getting Started" page

[ https://issues.apache.org/jira/browse/FLINK-24029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-24029: Summary: Fix "dept_id" typo in SQL "Getting Started" page (was: Update doc example sql field in release-1

[jira] [Closed] (FLINK-24029) Fix "dept_id" typo in SQL "Getting Started" page

[ https://issues.apache.org/jira/browse/FLINK-24029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-24029. --- Resolution: Fixed > Fix "dept_id" typo in SQL "Getting Started" page > -

<    5   6   7   8   9   10   11   12   13   14   >