[jira] [Commented] (FLINK-30444) State recovery error not handled correctly and always causes JM failure

2022-12-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648994#comment-17648994 ] Gyula Fora commented on FLINK-30444: This also not consistent with some other startup errors such

[GitHub] [flink] yuzelin opened a new pull request, #21525: [FLINK-30416][sql-gateway] Add configureSession REST API in the SQL Gateway

2022-12-18 Thread GitBox
yuzelin opened a new pull request, #21525: URL: https://github.com/apache/flink/pull/21525 ## What is the purpose of the change Add configureSession REST API in the SQL Gateway. ## Brief change log - Add `ConfigureSessionHandler`, `ConfigureSessionHeaders`,

[jira] [Updated] (FLINK-30416) Add configureSession REST API in the SQL Gateway

2022-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30416: --- Labels: pull-request-available (was: ) > Add configureSession REST API in the SQL Gateway

[jira] [Assigned] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-30411: -- Assignee: Kumar > Flink deployment stuck in UPGRADING state when deploy flinkdeployment

[jira] [Commented] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-18 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648977#comment-17648977 ] Gyula Fora commented on FLINK-30411: Thank you[~nowke] , we can backport this to 1.3 after it’s

[GitHub] [flink] yuzelin opened a new pull request, #21523: [FLINK-30449][sql-gateway] Introduce ResultInfo to improve the serial…

2022-12-18 Thread GitBox
yuzelin opened a new pull request, #21523: URL: https://github.com/apache/flink/pull/21523 …ization and deserialization of FetchResultsResponseBody. ## What is the purpose of the change Currently, the REST endpoint serialize and deserialize the ResultSet in the

[GitHub] [flink-kubernetes-operator] gyfora opened a new pull request, #488: [FLINK-30437][FLINK-30408] Harden HA meta check to avoid state loss

2022-12-18 Thread GitBox
gyfora opened a new pull request, #488: URL: https://github.com/apache/flink-kubernetes-operator/pull/488 ## What is the purpose of the change The previous HA metadata check recognizes unrelated configmaps as HA metadata which can under certain circumstances lead to state loss.

[jira] [Updated] (FLINK-30437) State incompatibility issue might cause state loss

2022-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30437: --- Labels: pull-request-available (was: ) > State incompatibility issue might cause state

[GitHub] [flink] lincoln-lil commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-12-18 Thread GitBox
lincoln-lil commented on PR #21219: URL: https://github.com/apache/flink/pull/21219#issuecomment-1356767872 @godfreyhe I've updated the pr and tried to add a new rule EventTimeTemporalJoinRewriteRule to replace the previous shuttle implementation and improved the error msg. Just simply

[jira] [Updated] (FLINK-30449) Improve Serialization and Deserialization of FetchResultsResponseBody

2022-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30449: --- Labels: pull-request-available (was: ) > Improve Serialization and Deserialization of

[GitHub] [flink-kubernetes-operator] nowke opened a new pull request, #487: [FLINK-30411] Validate empty JmSpec and TmSpec

2022-12-18 Thread GitBox
nowke opened a new pull request, #487: URL: https://github.com/apache/flink-kubernetes-operator/pull/487 ## What is the purpose of the change This PR validates `FlinkDeployment` without `jobManager` or `taskManager` spec. Currently, `FlinkDeployment` gets stuck in `UPGRADING` state

[jira] [Updated] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

2022-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30411: --- Labels: pull-request-available (was: ) > Flink deployment stuck in UPGRADING state when

[GitHub] [flink] Aitozi commented on pull request #21522: [FLINK-29585][hive] Migrate TableSchema to Schema for Hive connector

2022-12-18 Thread GitBox
Aitozi commented on PR #21522: URL: https://github.com/apache/flink/pull/21522#issuecomment-1356772077 cc @luoyuxia @wuchong please take a look when you are free -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] lincoln-lil commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-12-18 Thread GitBox
lincoln-lil commented on PR #21219: URL: https://github.com/apache/flink/pull/21219#issuecomment-1356805211 @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

[GitHub] [flink] flinkbot commented on pull request #21523: [FLINK-30449][sql-gateway] Introduce ResultInfo to improve the serialization and deserialization of FetchResultsResponseBody

