[
https://issues.apache.org/jira/browse/FLINK-29557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624867#comment-17624867
]
Yun Gao commented on FLINK-29557:
-
Hi [~aitozi] LGTM, very thanks for tracking the issue. Would you like
testjudyzhu opened a new pull request, #416:
URL: https://github.com/apache/flink-kubernetes-operator/pull/416
## What is the purpose of the change
*(For example: This pull request adds a new feature to periodically create
and maintain savepoints through the `FlinkDeployment`
gaoyunhaii commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1293023382
Thanks @ericxiao251 for the PR! I'll have a look at the PR today.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-29157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624825#comment-17624825
]
Congxian Qiu edited comment on FLINK-29157 at 10/27/22 5:22 AM:
merged
[
https://issues.apache.org/jira/browse/FLINK-29157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu updated FLINK-29157:
-
Fix Version/s: (was: 1.15.3)
> Clarify the contract between CompletedCheckpointStore and
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624861#comment-17624861
]
Yang Wang commented on FLINK-29315:
---
I will have a look on the CI machine Alibaba001 today.
>
flinkbot commented on PR #21169:
URL: https://github.com/apache/flink/pull/21169#issuecomment-1293001756
## CI report:
* 877470a67dacef1b3bfdb1ba1308fffeeca3c739 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29770:
---
Labels: pull-request-available (was: )
> hbase connector supports out-of-order data
>
cuibo01 opened a new pull request, #21169:
URL: https://github.com/apache/flink/pull/21169
## What is the purpose of the change
*(For example: This pull request makes task deployment go through the blob
server, rather than through RPC. That way we avoid re-transferring them
[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624852#comment-17624852
]
Yun Tang commented on FLINK-29427:
--
Another instance:
Myasuka commented on PR #20917:
URL: https://github.com/apache/flink/pull/20917#issuecomment-1292986632
The CI failed due to FLINK-29427
@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
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1292957867
@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.
gyfora opened a new pull request, #415:
URL: https://github.com/apache/flink-kubernetes-operator/pull/415
## What is the purpose of the change
Minor change based on mailng list discussion to align default confs with
Flink for subtask number and parallelism.
--
This is an automated
gyfora commented on PR #415:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/415#issuecomment-1292952390
cc @bgeng777
--
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-29611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624850#comment-17624850
]
Sopan Phaltankar commented on FLINK-29611:
--
[~martijnvisser] Here is my PR:
gyfora commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1292948210
Great work @darenwkt !
--
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
godfreyhe commented on PR #574:
URL: https://github.com/apache/flink-web/pull/574#issuecomment-1292943915
> Thanks a lot for putting together this big announcement, I mostly made
some wording suggestions
Thanks for the detailed comments, I have fixed them.
--
This is an automated
yuzelin closed pull request #21040: [FLINK-29486][sql-client] Implement a new
ClientResult for sql client to wrap the result returned by sql gateway
URL: https://github.com/apache/flink/pull/21040
--
This is an automated message from the Apache Git Service.
To respond to the message, please
LadyForest commented on code in PR #20652:
URL: https://github.com/apache/flink/pull/20652#discussion_r1006384680
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterTableSchemaUtil.java:
##
@@ -0,0 +1,516 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-29760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29760.
Resolution: Fixed
master: a58513e40eb0ffb50fb6eee357c4449a9d8483cd
> Introduce snapshots
JingsongLi merged PR #333:
URL: https://github.com/apache/flink-table-store/pull/333
--
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:
JingsongLi commented on PR #336:
URL:
https://github.com/apache/flink-table-store/pull/336#issuecomment-1292939114
How many times have you run without fail?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/FLINK-29075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-29075.
Fix Version/s: table-store-0.3.0
Resolution: Fixed
master:
JingsongLi merged PR #335:
URL: https://github.com/apache/flink-table-store/pull/335
--
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:
mbalassi commented on PR #414:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/414#issuecomment-1292928578
Thanks @darenwkt, makes sense. Could you please extract the sleep times to a
single `ROLLBACK_DELAY` or similarly named constant please?
--
This is an automated
[
https://issues.apache.org/jira/browse/FLINK-29773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29773:
---
Labels: pull-request-available (was: )
> PreAggregationITCase.LastValueAggregation and
>
tsreaper opened a new pull request, #336:
URL: https://github.com/apache/flink-table-store/pull/336
`PreAggregationITCase.LastValueAggregation` and
`PreAggregationITCase.LastNonNullValueAggregation` need to make sure that the
order of input data is determined. However the default
Jingsong Lee created FLINK-29774:
Summary: Introduce options metadata table
Key: FLINK-29774
URL: https://issues.apache.org/jira/browse/FLINK-29774
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-29773:
---
Summary: PreAggregationITCase.LastValueAggregation and
PreAggregationITCase.LastNonNullValueAggregation are unstable
Key: FLINK-29773
URL:
[
https://issues.apache.org/jira/browse/FLINK-29773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29773:
---
Assignee: Caizhi Weng
> PreAggregationITCase.LastValueAggregation and
>
[
https://issues.apache.org/jira/browse/FLINK-29075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29075:
---
Labels: pull-request-available (was: )
>
tsreaper opened a new pull request, #335:
URL: https://github.com/apache/flink-table-store/pull/335
`RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite` fails due
to some expected records in table `T4` does not appear in table `T3`. This is
because `stopJobSafely` method does
[
https://issues.apache.org/jira/browse/FLINK-29766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29766:
Assignee: Weijie Guo
> Speculative execution should also work in hybrid shuffle mode
>
[
https://issues.apache.org/jira/browse/FLINK-29767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xintong Song reassigned FLINK-29767:
Assignee: Weijie Guo
> Adaptive batch scheduler supports hybrid shuffle
>
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624836#comment-17624836
]
shizhengchao commented on FLINK-29772:
--
my case is kafka interval join，deadlock occurs when using
[ https://issues.apache.org/jira/browse/FLINK-29772 ]
shizhengchao deleted comment on FLINK-29772:
--
was (Author: tinny):
kafka interval join, deadlock occurs when using rocksdb
> Kafka table source scan blocked
>
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624834#comment-17624834
]
shizhengchao commented on FLINK-29772:
--
kafka interval join, deadlock occurs when using rocksdb
>
[
https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624832#comment-17624832
]
Weijie Guo commented on FLINK-24119:
flinkbot commented on PR #21168:
URL: https://github.com/apache/flink/pull/21168#issuecomment-1292895192
## CI report:
* 60f5c5556492722b05d6271731dff5f6430d22e6 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624830#comment-17624830
]
Weijie Guo commented on FLINK-29315:
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-29772:
-
Description:
{code:java}
//
"Source: TableSourceScan(table=[[ostream, user_mart,
[
https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang reassigned FLINK-27579:
-
Assignee: Yao Zhang
> The param client.timeout can not be set by dynamic properties when
liuyongvs opened a new pull request, #21168:
URL: https://github.com/apache/flink/pull/21168
## What is the purpose of the change
*backport FLINK-27579 to 1.15*
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the blob store on job creation time
[
https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624827#comment-17624827
]
Yang Wang commented on FLINK-27579:
---
When working for FLINK-29749, I realize that this ticket also
[
https://issues.apache.org/jira/browse/FLINK-29772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
shizhengchao updated FLINK-29772:
-
Description:
{code:java}
//
"Source: TableSourceScan(table=[[ostream, user_mart,
fredia commented on PR #21053:
URL: https://github.com/apache/flink/pull/21053#issuecomment-1292888602
Thanks a lot for reviewing.
--
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
HuangXingBo closed pull request #139: [hotfix] Remove 1.14
URL: https://github.com/apache/flink-docker/pull/139
--
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,
[
https://issues.apache.org/jira/browse/FLINK-29157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu resolved FLINK-29157.
--
Resolution: Fixed
merged into master 63767c5ed91642c67f97d9f16ff2b8955f9ae421
> Clarify the
[
https://issues.apache.org/jira/browse/FLINK-29157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Congxian Qiu reassigned FLINK-29157:
Assignee: Yanfei Lei (was: Roman Khachatryan)
> Clarify the contract between
[
https://issues.apache.org/jira/browse/FLINK-29075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caizhi Weng reassigned FLINK-29075:
---
Assignee: Caizhi Weng
> RescaleBucketITCase#testSuspendAndRecoverAfterRescaleOverwrite is
wangyang0918 merged PR #21164:
URL: https://github.com/apache/flink/pull/21164
--
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:
HuangXingBo commented on code in PR #574:
URL: https://github.com/apache/flink-web/pull/574#discussion_r1006341102
##
_config.yml:
##
@@ -73,6 +73,22 @@ FLINK_TABLE_STORE_GITHUB_REPO_NAME: flink-table-store
# md1_url:
[
https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624818#comment-17624818
]
Zhu Zhu edited comment on FLINK-29660 at 10/27/22 2:14 AM:
---
In the exception
[
https://issues.apache.org/jira/browse/FLINK-29660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624818#comment-17624818
]
Zhu Zhu commented on FLINK-29660:
-
In the exception history, it already shows all the root exceptions
shizhengchao created FLINK-29772:
Summary: Kafka table source scan blocked
Key: FLINK-29772
URL: https://issues.apache.org/jira/browse/FLINK-29772
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-29747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junhan Yang closed FLINK-29747.
---
Resolution: Fixed
> [UI] Refactor runtime web from module-based to standalone components
>
[
https://issues.apache.org/jira/browse/FLINK-29747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624817#comment-17624817
]
Junhan Yang commented on FLINK-29747:
-
master: 77204ff7b92da132c1033a356344d8ccd6b443f2
> [UI]
[
https://issues.apache.org/jira/browse/FLINK-29541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624816#comment-17624816
]
Lijie Wang commented on FLINK-29541:
No, I'm not working on this, because I'm not familiar with
yangjunhan merged PR #21144:
URL: https://github.com/apache/flink/pull/21144
--
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:
wangyang0918 commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1292866740
@SwimSweet Yes. The user jar for Yarn application mode could only be a HDFS
file. However, I believe it is enough since using Yarn distributed cache is
more appropriate than
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624813#comment-17624813
]
Xintong Song commented on FLINK-29572:
--
bq. If this works, TM will report its address as
saLeox commented on PR #21149:
URL: https://github.com/apache/flink/pull/21149#issuecomment-1292864583
@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-29629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624812#comment-17624812
]
Zhu Zhu commented on FLINK-29629:
-
Unfortunately we do not have enough resources to make this
jiangxin369 commented on code in PR #162:
URL: https://github.com/apache/flink-ml/pull/162#discussion_r1004217316
##
flink-ml-core/src/main/java/org/apache/flink/ml/util/QuantileSummary.java:
##
@@ -0,0 +1,359 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
[
https://issues.apache.org/jira/browse/FLINK-29764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
waywtdcc closed FLINK-29764.
Resolution: Not A Problem
> Automatic judgment of parallelism of source
>
[
https://issues.apache.org/jira/browse/FLINK-29764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624796#comment-17624796
]
waywtdcc commented on FLINK-29764:
--
Oh, sorry, I misunderstood.
> Automatic judgment of parallelism
[
https://issues.apache.org/jira/browse/FLINK-29572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624793#comment-17624793
]
Kevin Li commented on FLINK-29572:
--
The sidecar proxy allows application binding to 127.0.0.1 to
[
https://issues.apache.org/jira/browse/FLINK-29771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29771:
---
Labels: pull-request-available (was: )
> Fix flaky RollbackTest
> --
>
darenwkt opened a new pull request, #414:
URL: https://github.com/apache/flink-kubernetes-operator/pull/414
## What is the purpose of the change
This PR is to fix a flaky Unit Test in Rollback Test that has been failing
Github Actions in the past.
## Brief change
snuyanzin commented on PR #18927:
URL: https://github.com/apache/flink/pull/18927#issuecomment-1292626975
@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
darenwkt commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1292538966
> > Hi @darenwkt ideally we should be able to control the stack-trace per CR:
> > ```
> > flinkConfiguration:
> > taskmanager.numberOfTaskSlots: "2"
> >
darenwkt commented on PR #409:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/409#issuecomment-1292536844
> > Hi @morhidi,
> > I have updated the stackTrace to be a string and added a ConfigOption to
limit the length of the stackTrace string.
> > Regarding
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624703#comment-17624703
]
Gyula Fora commented on FLINK-29609:
This feature is only enabled for Application clusters. The
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154
]
Eric Xiao edited comment on FLINK-20578 at 10/26/22 7:24 PM:
-
Hi I wanted to
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154
]
Eric Xiao edited comment on FLINK-20578 at 10/26/22 7:20 PM:
-
Hi I wanted to
[
https://issues.apache.org/jira/browse/FLINK-29771?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-29771:
--
Assignee: Daren Wong (was: Gyula Fora)
> Fix flaky RollbackTest
> --
>
gyfora closed pull request #413: [hotfix] Temporarily disable RollbackTest
URL: https://github.com/apache/flink-kubernetes-operator/pull/413
--
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
gyfora commented on PR #413:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/413#issuecomment-1292509377
Daren Wong found the probable cause, he will fix this properly
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154
]
Eric Xiao edited comment on FLINK-20578 at 10/26/22 6:43 PM:
-
Hi I wanted to
[
https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624685#comment-17624685
]
Konstantin Knauf commented on FLINK-16073:
--
[~fuping.wang] Done
> Translate "State & Fault
[
https://issues.apache.org/jira/browse/FLINK-16073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf reassigned FLINK-16073:
Assignee: fuping.wang
> Translate "State & Fault Tolerance" pages into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154
]
Eric Xiao edited comment on FLINK-20578 at 10/26/22 6:29 PM:
-
Hi I wanted to
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624154#comment-17624154
]
Eric Xiao edited comment on FLINK-20578 at 10/26/22 6:27 PM:
-
Hi I wanted to
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624665#comment-17624665
]
Sriram Ganesh commented on FLINK-29609:
---
Sure [~Miuler] . I have started exploring the issue. Just
Samrat002 commented on PR #21154:
URL: https://github.com/apache/flink/pull/21154#issuecomment-1292400696
this is really cool
--
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=17624645#comment-17624645
]
Mason Chen commented on FLINK-24119:
[~martijnvisser] Sure, let me take a look later in the week
>
reswqa commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1292379575
> Thanks @reswqa for this PR. I'm wondering how executing the leadership
granting/revocation call from within another thread would help fixing the
issue. The locks might be still acquired
[
https://issues.apache.org/jira/browse/FLINK-29711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624591#comment-17624591
]
Mason Chen commented on FLINK-29711:
Can you provide exact details where you added logs? I can
SwimSweet commented on PR #20779:
URL: https://github.com/apache/flink/pull/20779#issuecomment-1292306760
@wangyang0918 I will work for it to support Yarn applicaiton mode and
standalone mode.
I found that Yarn application mode already has similar features. This
feature provides
[
https://issues.apache.org/jira/browse/FLINK-29609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624585#comment-17624585
]
Hector Miuler Malpica Gallegos commented on FLINK-29609:
Please, take into
[
https://issues.apache.org/jira/browse/FLINK-29762?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624581#comment-17624581
]
yuvipanda commented on FLINK-29762:
---
Ah interesting! I'm using the portable runner with Beam to run
[
https://issues.apache.org/jira/browse/FLINK-29364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624567#comment-17624567
]
Lijie Wang commented on FLINK-29364:
-> But the execution falls through to
[
https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624549#comment-17624549
]
Saad Ur Rahman commented on FLINK-20578:
Hi [~eric.xiao], it's all yours - have fun ;). I was
LadyForest commented on code in PR #20652:
URL: https://github.com/apache/flink/pull/20652#discussion_r1005830753
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/AlterTableSchemaUtil.java:
##
@@ -0,0 +1,516 @@
+/*
+ * Licensed to the
Gyula Fora created FLINK-29771:
--
Summary: Fix flaky RollbackTest
Key: FLINK-29771
URL: https://issues.apache.org/jira/browse/FLINK-29771
Project: Flink
Issue Type: Bug
Components:
XComp commented on PR #21137:
URL: https://github.com/apache/flink/pull/21137#issuecomment-1292206053
Thanks @reswqa for this PR. I'm wondering how executing the leadership
granting/revocation being called from within another thread would help fixing
the issue. The locks might be still
[
https://issues.apache.org/jira/browse/FLINK-29759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17624525#comment-17624525
]
Alexandre Decuq commented on FLINK-29759:
-
[~martijnvisser] noted we will try with 1.15 and let
ericxiao251 commented on PR #21077:
URL: https://github.com/apache/flink/pull/21077#issuecomment-1292163461
@lincoln-lil and @gaoyunhaii would you folks be able to review this PR?
Hopefully this PR is short and sweet :).
There are some doc changes related to the java examples that
klion26 commented on code in PR #21136:
URL: https://github.com/apache/flink/pull/21136#discussion_r1005746682
##
flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java:
##
@@ -79,12 +79,12 @@ public SharedStateRegistryImpl(Executor
LadyForest commented on code in PR #333:
URL: https://github.com/apache/flink-table-store/pull/333#discussion_r1005760161
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FlinkTableSource.java:
##
@@ -0,0 +1,95 @@
+/*
+ * Licensed to
1 - 100 of 263 matches
Mail list logo
