[jira] [Assigned] (FLINK-30744) Translate "Window Top-N" page of "Querys" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-30744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-30744: --- Assignee: chenhaiyang > Translate "Window Top-N" page of "Querys" into Chinese >

[jira] [Closed] (FLINK-31411) lookup.cache.caching-missing-key变更的配置应为lookup.partial-cache.caching-missing-key

[ https://issues.apache.org/jira/browse/FLINK-31411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31411. --- Resolution: Invalid Please use English and add descriptions for what is wrong and what you want to change.

[jira] [Closed] (FLINK-25347) Replace deprecated TableSchema with Schema in MergeTableLikeUtil

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

[jira] [Closed] (FLINK-8606) Clean up Table API for Java users

[ https://issues.apache.org/jira/browse/FLINK-8606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-8606. -- Resolution: Not A Problem TableEnvironment has been migrated to Java, so this is not a problem any more. >

[jira] [Commented] (FLINK-29541) [JUnit5 Migration] Module: flink-table-planner

[ https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17699311#comment-17699311 ] Jark Wu commented on FLINK-29541: - Hi [~rskraba], what's the progress now? I agree with you this might

[jira] [Closed] (FLINK-29743) CatalogPropertiesUtil supports de/serializing column comment

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

[jira] [Assigned] (FLINK-25347) Replace deprecated TableSchema with Schema in MergeTableLikeUtil

[ https://issues.apache.org/jira/browse/FLINK-25347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-25347: --- Assignee: Jark Wu > Replace deprecated TableSchema with Schema in MergeTableLikeUtil >

[jira] [Closed] (FLINK-18958) Lose column comment when create table

[ https://issues.apache.org/jira/browse/FLINK-18958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-18958. --- Fix Version/s: (was: 1.17.0) Assignee: (was: Feng Jin) Resolution: Fixed > Lose

[jira] [Commented] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

[ https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17698429#comment-17698429 ] Jark Wu commented on FLINK-31368: - [~twalthr], thank you for your idea. Another idea is colocating the

[jira] [Assigned] (FLINK-31382) Add select query ILIKE predicate support

[ https://issues.apache.org/jira/browse/FLINK-31382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31382: --- Assignee: Ran Tao > Add select query ILIKE predicate support >

[jira] [Assigned] (FLINK-31380) Add filter support for ShowOperations

[ https://issues.apache.org/jira/browse/FLINK-31380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31380: --- Assignee: Ran Tao > Add filter support for ShowOperations >

[jira] [Assigned] (FLINK-31256) [Umbrella] FLIP-297: Improve Auxiliary Sql Statements

[ https://issues.apache.org/jira/browse/FLINK-31256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31256: --- Assignee: Ran Tao > [Umbrella] FLIP-297: Improve Auxiliary Sql Statements >

[jira] [Assigned] (FLINK-29743) CatalogPropertiesUtil supports de/serializing column comment

[ https://issues.apache.org/jira/browse/FLINK-29743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-29743: --- Assignee: Jark Wu > CatalogPropertiesUtil supports de/serializing column comment >

[jira] [Updated] (FLINK-25347) Replace deprecated TableSchema with Schema in MergeTableLikeUtil

[ https://issues.apache.org/jira/browse/FLINK-25347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-25347: Parent: FLINK-29072 Issue Type: Sub-task (was: Technical Debt) > Replace deprecated TableSchema

[jira] [Commented] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

[ https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697820#comment-17697820 ] Jark Wu commented on FLINK-31368: - Hi [~zjureel], this is another topic. I think if an Operation can be

[jira] [Commented] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697817#comment-17697817 ] Jark Wu commented on FLINK-26945: - I think the Spark/Hive style date_add/date_sub can be a shortcut for

[jira] [Commented] (FLINK-26945) Add DATE_SUB supported in SQL & Table API

[ https://issues.apache.org/jira/browse/FLINK-26945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697816#comment-17697816 ] Jark Wu commented on FLINK-26945: - The BigQuery style is similar to the Flink function {{TIMESTAMPADD}}:

[jira] [Closed] (FLINK-31279) fix times using number and interval type bug

[ https://issues.apache.org/jira/browse/FLINK-31279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31279. --- Assignee: jackylau Resolution: Fixed Fixed in master: 75d94108a8e7dc51825ff9063c2c3f4649bf0eb4 > fix

[jira] [Updated] (FLINK-31279) Fix MULTIPLY(TIMES) function doesn't support interval types

[ https://issues.apache.org/jira/browse/FLINK-31279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31279: Summary: Fix MULTIPLY(TIMES) function doesn't support interval types (was: fix times using number and

[jira] [Updated] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

[ https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31368: Description: Currently, {{TableEnvironmentImpl}} is a bit bloated. The implementation of

[jira] [Commented] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

[ https://issues.apache.org/jira/browse/FLINK-31368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697797#comment-17697797 ] Jark Wu commented on FLINK-31368: - cc [~lincoln.86xy] [~twalthr], what do you think about this? > Move

[jira] [Created] (FLINK-31368) Move operation execution logic out from TableEnvironmentImpl

Jark Wu created FLINK-31368: --- Summary: Move operation execution logic out from TableEnvironmentImpl Key: FLINK-31368 URL: https://issues.apache.org/jira/browse/FLINK-31368 Project: Flink Issue

[jira] [Commented] (FLINK-31336) interval type process has problem in table api and sql

[ https://issues.apache.org/jira/browse/FLINK-31336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17697406#comment-17697406 ] Jark Wu commented on FLINK-31336: - Could you help to investigate what's the behavior in other systems,

[jira] [Updated] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-15289: Fix Version/s: (was: 1.17.0) > Run sql appear error of "Zero-length character strings have no

[jira] [Updated] (FLINK-31327) Added conversion method for GenericRowData

[ https://issues.apache.org/jira/browse/FLINK-31327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31327: Component/s: Table SQL / API > Added conversion method for GenericRowData >

[jira] [Commented] (FLINK-31324) Broken SingleThreadFetcherManager constructor API

[ https://issues.apache.org/jira/browse/FLINK-31324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17696653#comment-17696653 ] Jark Wu commented on FLINK-31324: - +1 for keeping compatibility. Besides, I think

[jira] [Comment Edited] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695756#comment-17695756 ] Jark Wu edited comment on FLINK-31275 at 3/2/23 3:03 PM: - Hi [~zjureel], feel

[jira] [Commented] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695756#comment-17695756 ] Jark Wu commented on FLINK-31275: - Hi [~zjureel], feel free to create FLIP and start a discussion in dev

[jira] [Commented] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695656#comment-17695656 ] Jark Wu commented on FLINK-31275: - Thank you [~zjureel], I think the lineage information of tables and

[jira] [Closed] (FLINK-29729) Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29729. --- Fix Version/s: 1.17.0 1.16.2 1.18.0 1.15.5

[jira] [Comment Edited] (FLINK-29729) Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695091#comment-17695091 ] Jark Wu edited comment on FLINK-29729 at 3/2/23 2:06 AM: - Fixed in: - master:

[jira] [Commented] (FLINK-31285) FileSource should support reading files in order

[ https://issues.apache.org/jira/browse/FLINK-31285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695411#comment-17695411 ] Jark Wu commented on FLINK-31285: - I think extending FlinkSourceBuilder to accept user-defined

[jira] [Assigned] (FLINK-29729) Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-29729: --- Assignee: dalongliu > Fix credential info configured in flink-conf.yaml is lost during creating >

[jira] [Commented] (FLINK-29729) Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695091#comment-17695091 ] Jark Wu commented on FLINK-29729: - Fixed in: - master: 49b8726850cb0da5f3a888c836f31bfa69be739d -

[jira] [Assigned] (FLINK-31273) Left join with IS_NULL filter be wrongly pushed down and get wrong join results

[ https://issues.apache.org/jira/browse/FLINK-31273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31273: --- Assignee: Yunhong Zheng > Left join with IS_NULL filter be wrongly pushed down and get wrong join

[jira] [Commented] (FLINK-31275) Generate planner id in planner

[ https://issues.apache.org/jira/browse/FLINK-31275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695057#comment-17695057 ] Jark Wu commented on FLINK-31275: - What's the purpose to "create relations between source and sink

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17695055#comment-17695055 ] Jark Wu commented on FLINK-31259: - Sorry, for the "global catalog", I mean the catalog definition is

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694875#comment-17694875 ] Jark Wu commented on FLINK-31259: - Thank you [~zjureel], do you mean supporting the initialization file

[jira] [Assigned] (FLINK-31268) OperatorCoordinator.Context#metricGroup will return null when restore from a savepoint

[ https://issues.apache.org/jira/browse/FLINK-31268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31268: --- Assignee: Hang Ruan > OperatorCoordinator.Context#metricGroup will return null when restore from a

[jira] [Closed] (FLINK-31257) Fix errors in “CSV Formats" page

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

[jira] [Assigned] (FLINK-31257) Fix errors in “CSV Formats" page

[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31257: --- Assignee: ZhengYi Weng > Fix errors in “CSV Formats" page > - > >

[jira] [Commented] (FLINK-31257) Fix errors in “CSV Formats" page

[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694812#comment-17694812 ] Jark Wu commented on FLINK-31257: - You can translate it into “指定识别成 null 值的字符串，在输入端会将该字符串转为 null

[jira] [Commented] (FLINK-31259) Gateway supports initialization of catalog at startup

[ https://issues.apache.org/jira/browse/FLINK-31259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694811#comment-17694811 ] Jark Wu commented on FLINK-31259: - Could you share more details of the purpose and design? > Gateway

[jira] [Commented] (FLINK-31257) Fix errors in “CSV Formats" page

[ https://issues.apache.org/jira/browse/FLINK-31257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694506#comment-17694506 ] Jark Wu commented on FLINK-31257: - What error do you mean? Could you share the screenshot? > Fix errors

[jira] [Closed] (FLINK-30746) Flink Table / SQL Column types of query result and sink for do not match, but should

[ https://issues.apache.org/jira/browse/FLINK-30746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-30746. --- Resolution: Not A Problem I closed the issue for now. Feel free to reopen it if not the reason. > Flink

[jira] [Commented] (FLINK-30746) Flink Table / SQL Column types of query result and sink for do not match, but should

[ https://issues.apache.org/jira/browse/FLINK-30746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694071#comment-17694071 ] Jark Wu commented on FLINK-30746: - The exception is very clear, the column order is mismatched. In the

[jira] [Updated] (FLINK-30959) Improve the documentation of UNIX_TIMESTAMP for different argument format

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30959: Summary: Improve the documentation of UNIX_TIMESTAMP for different argument format (was:

[jira] [Updated] (FLINK-30959) UNIX_TIMESTAMP's return value does not meet expected

[ https://issues.apache.org/jira/browse/FLINK-30959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30959: Issue Type: Improvement (was: Bug) > UNIX_TIMESTAMP's return value does not meet expected >

[jira] [Commented] (FLINK-28985) support create table like view

[ https://issues.apache.org/jira/browse/FLINK-28985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694057#comment-17694057 ] Jark Wu commented on FLINK-28985: - Hi [~waywtdcc], as this involves exposing a new SQL syntax, it

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694058#comment-17694058 ] Jark Wu commented on FLINK-26541: - Looking forward to the FLIP [~Paul Lin]! > SQL Client should

[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694052#comment-17694052 ] Jark Wu commented on FLINK-28897: - A release note guides users on how to upgrade from an old version.

[jira] [Commented] (FLINK-23810) Print sql when parse failed , which is convenient to find error sql from multiple executed sql

[ https://issues.apache.org/jira/browse/FLINK-23810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17694036#comment-17694036 ] Jark Wu commented on FLINK-23810: - I think it's fine to add the DEBUG log. Adding INFO log seems verbose

[jira] [Assigned] (FLINK-12450) [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table API and SQL

[ https://issues.apache.org/jira/browse/FLINK-12450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-12450: --- Assignee: Ran Tao > [Bitwise Functions] Add BIT_LSHIFT, BIT_RSHIFT functions supported in Table >

[jira] [Updated] (FLINK-29729) Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29729: Summary: Fix credential info configured in flink-conf.yaml is lost during creating ParquetReader (was:

[jira] [Assigned] (FLINK-30129) Push projection through ChangelogNormalize

[ https://issues.apache.org/jira/browse/FLINK-30129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-30129: --- Assignee: Jark Wu > Push projection through ChangelogNormalize >

[jira] [Updated] (FLINK-30129) Push projection through ChangelogNormalize

[ https://issues.apache.org/jira/browse/FLINK-30129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30129: Fix Version/s: 1.18.0 > Push projection through ChangelogNormalize >

[jira] [Closed] (FLINK-30690) java document, web document, word some error perfect

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

[jira] [Updated] (FLINK-30292) Better support for conversion between DataType and TypeInformation

[ https://issues.apache.org/jira/browse/FLINK-30292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30292: Fix Version/s: 1.18.0 > Better support for conversion between DataType and TypeInformation >

[jira] [Closed] (FLINK-29880) Hive sink supports merge files in batch mode

[ https://issues.apache.org/jira/browse/FLINK-29880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29880. --- Assignee: luoyuxia Resolution: Fixed Fixed in master: cf358d7d55ca48b9d25e5217006898e3070a85ad >

[jira] [Comment Edited] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681930#comment-17681930 ] Jark Wu edited comment on FLINK-30679 at 1/31/23 3:08 AM: -- Fixed in - master:

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30679: Fix Version/s: 1.16.2 > Can not load the data of hive dim table when project-push-down is introduced >

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30679: Fix Version/s: 1.14.7 > Can not load the data of hive dim table when project-push-down is introduced >

[jira] [Updated] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30679: Fix Version/s: 1.15.4 > Can not load the data of hive dim table when project-push-down is introduced >

[jira] [Comment Edited] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

[ https://issues.apache.org/jira/browse/FLINK-30679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681930#comment-17681930 ] Jark Wu edited comment on FLINK-30679 at 1/30/23 11:46 AM: --- Fixed in -

[jira] [Closed] (FLINK-30679) Can not load the data of hive dim table when project-push-down is introduced

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

[jira] [Commented] (FLINK-28897) Fail to use udf in added jar when enabling checkpoint

[ https://issues.apache.org/jira/browse/FLINK-28897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17681561#comment-17681561 ] Jark Wu commented on FLINK-28897: - I reproduced this bug on the master branch. I think this bug was

[jira] [Comment Edited] (FLINK-29729) Support including the configured properties from flink-conf.yaml during create ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677818#comment-17677818 ] Jark Wu edited comment on FLINK-29729 at 1/17/23 3:54 PM: -- I think it's

[jira] [Commented] (FLINK-29729) Support including the configured properties from flink-conf.yaml during create ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677818#comment-17677818 ] Jark Wu commented on FLINK-29729: - I think it's reasonable for the parquet to be aware of

[jira] [Closed] (FLINK-29879) Introduce operators for files merging in batch mode

[ https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29879. --- Assignee: luoyuxia Resolution: Fixed Fixed in master: b5f465036d28ed422a1218bfb8549cbf3e6ecd2e >

[jira] [Commented] (FLINK-30130) Table.select lose watermark

[ https://issues.apache.org/jira/browse/FLINK-30130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17677130#comment-17677130 ] Jark Wu commented on FLINK-30130: - Sorry [~yunfengzhou] [~kamalesh0420], I don't think this is a problem

[jira] [Closed] (FLINK-30130) Table.select lose watermark

[ https://issues.apache.org/jira/browse/FLINK-30130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-30130. --- Resolution: Won't Fix > Table.select lose watermark > --- > > Key:

[jira] [Assigned] (FLINK-30694) Translate "Windowing TVF" page of "Querys" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-30694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-30694: --- Assignee: chenhaiyang (was: zhule) > Translate "Windowing TVF" page of "Querys" into Chinese >

[jira] [Comment Edited] (FLINK-30592) The unsupported hive version is not deleted on the hive overview document

[ https://issues.apache.org/jira/browse/FLINK-30592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17655878#comment-17655878 ] Jark Wu edited comment on FLINK-30592 at 1/11/23 2:09 AM: -- Fixed in - master:

[jira] [Updated] (FLINK-30592) The unsupported hive version is not deleted on the hive overview document

[ https://issues.apache.org/jira/browse/FLINK-30592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30592: Fix Version/s: 1.16.1 > The unsupported hive version is not deleted on the hive overview document >

[jira] [Closed] (FLINK-30592) The unsupported hive version is not deleted on the hive overview document

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

[jira] [Closed] (FLINK-30019) Remove the unused HiveTableFileInputFormat in hive connector

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

[jira] [Commented] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17643704#comment-17643704 ] Jark Wu commented on FLINK-30245: - [~zhongwei] could you open PRs for release-1.16 and release-1.15

[jira] [Closed] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-30245. --- Fix Version/s: 1.17.0 Assignee: Wei Zhong Resolution: Fixed Fixed in - master:

[jira] [Commented] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17641248#comment-17641248 ] Jark Wu commented on FLINK-30245: - cc [~lsy] do you have time to have a look at this? > NPE thrown when

[jira] [Updated] (FLINK-29729) Support including the configured properties from flink-conf.yaml during create ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29729: Fix Version/s: 1.17.0 > Support including the configured properties from flink-conf.yaml during > create

[jira] [Created] (FLINK-30129) Push projection through ChangelogNormalize

Jark Wu created FLINK-30129: --- Summary: Push projection through ChangelogNormalize Key: FLINK-30129 URL: https://issues.apache.org/jira/browse/FLINK-30129 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-30076) hive join mysql error

[ https://issues.apache.org/jira/browse/FLINK-30076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-30076: Component/s: Connectors / Hive > hive join mysql error > - > > Key:

[jira] [Updated] (FLINK-29486) Introduce Client Parser to get statement type

[ https://issues.apache.org/jira/browse/FLINK-29486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29486: Parent Issue: FLINK-29941 (was: FLINK-29073) > Introduce Client Parser to get statement type >

[jira] [Updated] (FLINK-29941) Support SQL Client connects to SQL Gateway

[ https://issues.apache.org/jira/browse/FLINK-29941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29941: Description: This is an umbrella issue to track the effort to support SQL Client connects to SQL

[jira] [Updated] (FLINK-29751) Migrate SQL Client Embedded Mode to use sql gateway

[ https://issues.apache.org/jira/browse/FLINK-29751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29751: Parent Issue: FLINK-29941 (was: FLINK-29073) > Migrate SQL Client Embedded Mode to use sql gateway >

[jira] [Created] (FLINK-29942) Improve average performance for TPC-DS

Jark Wu created FLINK-29942: --- Summary: Improve average performance for TPC-DS Key: FLINK-29942 URL: https://issues.apache.org/jira/browse/FLINK-29942 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-29941) Support SQL Client connects to SQL Gateway

Jark Wu created FLINK-29941: --- Summary: Support SQL Client connects to SQL Gateway Key: FLINK-29941 URL: https://issues.apache.org/jira/browse/FLINK-29941 Project: Flink Issue Type: New Feature

[jira] [Closed] (FLINK-29920) Minor reformat Kafka connector documentation

[ https://issues.apache.org/jira/browse/FLINK-29920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29920. --- Fix Version/s: 1.17.0 Assignee: Mingliang Liu Resolution: Fixed Fixed in master:

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17626425#comment-17626425 ] Jark Wu commented on FLINK-29801: - I think this is a nice feature. [~zhuzh] what do you think? >

[jira] [Closed] (FLINK-29458) When two tables have the same field, do not specify the table name,Exception will be thrown：SqlValidatorException :Column 'currency' is ambiguous

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

[jira] [Closed] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

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

[jira] [Updated] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

[ https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29271: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Change to byte array from bytebuffer to

[jira] [Commented] (FLINK-29692) Support early/late fires for Windowing TVFs

[ https://issues.apache.org/jira/browse/FLINK-29692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17621167#comment-17621167 ] Jark Wu commented on FLINK-29692: - I'm fine with supporting this feature. But we have supported

[jira] [Assigned] (FLINK-29679) DESCRIBE statement shows comment

[ https://issues.apache.org/jira/browse/FLINK-29679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-29679: --- Assignee: Yubin Li > DESCRIBE statement shows comment > > >

[jira] [Closed] (FLINK-29590) Fix literal issue in HiveDialect

[ https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29590. --- Resolution: Fixed > Fix literal issue in HiveDialect > > >

[jira] [Updated] (FLINK-29590) Fix literal issue in HiveDialect

[ https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29590: Fix Version/s: 1.16.0 > Fix literal issue in HiveDialect > > >

[jira] [Comment Edited] (FLINK-29590) Fix literal issue in HiveDialect

[ https://issues.apache.org/jira/browse/FLINK-29590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616976#comment-17616976 ] Jark Wu edited comment on FLINK-29590 at 10/17/22 9:14 AM: --- Fixed in -

[jira] [Updated] (FLINK-29350) Add a section for moving planner jar in Hive dependencies page

[ https://issues.apache.org/jira/browse/FLINK-29350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-29350: Fix Version/s: 1.16.0 > Add a section for moving planner jar in Hive dependencies page >

[jira] [Closed] (FLINK-29350) Add a section for moving planner jar in Hive dependencies page

[ https://issues.apache.org/jira/browse/FLINK-29350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-29350. --- Resolution: Fixed > Add a section for moving planner jar in Hive dependencies page >

[jira] [Comment Edited] (FLINK-29350) Add a section for moving planner jar in Hive dependencies page

[ https://issues.apache.org/jira/browse/FLINK-29350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17616974#comment-17616974 ] Jark Wu edited comment on FLINK-29350 at 10/17/22 9:13 AM: --- Fixed in -

<    1   2   3   4   5   6   7   8   9   10   >