[jira] [Commented] (FLINK-31756) KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException

[ https://issues.apache.org/jira/browse/FLINK-31756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709939#comment-17709939 ] Sergey Nuyanzin commented on FLINK-31756: - similar to

[jira] [Created] (FLINK-31756) KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException

Sergey Nuyanzin created FLINK-31756: --- Summary: KafkaTableITCase.testStartFromGroupOffsetsNone fails due to UnknownTopicOrPartitionException Key: FLINK-31756 URL:

[jira] [Commented] (FLINK-26402) MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste failed due to Container startup failed

[ https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709937#comment-17709937 ] Sergey Nuyanzin commented on FLINK-26402: -

[GitHub] [flink] luoyuxia commented on pull request #22301: [FLINK-31426][table] Upgrade the deprecated UniqueConstraint to the n…

luoyuxia commented on PR #22301: URL: https://github.com/apache/flink/pull/22301#issuecomment-1501027828 @clownxc Thanks for contribution. I'll have a look when i'm free -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] slfan1989 commented on pull request #22207: [FLINK-31510][yarn] Use getMemorySize instead of getMemory.

slfan1989 commented on PR #22207: URL: https://github.com/apache/flink/pull/22207#issuecomment-1501007098 > Thanks @slfan1989 for the update, would you mind squashing all to only one commit with the message like: @reswqa Thank you for your help to review the code! I will rebase and

[GitHub] [flink] wuchong closed pull request #22254: [FLINK-31597][table] Cleanup usage of deprecated TableEnvironment#registerFunction

wuchong closed pull request #22254: [FLINK-31597][table] Cleanup usage of deprecated TableEnvironment#registerFunction URL: https://github.com/apache/flink/pull/22254 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] wuchong commented on pull request #22254: [FLINK-31597][table] Cleanup usage of deprecated TableEnvironment#registerFunction

wuchong commented on PR #22254: URL: https://github.com/apache/flink/pull/22254#issuecomment-1500915644 I tried to cleanup the registerFunction usage. But it seems it is a big effort because of the different behavior between `registerFunction` and `createTemporarySystemFunction`, e.g., the

[jira] [Updated] (FLINK-31754) Build flink master error with Error in ASM processing class org/apache/calcite/sql/validate/SqlValidatorImpl$NavigationExpander.class: 19

[ https://issues.apache.org/jira/browse/FLINK-31754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31754: Description: maven 3.25 jdk 1.8 scala 2.12 window 10

[jira] [Commented] (FLINK-31629) Trying to access closed classloader when submit query to restSqlGateway via SqlClient

[ https://issues.apache.org/jira/browse/FLINK-31629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709898#comment-17709898 ] Weijie Guo commented on FLINK-31629: By offline discuss with [~luoyuxia], this issue can be fixed by

[jira] [Commented] (FLINK-31686) Filesystem connector should replace the shallow copy with deep copy

[ https://issues.apache.org/jira/browse/FLINK-31686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709887#comment-17709887 ] Jark Wu commented on FLINK-31686: - I think you are right. The current implementation has some problems.

[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=17709884#comment-17709884 ] Jark Wu commented on FLINK-29541: - Considering migrating for flink-table-planner is a huge effort, I

[jira] [Updated] (FLINK-31674) [JUnit5 Migration] Module: flink-table-planner (BatchAbstractTestBase)

[ https://issues.apache.org/jira/browse/FLINK-31674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31674: Parent Issue: FLINK-29541 (was: FLINK-25325) > [JUnit5 Migration] Module: flink-table-planner

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

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

[jira] [Commented] (FLINK-6757) Investigate Apache Atlas integration

[ https://issues.apache.org/jira/browse/FLINK-6757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709883#comment-17709883 ] Jark Wu commented on FLINK-6757: Hi [~litiliu], [~fangyong] is working on FLIP-294[1], which is designed

[jira] [Commented] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

[ https://issues.apache.org/jira/browse/FLINK-31661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709881#comment-17709881 ] Jark Wu commented on FLINK-31661: - This can be a big effort because we need to contribute this feature

[jira] [Updated] (FLINK-31661) Add parity between `ROW` value function and it's type declaration

[ https://issues.apache.org/jira/browse/FLINK-31661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31661: Component/s: Table SQL / API (was: API / DataSet) > Add parity between `ROW` value

[jira] [Closed] (FLINK-31550) Replace deprecated TableSchema with Schema in OperationConverterUtils

[ https://issues.apache.org/jira/browse/FLINK-31550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31550. --- Resolution: Invalid I might checkout an outdated branch. Thank you for pointing out this. > Replace

[jira] [Updated] (FLINK-31629) Trying to access closed classloader when submit query to restSqlGateway via SqlClient

[ https://issues.apache.org/jira/browse/FLINK-31629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31629: Component/s: Connectors / Hive > Trying to access closed classloader when submit query to restSqlGateway

[jira] [Commented] (FLINK-31629) Trying to access closed classloader when submit query to restSqlGateway via SqlClient

[ https://issues.apache.org/jira/browse/FLINK-31629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709879#comment-17709879 ] Jark Wu commented on FLINK-31629: - cc [~fsk119] [~luoyuxia] > Trying to access closed classloader when

[jira] [Assigned] (FLINK-31606) Translate "sqlClient.md" page of "table" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-31606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-31606: --- Assignee: Fang Yong > Translate "sqlClient.md" page of "table" into Chinese >

[jira] [Updated] (FLINK-31607) Refactor the logic for HiveExecutableOperation

[ https://issues.apache.org/jira/browse/FLINK-31607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-31607: Component/s: Connectors / Hive > Refactor the logic for HiveExecutableOperation >

[GitHub] [flink] wuchong closed pull request #22276: [FLINK-31603][table-planner] Line break should be removed in create t…

wuchong closed pull request #22276: [FLINK-31603][table-planner] Line break should be removed in create t… URL: https://github.com/apache/flink/pull/22276 -- 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

[GitHub] [flink] wuchong commented on pull request #22276: [FLINK-31603][table-planner] Line break should be removed in create t…

wuchong commented on PR #22276: URL: https://github.com/apache/flink/pull/22276#issuecomment-1500878784 I would like to close this PR first. The community suggests reaching a consensus before opening a pull request. Feel free to continue the discussion on the JIRA issue. -- This is an

[jira] [Closed] (FLINK-31603) Line break should be removed in create table with-clauses, load module with-clauses and table hints for both keys and values

[ https://issues.apache.org/jira/browse/FLINK-31603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-31603. --- Fix Version/s: (was: 1.18.0) Resolution: Invalid I will close this issue first, feel free to

[jira] [Updated] (FLINK-31713) k8s operator should gather job version metrics

[ https://issues.apache.org/jira/browse/FLINK-31713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31713: --- Labels: pull-request-available (was: ) > k8s operator should gather job version metrics >

[GitHub] [flink-kubernetes-operator] mateczagany opened a new pull request, #562: [FLINK-31713] Expose FlinkDeployment version metrics

mateczagany opened a new pull request, #562: URL: https://github.com/apache/flink-kubernetes-operator/pull/562 ## What is the purpose of the change Expose count of Flink versions on a per namespace basis via metrics ## Brief change log - Create new gauge in

[GitHub] [flink] WencongLiu commented on pull request #22341: [FLINK-27204] Refract FileSystemJobResultStore to execute I/O operations on the ioExecutor

WencongLiu commented on PR #22341: URL: https://github.com/apache/flink/pull/22341#issuecomment-1500819380 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific