[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&focusedCommentId=17709939#comment-17709939 ] Sergey Nuyanzin commented on FLINK-31756: - similar to https://issues.apache.org/

[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: https://issues.apache.org/jira/browse/FLINK-31756

[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&focusedCommentId=17709937#comment-17709937 ] Sergey Nuyanzin commented on FLINK-26402: - https://dev.azure.com/apache-flink/ap

[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 su

[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 UR

[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 [E:\Project\flink\flink\flink-table\flink-table-p

[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&focusedCommentId=17709898#comment-17709898 ] Weijie Guo commented on FLINK-31629: By offline discuss with [~luoyuxia], this issue

[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&focusedCommentId=17709887#comment-17709887 ] Jark Wu commented on FLINK-31686: - I think you are right. The current implementation has

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

[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 (BatchAbstr

[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] Mo

[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&focusedCommentId=17709883#comment-17709883 ] Jark Wu commented on FLINK-6757: Hi [~litiliu], [~fangyong] is working on FLIP-294[1], wh

[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&focusedCommentId=17709881#comment-17709881 ] Jark Wu commented on FLINK-31661: - This can be a big effort because we need to contribut

[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 fu

[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 deprec

[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 v

[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&focusedCommentId=17709879#comment-17709879 ] Jark Wu commented on FLINK-31629: - cc [~fsk119] [~luoyuxia] > Trying to access closed c

[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 g

[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 a

[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 cont

[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 FlinkDeploymen

[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 comment