2022-12-18 Thread GitBox
flinkbot commented on PR #21523: URL: https://github.com/apache/flink/pull/21523#issuecomment-1356783193 ## CI report: * b6680cef62c6e1634ac7b8d7bfa50b60e3e34b00 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] flinkbot commented on pull request #21524: [hotfix] Avoiding unsecure HTTP reference to JBoss repo

2022-12-18 Thread GitBox
flinkbot commented on PR #21524: URL: https://github.com/apache/flink/pull/21524#issuecomment-1356798403 ## CI report: * 1545490304d690ba39d988fbb410651085771f7b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21443: [FLINK-30213] Change ForwardPartitioner to RebalancePartitioner on parallelism changes

2022-12-18 Thread GitBox
1996fanrui commented on code in PR #21443: URL: https://github.com/apache/flink/pull/21443#discussion_r1051603792 ## flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java: ## @@ -122,6 +130,9 @@ import

[GitHub] [flink] lincoln-lil commented on a diff in pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-12-18 Thread GitBox
lincoln-lil commented on code in PR #21219: URL: https://github.com/apache/flink/pull/21219#discussion_r1051569801 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkSnapshotConverter.java: ## @@ -0,0 +1,95 @@ +/* + * Licensed to the

[GitHub] [flink] gunnarmorling opened a new pull request, #21524: [hotfix] Avoiding unsecure HTTP reference to JBoss repo

2022-12-18 Thread GitBox
gunnarmorling opened a new pull request, #21524: URL: https://github.com/apache/flink/pull/21524 I'm not totally sure whether this repo actually is required, as I could build the project with current Maven versions (which block non-HTTPS access), but changing it to make use of HTTPS seems

[GitHub] [flink] flinkbot commented on pull request #21525: [FLINK-30416][sql-gateway] Add configureSession REST API in the SQL Gateway

2022-12-18 Thread GitBox
flinkbot commented on PR #21525: URL: https://github.com/apache/flink/pull/21525#issuecomment-1356834105 ## CI report: * 1c3a82cf18e77cf18e4c10d5046d29e375591112 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-30449) Improve Serialization and Deserialization of FetchResultsResponseBody

2022-12-18 Thread yuzelin (Jira)
yuzelin created FLINK-30449: --- Summary: Improve Serialization and Deserialization of FetchResultsResponseBody Key: FLINK-30449 URL: https://issues.apache.org/jira/browse/FLINK-30449 Project: Flink

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

2022-12-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649023#comment-17649023 ] ouyangwulin commented on FLINK-26541: - Please assign the ticket to me [~wangyang0918]  > SQL Client

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21111: [FLINK-29664][runtime] Collect subpartition sizes of blocking result partitions

2022-12-18 Thread GitBox
wanglijie95 commented on code in PR #2: URL: https://github.com/apache/flink/pull/2#discussion_r1051748924 ## flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerTest.java: ## @@ -117,25 +139,139 @@ void

[jira] [Updated] (FLINK-29996) Link to the task manager's thread dump page in the backpressure tab

2022-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29996: --- Labels: pull-request-available (was: ) > Link to the task manager's thread dump page in

[jira] [Closed] (FLINK-30204) Table Store support separated compact jobs

2022-12-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30204. --- Resolution: Fixed > Table Store support separated compact jobs >

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21111: [FLINK-29664][runtime] Collect subpartition sizes of blocking result partitions

2022-12-18 Thread GitBox
wanglijie95 commented on code in PR #2: URL: https://github.com/apache/flink/pull/2#discussion_r1051749457 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchScheduler.java: ## @@ -150,10 +164,62 @@ protected void

[jira] [Closed] (FLINK-30212) Introduce a TableStoreCompactJob class for users to submit compact jobs in Table Store

2022-12-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30212. --- Resolution: Fixed master: 15af711a1bf50b2d612b439a27225c8ad42acb1d > Introduce a

[jira] [Updated] (FLINK-30450) FileSystem supports exporting client-side metrics

2022-12-18 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu updated FLINK-30450: - Description: Client-side metrics, or job level metrics for filesystem could help us to monitor

[GitHub] [flink] xintongsong commented on a diff in pull request #21447: [FLINK-30185] Provide the flame graph to the subtask level

2022-12-18 Thread GitBox
xintongsong commented on code in PR #21447: URL: https://github.com/apache/flink/pull/21447#discussion_r1051736030 ## flink-runtime/src/main/java/org/apache/flink/runtime/messages/ThreadInfoSample.java: ## @@ -32,25 +36,33 @@ */ public class ThreadInfoSample implements

