[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yiwei93 updated FLINK-29881:
Description:
use restful api , fetch result from
{code:java}
JingGe commented on code in PR #21219:
URL: https://github.com/apache/flink/pull/21219#discussion_r1013714868
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -449,6 +456,34 @@ protected
JingGe commented on code in PR #21219:
URL: https://github.com/apache/flink/pull/21219#discussion_r1013714868
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -449,6 +456,34 @@ protected
JingGe commented on code in PR #21219:
URL: https://github.com/apache/flink/pull/21219#discussion_r1013714868
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkFilterJoinRule.java:
##
@@ -449,6 +456,34 @@ protected
XComp commented on PR #20805:
URL: https://github.com/apache/flink/pull/20805#issuecomment-1303090295
@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.
XComp commented on PR #20805:
URL: https://github.com/apache/flink/pull/20805#issuecomment-1303090201
Failure caused by FLINK-24119
--
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
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628761#comment-17628761
]
Matthias Pohl commented on FLINK-24119:
---
XComp commented on PR #21236:
URL: https://github.com/apache/flink/pull/21236#issuecomment-1303089291
@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.
XComp commented on PR #21236:
URL: https://github.com/apache/flink/pull/21236#issuecomment-1303089170
Failure caused by FLINK-29427
--
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
Jane Chan created FLINK-29882:
-
Summary: LargeDataITCase is not stable
Key: FLINK-29882
URL: https://issues.apache.org/jira/browse/FLINK-29882
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628760#comment-17628760
]
Matthias Pohl commented on FLINK-29427:
---
flinkbot commented on PR #21240:
URL: https://github.com/apache/flink/pull/21240#issuecomment-1303083921
## CI report:
* 2b10e7fcf4f1415cff76ef088e5a74dcf5ea4561 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
gyfora commented on code in PR #425:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1013707053
##
docs/content/docs/custom-resource/reference.md:
##
@@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment
custom resource
[
https://issues.apache.org/jira/browse/FLINK-29740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-29740:
--
Assignee: Martijn Visser
> [FLIP-265] Deprecate all customer-facing Scala APIs
>
[
https://issues.apache.org/jira/browse/FLINK-26088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628747#comment-17628747
]
Martijn Visser commented on FLINK-26088:
[~iture123] Why haven't you been using the new Java API
cvaliente opened a new pull request, #21240:
URL: https://github.com/apache/flink/pull/21240
## What is the purpose of the change
the example uses the same parameter name in the outer method
`eval(CompletableFuture> result, String rowkey)` and in the
inner `public void
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628743#comment-17628743
]
yiwei93 commented on FLINK-29881:
-
Hi,
thank you for replying
the problem your mentioned is what
tsreaper opened a new pull request, #353:
URL: https://github.com/apache/flink-table-store/pull/353
(Cherry-picked from #349).
--
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
yangjf2019 commented on code in PR #425:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1013686219
##
docs/content/docs/custom-resource/reference.md:
##
@@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment
custom resource
[
https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628728#comment-17628728
]
Samrat Deb commented on FLINK-29878:
Yes ! looking into it
> Fail to use
[
https://issues.apache.org/jira/browse/FLINK-18229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628727#comment-17628727
]
Weihua Hu commented on FLINK-18229:
---
Hi, [~xtsong] I have updated the design doc. To make the changes
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628723#comment-17628723
]
yuzelin edited comment on FLINK-29881 at 11/4/22 7:02 AM:
--
Hi,
Maybe it is a
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628723#comment-17628723
]
yuzelin edited comment on FLINK-29881 at 11/4/22 7:01 AM:
--
Hi,
Maybe it is a
[
https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603314#comment-17603314
]
Qingsheng Ren edited comment on FLINK-28975 at 11/4/22 6:59 AM:
Fixed on
PatrickRen merged PR #20831:
URL: https://github.com/apache/flink/pull/20831
--
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:
PatrickRen commented on PR #20831:
URL: https://github.com/apache/flink/pull/20831#issuecomment-1303046885
A successful run:
https://renqs.visualstudio.com/Apache%20Flink/_build/results?buildId=417=results
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628723#comment-17628723
]
yuzelin edited comment on FLINK-29881 at 11/4/22 6:53 AM:
--
Hi,
Maybe it is a
tsreaper merged PR #349:
URL: https://github.com/apache/flink-table-store/pull/349
--
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:
yangjf2019 commented on code in PR #425:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1013676491
##
docs/content/docs/custom-resource/reference.md:
##
@@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment
custom resource
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628723#comment-17628723
]
yuzelin commented on FLINK-29881:
-
Hi,
Maybe it is a little misleading, let me explain.
Currently,
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yiwei93 updated FLINK-29881:
Attachment: image-2022-11-04-14-47-00-762.png
> when Fetch results in sql gateway, the result using open
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013672492
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java:
##
@@ -93,48 +87,47 @@ public class
gyfora commented on code in PR #425:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/425#discussion_r1013668485
##
docs/content/docs/custom-resource/reference.md:
##
@@ -67,7 +67,7 @@ This page serves as a full reference for FlinkDeployment
custom resource
[
https://issues.apache.org/jira/browse/FLINK-29876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29876:
---
Labels: pull-request-available (was: )
> Explicitly throw exception from Table Store sink
tsreaper opened a new pull request, #352:
URL: https://github.com/apache/flink-table-store/pull/352
Currently table store sink does not support unaligned checkpoint or at least
once checkpoint mode, but no exception is explicitly thrown. We should throw
exception so that users can change
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1303034139
Thanks everyone for your comments and discussion, which is very meaningful
to me. Based on the above discussion, I think @xintongsong's suggestion looks
good to me, +1 for this plan.
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628715#comment-17628715
]
Leonard Xu commented on FLINK-29877:
I don't see a reasonable opinion that we should mark this issue
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29877:
---
Priority: Major (was: Blocker)
> Failed to fetch next result
> ---
>
>
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628708#comment-17628708
]
yuanfenghu commented on FLINK-29881:
The executestatment operation is asynchronous, you have to get
[
https://issues.apache.org/jira/browse/FLINK-29876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29876:
---
Assignee: Caizhi Weng
> Explicitly throw exception from Table Store sink when unaligned
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29874:
---
Component/s: BuildSystem / Shaded
> Streaming File Sink end-to-end test failed on azure due to
>
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628707#comment-17628707
]
Leonard Xu commented on FLINK-29874:
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628706#comment-17628706
]
Leonard Xu commented on FLINK-29874:
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu updated FLINK-29874:
---
Priority: Critical (was: Major)
> Streaming File Sink end-to-end test failed on azure due to
>
[
https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628705#comment-17628705
]
Leonard Xu commented on FLINK-29874:
[
https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628703#comment-17628703
]
Leonard Xu commented on FLINK-29836:
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628702#comment-17628702
]
penney commented on FLINK-29877:
-
It's TableA union all TableB union all TableC.The data volume of the
[
https://issues.apache.org/jira/browse/FLINK-29877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
penney updated FLINK-29877:
Attachment: image-2022-11-04-14-22-36-466.png
> Failed to fetch next result
> ---
[
https://issues.apache.org/jira/browse/FLINK-25587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628699#comment-17628699
]
Leonard Xu commented on FLINK-25587:
##[error]Exit code 137 returned from process: file name
yiwei93 created FLINK-29881:
---
Summary: when Fetch results in sql gateway, the result using open
api is different from using restful api
Key: FLINK-29881
URL: https://issues.apache.org/jira/browse/FLINK-29881
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628690#comment-17628690
]
Jiale Tan edited comment on FLINK-29610 at 11/4/22 6:16 AM:
[~gaoyunhaii]
[
https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628695#comment-17628695
]
Leonard Xu commented on FLINK-29405:
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Description:
Similar to streaming mode, we introuce the following four operators:
BatchFileWriter ->
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiale Tan updated FLINK-29610:
--
Description:
In {{{}SavepointHandlers{}}}, both
leletan closed pull request #21191: [FLINK-29610] [flink-runtime]: Use rest
time out instead of RpcUtils.INF_TIMEOUT Infinite timeout in SavepointHandlers
and CheckpointHandlers
URL: https://github.com/apache/flink/pull/21191
--
This is an automated message from the Apache Git Service.
To
reswqa commented on code in PR #21137:
URL: https://github.com/apache/flink/pull/21137#discussion_r1013656229
##
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterServiceLeadershipRunnerTest.java:
##
@@ -93,48 +87,47 @@ public class
flinkbot commented on PR #21239:
URL: https://github.com/apache/flink/pull/21239#issuecomment-1303022931
## CI report:
* 1eb77f4640aec4ba4e70fe632e88c8055bcfb837 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiale Tan updated FLINK-29610:
--
Summary: Infinite timeout is used in SavepointHandlers and
CheckpointTriggerHandler calls to
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Description:
Similar to streaming mode, we introuce the following four operators:
BatchFileWriter ->
[
https://issues.apache.org/jira/browse/FLINK-29610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628690#comment-17628690
]
Jiale Tan commented on FLINK-29610:
---
[~gaoyunhaii] thanks for the info!
I created a PR
luoyuxia created FLINK-29880:
Summary: Hive sink supports merge files in batch mode
Key: FLINK-29880
URL: https://issues.apache.org/jira/browse/FLINK-29880
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Summary: Introduce operators for files merging in batch mode (was:
Introduce operators for files
[
https://issues.apache.org/jira/browse/FLINK-29879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
luoyuxia updated FLINK-29879:
-
Description: Similar to straming
> Introduce operators for files merging
>
luoyuxia created FLINK-29879:
Summary: Introduce operators for files merging
Key: FLINK-29879
URL: https://issues.apache.org/jira/browse/FLINK-29879
Project: Flink
Issue Type: Sub-task
leletan opened a new pull request, #21239:
URL: https://github.com/apache/flink/pull/21239
## What is the purpose of the change
This pull request makes SavepointHandlers and CheckpointHandlers call to
RestfulGateway using `ASK_TIMEOUT_DURATION`, instead of
201 - 265 of 265 matches
Mail list logo
