flinkbot commented on PR #21486:
URL: https://github.com/apache/flink/pull/21486#issuecomment-1345602384
## CI report:
* 44a734d94665d8232b364349a7652aea9081433d UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-15635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645804#comment-17645804
]
Prabhu Joseph commented on FLINK-15635:
---
We are seeing below ClassNotFoundException in Sql Client
[
https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645844#comment-17645844
]
Zhenqiu Huang edited comment on FLINK-30363 at 12/11/22 7:34 PM:
-
luoyuxia commented on PR #21316:
URL: https://github.com/apache/flink/pull/21316#issuecomment-1345736846
@wuchong Could you please help merge?
--
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
luoyuxia commented on PR #21316:
URL: https://github.com/apache/flink/pull/21316#issuecomment-1345736892
@wuchong Could you please help merge?
--
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
Dian Fu created FLINK-30364:
---
Summary: Job failed without exception stack
Key: FLINK-30364
URL: https://issues.apache.org/jira/browse/FLINK-30364
Project: Flink
Issue Type: Bug
fsk119 merged PR #21141:
URL: https://github.com/apache/flink/pull/21141
--
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:
[
https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645794#comment-17645794
]
Sergey Nuyanzin edited comment on FLINK-30362 at 12/11/22 4:43 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645794#comment-17645794
]
Sergey Nuyanzin edited comment on FLINK-30362 at 12/11/22 4:43 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645794#comment-17645794
]
Sergey Nuyanzin edited comment on FLINK-30362 at 12/11/22 4:43 PM:
---
[
https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645844#comment-17645844
]
Zhenqiu Huang commented on FLINK-30363:
---
[~gyfora]
Would you please assign this jira to me, if
chenqin opened a new pull request, #21486:
URL: https://github.com/apache/flink/pull/21486
## What is the purpose of the change
This pull reqeust exclude org.pentaho.* from blocked jboss mirror so that
flink-connector-hive can build and pass tests with maven 3.8.1+
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645810#comment-17645810
]
SwathiChandrashekar commented on FLINK-30361:
-
Yes [~gyfora] , I would like to try this
>
Yunhong Zheng created FLINK-30365:
-
Summary: New dynamic partition pruning strategy to support more
dpp patterns
Key: FLINK-30365
URL: https://issues.apache.org/jira/browse/FLINK-30365
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-29742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-29742:
-
Assignee: yuzelin
> Support completing statement in SqlGatewayService.
>
[
https://issues.apache.org/jira/browse/FLINK-29742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-29742.
-
Resolution: Implemented
Merged into master: dc3ea827941f9c0a28b593f6fc628d742a8562a2
> Support
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645786#comment-17645786
]
Gyula Fora commented on FLINK-30361:
[~Swathi Chandrashekar] do you want to give this issue a try?
yuchen-ecnu opened a new pull request, #21485:
URL: https://github.com/apache/flink/pull/21485
… checkpoint tab
## What is the purpose of the change
In the Web UI, we link the pending or failed subtask to the corresponding TM
for the job's checkpoint page, which helps to
[
https://issues.apache.org/jira/browse/FLINK-29997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-29997:
---
Labels: pull-request-available (was: )
> Link to the taskmanager page in the expired
flinkbot commented on PR #21485:
URL: https://github.com/apache/flink/pull/21485#issuecomment-1345588992
## CI report:
* 78f3496a73d9d11e6617eff2b80a1d04f78cab6c UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Chen Qin created FLINK-30362:
Summary: Flink-connector-hive can't build with maven 3.8
Key: FLINK-30362
URL: https://issues.apache.org/jira/browse/FLINK-30362
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30362:
---
Labels: pull-request-available (was: )
> Flink-connector-hive can't build with maven 3.8
>
rkhachatryan commented on PR #21468:
URL: https://github.com/apache/flink/pull/21468#issuecomment-1345602914
Thanks for the PR @masteryhx , I like the proposal.
How about taking it one step further:
1. Use `DataOutputView` instead of `DataOutputViewStreamWrapper` (`master`)
/
[
https://issues.apache.org/jira/browse/FLINK-27640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645799#comment-17645799
]
Chen Qin commented on FLINK-27640:
--
shall we exclude
Zhenqiu Huang created FLINK-30363:
-
Summary: Disable HadoppConf and Kerboros Decorator by default
Key: FLINK-30363
URL: https://issues.apache.org/jira/browse/FLINK-30363
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora reassigned FLINK-30361:
--
Assignee: SwathiChandrashekar
> Cluster deleted and created back while updating replicas
>
ashmeet-kandhari commented on PR #20991:
URL: https://github.com/apache/flink/pull/20991#issuecomment-1345624195
> hi @ashmeet-kandhari thanks for conflicts resolution I left some comments
(i didn't go through the whole changeset) however there are several types of
things which
[
https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645794#comment-17645794
]
Sergey Nuyanzin commented on FLINK-30362:
-
*Looks like a duplicate of
[
https://issues.apache.org/jira/browse/FLINK-30362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645794#comment-17645794
]
Sergey Nuyanzin edited comment on FLINK-30362 at 12/11/22 4:42 PM:
---
yangjunhan merged PR #21469:
URL: https://github.com/apache/flink/pull/21469
--
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:
ruanliang-hualun closed pull request #21470: [FLINK-30346] change the code
comment
URL: https://github.com/apache/flink/pull/21470
--
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
swuferhong opened a new pull request, #21487:
URL: https://github.com/apache/flink/pull/21487
## What is the purpose of the change
This pr is a bug fix pr to fix `FlinkJoinToMultiJoinRule` incorrectly
combines Left/Right outer join to `MultiJoin` error. while
yangjunhan merged PR #21432:
URL: https://github.com/apache/flink/pull/21432
--
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:
Xingbo Huang created FLINK-30366:
Summary: Python Group Agg failed in cleaning the idle state
Key: FLINK-30366
URL: https://issues.apache.org/jira/browse/FLINK-30366
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-30250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junhan Yang resolved FLINK-30250.
-
Resolution: Fixed
> The flame graph type is wrong
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-30250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645897#comment-17645897
]
Junhan Yang commented on FLINK-30250:
-
master: 6af92a3eda4d243f765f6ea0c8c548ca70ca423a
> The flame
Yun Tang created FLINK-30367:
Summary: Enrich the thread dump info with deeper stack
Key: FLINK-30367
URL: https://issues.apache.org/jira/browse/FLINK-30367
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-30367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yun Tang reassigned FLINK-30367:
Assignee: Yu Chen
> Enrich the thread dump info with deeper stack
>
[
https://issues.apache.org/jira/browse/FLINK-30363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645924#comment-17645924
]
Zhenqiu Huang commented on FLINK-30363:
---
Discussed with [~gyfora] offline, the change will wait
[
https://issues.apache.org/jira/browse/FLINK-30270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-30270:
--
Parent: FLINK-27583
Issue Type: Sub-task (was: Bug)
> FlinkJoinToMultiJoinRule
[
https://issues.apache.org/jira/browse/FLINK-30270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30270:
---
Labels: pull-request-available (was: )
> FlinkJoinToMultiJoinRule incorrectly combines
tsreaper commented on code in PR #428:
URL: https://github.com/apache/flink-table-store/pull/428#discussion_r1045401837
##
flink-table-store-core/src/test/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTableTest.java:
##
@@ -615,6 +618,69 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-30217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645920#comment-17645920
]
Hangxiang Yu commented on FLINK-30217:
--
Hi [~xljtswf]. Thanks a lot for reporting this.
I think it
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645907#comment-17645907
]
Samrat Deb edited comment on FLINK-30318 at 12/12/22 6:13 AM:
--
[~lsy] , m
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645955#comment-17645955
]
Yanfei Lei commented on FLINK-24932:
Merged into
[
https://issues.apache.org/jira/browse/FLINK-21223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xingbo Huang closed FLINK-21223.
Fix Version/s: 1.17.0
Resolution: Done
Merged into master via
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junhan Yang resolved FLINK-29925.
-
Resolution: Fixed
> table ui of configure value is strange
>
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645907#comment-17645907
]
Samrat Deb commented on FLINK-30318:
[~lsy] , m on it ! i will share the root cause once i find
[
https://issues.apache.org/jira/browse/FLINK-30368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-30368:
--
Parent: FLINK-27583
Issue Type: Sub-task (was: Improvement)
> Fix calcite method
fsk119 commented on code in PR #21187:
URL: https://github.com/apache/flink/pull/21187#discussion_r1045350575
##
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java:
##
@@ -102,6 +109,8 @@ private SessionContext(
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645876#comment-17645876
]
dalongliu commented on FLINK-30318:
---
[~samrat007] As [~luoyuxia] explain, the jars added by `-j` and
[
https://issues.apache.org/jira/browse/FLINK-30364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-30364:
Attachment: screenshot-1.png
> Job failed without exception stack
> --
>
[
https://issues.apache.org/jira/browse/FLINK-30019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-30019.
---
Fix Version/s: 1.17.0
Assignee: Aitozi
Resolution: Fixed
Fixed in master:
flinkbot commented on PR #21487:
URL: https://github.com/apache/flink/pull/21487#issuecomment-1345795937
## CI report:
* 296461b819412af4af13a8ddce0eb01bf6880254 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
flinkbot commented on PR #21489:
URL: https://github.com/apache/flink/pull/21489#issuecomment-1345850269
## CI report:
* d15eab23be3a3ce3461150c9a9b77121e4cd05e9 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Yunhong Zheng created FLINK-30368:
-
Summary: Fix calcite method RelMdUtil$numDistinctVals() wrongly
return zero if the method input domainSize much larger than numSelected
Key: FLINK-30368
URL:
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645907#comment-17645907
]
Samrat Deb edited comment on FLINK-30318 at 12/12/22 4:44 AM:
--
[~lsy] , m
JingsongLi commented on code in PR #428:
URL: https://github.com/apache/flink-table-store/pull/428#discussion_r1045472745
##
flink-table-store-core/src/test/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTableTest.java:
##
@@ -615,6 +618,69 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-30365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645877#comment-17645877
]
dalongliu commented on FLINK-30365:
---
Please convert it as the subtask of
flinkbot commented on PR #21488:
URL: https://github.com/apache/flink/pull/21488#issuecomment-1345833926
## CI report:
* 36e272ca6772c5d503394baa239688b165165d84 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
swuferhong opened a new pull request, #21489:
URL: https://github.com/apache/flink/pull/21489
## What is the purpose of the change
This pr is aims to introduce a new dynamic partition pruning strategy named
`FlinkDynamicPartitionPruningConverterProgram` to instead of the old
[
https://issues.apache.org/jira/browse/FLINK-30365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30365:
---
Labels: pull-request-available (was: )
> New dynamic partition pruning strategy to support
[
https://issues.apache.org/jira/browse/FLINK-30318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645907#comment-17645907
]
Samrat Deb edited comment on FLINK-30318 at 12/12/22 4:58 AM:
--
[~lsy] , m
[
https://issues.apache.org/jira/browse/FLINK-30219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645913#comment-17645913
]
Wencong Liu commented on FLINK-30219:
-
Hi, [~Aiden Gong] , could you please illustrate this error in
[
https://issues.apache.org/jira/browse/FLINK-30365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yunhong Zheng updated FLINK-30365:
--
Parent: FLINK-27583
Issue Type: Sub-task (was: Improvement)
> New dynamic partition
swuferhong opened a new pull request, #21490:
URL: https://github.com/apache/flink/pull/21490
## What is the purpose of the change
This pr is aims to fix calcite method `RelMdUtil$numDistinctVals()` wrongly
return zero if the method input `domainSize` is a very large value. If
[
https://issues.apache.org/jira/browse/FLINK-30368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30368:
---
Labels: pull-request-available (was: )
> Fix calcite method RelMdUtil$numDistinctVals()
Yunhong Zheng created FLINK-30369:
-
Summary: Fix FlinkFilterJoinRule push wrong filters to another
side while join type is left/right outer join
Key: FLINK-30369
URL:
1996fanrui commented on PR #21432:
URL: https://github.com/apache/flink/pull/21432#issuecomment-1346016361
@yangjunhan thanks a lot for your review.
--
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
tsreaper commented on code in PR #428:
URL: https://github.com/apache/flink-table-store/pull/428#discussion_r1045481303
##
flink-table-store-core/src/test/java/org/apache/flink/table/store/table/ChangelogWithKeyFileStoreTableTest.java:
##
@@ -615,6 +618,79 @@ public void
wuchong merged PR #21316:
URL: https://github.com/apache/flink/pull/21316
--
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 closed pull request #21332: [FLINK-21223][python] Support to
specify the output types of Python UDFs via string
URL: https://github.com/apache/flink/pull/21332
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
tsreaper commented on code in PR #428:
URL: https://github.com/apache/flink-table-store/pull/428#discussion_r1044238642
##
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/SimpleRuntimeSource.java:
##
@@ -27,12 +27,14 @@
import
masteryhx commented on PR #21468:
URL: https://github.com/apache/flink/pull/21468#issuecomment-1345886670
>
Thanks a lot for your suggestion.
I think it could make interface more generic.
BTW, Changelog is [production-ready in release
flinkbot commented on PR #21490:
URL: https://github.com/apache/flink/pull/21490#issuecomment-1345983940
## CI report:
* 17f483c1719504d134acab11527b27dbc84f7dc1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-29925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645896#comment-17645896
]
Junhan Yang commented on FLINK-29925:
-
master: 4e1e1a81ededd86199fcb43c933a198fcbdbe55b
> table ui
[
https://issues.apache.org/jira/browse/FLINK-30366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30366:
---
Labels: pull-request-available (was: )
> Python Group Agg failed in cleaning the idle
HuangXingBo opened a new pull request, #21488:
URL: https://github.com/apache/flink/pull/21488
## What is the purpose of the change
*This pull request will fix Python Group Agg failed in cleaning the idle
state*
## Brief change log
- *Adds the type cast*
##
[
https://issues.apache.org/jira/browse/FLINK-30253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645946#comment-17645946
]
Hangxiang Yu commented on FLINK-30253:
--
IIUC, Standalone checkpoint store will also use io executor
[
https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645955#comment-17645955
]
Yanfei Lei edited comment on FLINK-24932 at 12/12/22 7:40 AM:
--
Merged into
jiangxin369 commented on code in PR #187:
URL: https://github.com/apache/flink-ml/pull/187#discussion_r1045197314
##
flink-ml-lib/src/main/java/org/apache/flink/ml/feature/univariatefeatureselector/UnivariateFeatureSelectorModel.java:
##
@@ -0,0 +1,201 @@
+/*
+ * Licensed to
Aitozi commented on code in PR #20855:
URL: https://github.com/apache/flink/pull/20855#discussion_r1045211502
##
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserUtils.java:
##
@@ -1689,4 +1694,61 @@ public static
Jichao Wang created FLINK-30360:
---
Summary: A null pointer exception is thrown when data is written
to the HBase table using the specified column name
Key: FLINK-30360
URL:
[
https://issues.apache.org/jira/browse/FLINK-30360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jichao Wang updated FLINK-30360:
Description:
A null pointer exception is thrown when data is written to the HBase table
using
[
https://issues.apache.org/jira/browse/FLINK-30360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jichao Wang updated FLINK-30360:
Attachment: (was: image-2022-12-11-19-55-34-932.png)
> A null pointer exception is thrown
flinkbot commented on PR #21484:
URL: https://github.com/apache/flink/pull/21484#issuecomment-1345540195
## CI report:
* 78d780c417eaf72857a98b3a7dd3d63296153ce1 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-30360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-30360:
---
Labels: pull-request-available (was: )
> A null pointer exception is thrown when data is
SwathiChandrashekar created FLINK-30361:
---
Summary: Flink cluster deleted while updating the replicas
Key: FLINK-30361
URL: https://issues.apache.org/jira/browse/FLINK-30361
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-30361:
Description:
Whenever we try to update the replicas of the task manager for a
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-30361:
Description:
Whenever we try to update the replicas of the task manager for a
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645766#comment-17645766
]
SwathiChandrashekar commented on FLINK-30361:
-
This is the case, as in
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-30361:
Description:
Whenever we try to update the replicas of the task manager for a
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645766#comment-17645766
]
SwathiChandrashekar edited comment on FLINK-30361 at 12/11/22 12:36 PM:
MartijnVisser commented on PR #4:
URL:
https://github.com/apache/flink-connector-pulsar/pull/4#issuecomment-1345543897
@syhily Could you review this?
--
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
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645766#comment-17645766
]
SwathiChandrashekar edited comment on FLINK-30361 at 12/11/22 12:38 PM:
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17645770#comment-17645770
]
Gyula Fora commented on FLINK-30361:
We have similar logic in place for standalone applications with
MartijnVisser commented on PR #5:
URL:
https://github.com/apache/flink-connector-pulsar/pull/5#issuecomment-1345543930
@syhily Could you review this?
--
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
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-30361:
Summary: Flink cluster deleted and created back while updating replicas
(was:
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-30361:
Summary: Flink cluster deleted and created back while updating the replicas
[
https://issues.apache.org/jira/browse/FLINK-30361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
SwathiChandrashekar updated FLINK-30361:
Summary: Cluster deleted and created back while updating replicas (was:
Flink
1 - 100 of 102 matches
Mail list logo