[GitHub] [flink] 1996fanrui commented on pull request #21447: [FLINK-30185] Provide the flame graph to the subtask level

2022-12-18 Thread GitBox
1996fanrui commented on PR #21447: URL: https://github.com/apache/flink/pull/21447#issuecomment-1357004999 Hi @xintongsong , I have finished the step1, could you help take a look in your free time? And could I finish the step2 in the next PR? -- This is an automated message from

[GitHub] [flink] yuchen-ecnu commented on a diff in pull request #21485: [FLINK-29997] Link to the taskmanager page in the expired sub-task of…

2022-12-18 Thread GitBox
yuchen-ecnu commented on code in PR #21485: URL: https://github.com/apache/flink/pull/21485#discussion_r1051806981 ## flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/subtask/job-checkpoints-subtask.component.html: ## @@ -181,7 +186,19 @@ {{

[jira] [Commented] (FLINK-26088) Add Elasticsearch 8.0 support

2022-12-18 Thread Matheus Felisberto (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649108#comment-17649108 ] Matheus Felisberto commented on FLINK-26088: Thank you [~chalixar], I appreciate that. :D

[jira] [Updated] (FLINK-30448) "filter(Objects::nonNull)" will bring down task with failure cause: ClassCastException

2022-12-18 Thread Yong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yong updated FLINK-30448: - Description: Attached an *all-in-one* java program, which can run locally in DEV environment(e.g. IntelliJ

[GitHub] [flink] lincoln-lil commented on pull request #21219: [FLINK-29849][table-planner] Fix event time temporal join on an upsert source may produce incorrect execution plan

2022-12-18 Thread GitBox
lincoln-lil commented on PR #21219: URL: https://github.com/apache/flink/pull/21219#issuecomment-1356937839 @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

[GitHub] [flink] masteryhx commented on a diff in pull request #21468: [FLINK-30345][state/changelog] Avoid using sync DataOutputViewStreamWrapper to serialize records to changelog

2022-12-18 Thread GitBox
masteryhx commented on code in PR #21468: URL: https://github.com/apache/flink/pull/21468#discussion_r1051733639 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/KvStateChangeLoggerImpl.java: ## @@ -78,21 +79,25 @@ public void

[GitHub] [flink-table-store] tsreaper merged pull request #437: [FLINK-30212] Introduce a TableStoreCompactJob class for users to submit compact jobs in Table Store

2022-12-18 Thread GitBox
tsreaper merged PR #437: URL: https://github.com/apache/flink-table-store/pull/437 -- 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. To unsubscribe, e-mail:

[GitHub] [flink] yuchen-ecnu commented on pull request #21465: [FLINK-29996] Link to the task manager's thread dump page in the back…

2022-12-18 Thread GitBox
yuchen-ecnu commented on PR #21465: URL: https://github.com/apache/flink/pull/21465#issuecomment-1357009789 > Hi @yuchen-ecnu , thanks for your contribution, the PR makes sense. > > The commit message and PR title is [FLINK-29995](https://issues.apache.org/jira/browse/FLINK-29995),

[GitHub] [flink] yuchen-ecnu commented on pull request #21465: [FLINK-29996] Link to the task manager's thread dump page in the back…

2022-12-18 Thread GitBox
yuchen-ecnu commented on PR #21465: URL: https://github.com/apache/flink/pull/21465#issuecomment-1357107268 > @yuchen-ecnu Please refine the commit message to point to [FLINK-29996](https://issues.apache.org/jira/browse/FLINK-29996), and the rest part looks good to me. Thanks for

[GitHub] [flink] ramkrish86 commented on pull request #21508: [FLINK-30128] Introduce Azure Data Lake Gen2 APIs in the Hadoop Recoverable path

2022-12-18 Thread GitBox
ramkrish86 commented on PR #21508: URL: https://github.com/apache/flink/pull/21508#issuecomment-1357107009 @xintongsong - A gentle ping!!! -- 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

[jira] [Created] (FLINK-30451) Add Estimator and Transformer for Swing

2022-12-18 Thread Zhipeng Zhang (Jira)
Zhipeng Zhang created FLINK-30451: - Summary: Add Estimator and Transformer for Swing Key: FLINK-30451 URL: https://issues.apache.org/jira/browse/FLINK-30451 Project: Flink Issue Type: New

[GitHub] [flink] flinkbot commented on pull request #21526: [FLINK-28796] Add completeStatement REST API in the SQL Gateway

2022-12-18 Thread GitBox
flinkbot commented on PR #21526: URL: https://github.com/apache/flink/pull/21526#issuecomment-1356844463 ## CI report: * b93838edfccd425e51e87901bdf853749bafb0e3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Closed] (FLINK-30410) Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store

2022-12-18 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30410. --- Resolution: Fixed master: e6156e2f2998a5c7227f0a40512f03312f041e0a > Rename 'full' to

[GitHub] [flink] yuchen-ecnu commented on a diff in pull request #21498: [FLINK-30392] Replace default thread dump depth to 24

2022-12-18 Thread GitBox
yuchen-ecnu commented on code in PR #21498: URL: https://github.com/apache/flink/pull/21498#discussion_r1051818487 ## docs/layouts/shortcodes/generated/cluster_configuration.html: ## @@ -70,7 +70,7 @@ cluster.thread-dump.stacktrace-max-depth -

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21468: [FLINK-30345][state/changelog] Avoid using sync DataOutputViewStreamWrapper to serialize records to changelog

2022-12-18 Thread GitBox
rkhachatryan commented on code in PR #21468: URL: https://github.com/apache/flink/pull/21468#discussion_r1051681637 ## flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/KvStateChangeLoggerImpl.java: ## @@ -78,21 +79,25 @@ public

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

2022-12-18 Thread ouyangwulin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26541 ] ouyangwulin deleted comment on FLINK-26541: - was (Author: ouyangwuli): Please assign the ticket to me [~wangyang0918]  > SQL Client should support submitting SQL jobs in application mode >

[jira] [Created] (FLINK-30450) FileSystem supports exporting client-side metrics

2022-12-18 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-30450: Summary: FileSystem supports exporting client-side metrics Key: FLINK-30450 URL: https://issues.apache.org/jira/browse/FLINK-30450 Project: Flink Issue

[jira] [Updated] (FLINK-28796) Add Statement Completement API for sql gateway rest endpoint

2022-12-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28796: --- Labels: pull-request-available (was: ) > Add Statement Completement API for sql gateway

[GitHub] [flink] xintongsong commented on a diff in pull request #21347: [FLINK-29640][Client/Job Submission]Enhance the function configured by execution.shutdown-on-attached-exi…

2022-12-18 Thread GitBox
xintongsong commented on code in PR #21347: URL: https://github.com/apache/flink/pull/21347#discussion_r1051748186 ## flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java: ## @@ -1344,6 +1344,13 @@ public CompletableFuture>

[GitHub] [flink] yuzelin opened a new pull request, #21526: [FLINK-28796] Add completeStatement REST API in the SQL Gateway

2022-12-18 Thread GitBox
yuzelin opened a new pull request, #21526: URL: https://github.com/apache/flink/pull/21526 ## What is the purpose of the change Add completeStatement REST API in the SQL Gateway. ## Brief change log - Add `CompleteStatementHandler`,

[GitHub] [flink-table-store] tsreaper merged pull request #439: [FLINK-30410] Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store

2022-12-18 Thread GitBox
tsreaper merged PR #439: URL: https://github.com/apache/flink-table-store/pull/439 -- 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. To unsubscribe, e-mail:

[jira] [Resolved] (FLINK-29997) Link to the taskmanager page in the expired sub-task of checkpoint tab

2022-12-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-29997. -- Resolution: Fixed merged in master: 1064b13a2f2e0bdae64bdaecce10ec22a162a5e1 > Link to the

[jira] [Updated] (FLINK-26426) Hive dialect support "create table like"

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26426: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Hive dialect support "create

[jira] [Updated] (FLINK-27603) Hive dialect supports "reload function"

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Hive dialect supports "reload

[jira] [Updated] (FLINK-27374) Fix using wrong Flink type for Hive's void type

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27374: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Fix using wrong Flink type

[jira] [Reopened] (FLINK-30335) [Umbrella] Improvement for Hive Query Syntax Compatibility-Part2

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reopened FLINK-30335: -- > [Umbrella] Improvement for Hive Query Syntax Compatibility-Part2 >

[jira] [Updated] (FLINK-26415) support partitioned view in hive dialect

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26415: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > support partitioned view in hive dialect

[jira] [Updated] (FLINK-27859) Hive dialect should support create table whose name begins with digits

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27859: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Hive dialect should support create table

[jira] [Updated] (FLINK-27374) Fix using wrong Flink type for Hive's void type

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27374: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Fix using wrong Flink type for Hive's

[jira] [Updated] (FLINK-27850) Hive dialect supports "add file xxx"

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27850: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Hive dialect supports "add file xxx" >

[jira] [Updated] (FLINK-27014) Fix exception when select null literal in subquery for Hive dialect

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27014: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Fix exception when select null literal

[jira] [Updated] (FLINK-28317) Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28317: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Throw unsupport exception when

[jira] [Updated] (FLINK-27375) Fix exception when no order keys exists in over() in Hive Dialect

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27375: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Fix exception when no order keys exists

[GitHub] [flink] Myasuka merged pull request #21485: [FLINK-29997] Link to the taskmanager page in the expired sub-task of…

2022-12-18 Thread GitBox
Myasuka merged PR #21485: URL: https://github.com/apache/flink/pull/21485 -- 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. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-26426) Hive dialect support "create table like"

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26426: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Hive dialect support "create table like"

[jira] [Created] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
luoyuxia created FLINK-30452: Summary: Wrong argument type is used when call Hive's function Key: FLINK-30452 URL: https://issues.apache.org/jira/browse/FLINK-30452 Project: Flink Issue Type:

[jira] [Updated] (FLINK-27375) Fix exception when no order keys exists in over() in Hive Dialect

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27375: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Fix exception when no order

[jira] [Updated] (FLINK-26415) support partitioned view in hive dialect

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-26415: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > support partitioned view in

[jira] [Updated] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-30452: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Wrong argument type is used when call

[jira] [Updated] (FLINK-27603) Hive dialect supports "reload function"

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27603: - Parent: FLINK-30335 Issue Type: Sub-task (was: Bug) > Hive dialect supports "reload function"

[jira] [Updated] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-30452: - Description: While calling Hive function, if the argument is void type, it will be [considered as

[jira] [Comment Edited] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649196#comment-17649196 ] luoyuxia edited comment on FLINK-30452 at 12/19/22 7:54 AM: I don't think

[jira] [Comment Edited] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649196#comment-17649196 ] luoyuxia edited comment on FLINK-30452 at 12/19/22 7:53 AM: I don't think

[jira] [Comment Edited] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649196#comment-17649196 ] luoyuxia edited comment on FLINK-30452 at 12/19/22 7:53 AM: I don't think

[jira] [Updated] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-30452: - Description: While calling Hive function, if the argument is void type, it will be [considered as

[GitHub] [flink] 1996fanrui commented on pull request #21465: [FLINK-29996] Link to the task manager's thread dump page in the back…

2022-12-18 Thread GitBox
1996fanrui commented on PR #21465: URL: https://github.com/apache/flink/pull/21465#issuecomment-1357222199 @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

[jira] [Commented] (FLINK-30452) Wrong argument type is used when call Hive's function

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649196#comment-17649196 ] luoyuxia commented on FLINK-30452: -- I don't think when we do the type inference, void type should be

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21162: [FLINK-29665][runtime] Support flexible subpartion range division

2022-12-18 Thread GitBox
zhuzhurk commented on code in PR #21162: URL: https://github.com/apache/flink/pull/21162#discussion_r1049598360 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SubpartitionIndexRange.java: ## @@ -0,0 +1,27 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-28317) Throw unsupport exception when RexSubQuery contains LogicalUnion and correlate variables

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28317: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Throw unsupport exception

[jira] [Resolved] (FLINK-26360) [Umbrella] Improvement for Hive Query Syntax Compatibility

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia resolved FLINK-26360. -- Resolution: Fixed > [Umbrella] Improvement for Hive Query Syntax Compatibility >

[jira] [Updated] (FLINK-27850) Hive dialect supports "add file xxx"

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27850: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Hive dialect supports "add

[jira] [Updated] (FLINK-27859) Hive dialect should support create table whose name begins with digits

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27859: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Hive dialect should support

[jira] [Updated] (FLINK-28741) Unexpected result if insert 'false' to boolean column

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-28741: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Unexpected result if insert

[jira] [Updated] (FLINK-27014) Fix exception when select null literal in subquery for Hive dialect

2022-12-18 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-27014: - Parent: (was: FLINK-26360) Issue Type: Bug (was: Sub-task) > Fix exception when select