[
https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649196#comment-17649196
]
luoyuxia edited comment on FLINK-30452 at 12/19/22 7:54 AM:
[
https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649196#comment-17649196
]
luoyuxia edited comment on FLINK-30452 at 12/19/22 7:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649196#comment-17649196
]
luoyuxia edited comment on FLINK-30452 at 12/19/22 7:53 AM:
[
https://issues.apache.org/jira/browse/FLINK-30452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649196#comment-17649196
]
luoyuxia commented on FLINK-30452:
--
I don't think when we do the type inference, void t
[
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 strin
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 comment
[
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 strin
[
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"
>
[
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 Hiv
[
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 voi
[
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
[
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
[
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"
> --
[
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 in
[
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 i
[
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 RexSubQuer
[
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"
[
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
> -
[
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 when
[
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 null
[
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 'f
[
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 cr
[
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 fil
[
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 ke
[
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 hi
[
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 for
[
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
[
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 t
[
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
> -
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: Bug
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 Foundat
[
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 taskmanage
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: issues-unsubscr...@flink.apach
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 Fea
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
-
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 the
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 spe
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 @@
{{ subTask['unal
[
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
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 Type:
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>
listCompletedClusterDatas
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 startScheduling
[
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 TableStoreCompactJ
[
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
> ---
[
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 the
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 testDecideParallelis
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), as
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: issues-unsubscr...@fl
[
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 'latest-full'
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: issues-unsubscr...@fl
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 th
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 Serial
[ 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
> -
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 n
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 commen
[
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 IDEA
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649108#comment-17649108
]
Matheus Felisberto commented on FLINK-26088:
Thank you [~chalixar], I apprec
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 voi
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`
[
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 res
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`, `CompleteStatementHea
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`
[
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
>
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`,
`Co
[
https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649023#comment-17649023
]
ouyangwulin commented on FLINK-26541:
-
Please assign the ticket to me [~wangyang0918
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 commen
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 org.apache.flink.streaming.api.ope
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`
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 a
[
https://issues.apache.org/jira/browse/FLINK-30444?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17648994#comment-17648994
]
Gyula Fora commented on FLINK-30444:
This also not consistent with some other startu
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`
[
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 Fetch
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
FetchResults
[
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 loss
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.
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
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
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 enu
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 Apa
[
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 dep
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 if
[
https://issues.apache.org/jira/browse/FLINK-30411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17648977#comment-17648977
]
Gyula Fora commented on FLINK-30411:
Thank you[~nowke] , we can backport this to 1.3
[
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 witho
83 matches
Mail list logo
