[
https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811807#comment-17811807
]
Jiabao Sun commented on FLINK-34260:
Hi [~martijnvisser], can I take this ticket?
> Update
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
Prabhu Joseph created FLINK-34262:
-
Summary: Support to set user specified labels for Rest Service
Object
Key: FLINK-34262
URL: https://issues.apache.org/jira/browse/FLINK-34262
Project: Flink
MartijnVisser commented on PR #42:
URL:
https://github.com/apache/flink-connector-kafka/pull/42#issuecomment-1914342095
@mas-chen Want to take a look?
--
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-34193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811793#comment-17811793
]
Martijn Visser commented on FLINK-34193:
[~jinsuichen] That depends on the proposed changes. We
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-34261:
---
Assignee: junzhong qin
> When slotmanager.redundant-taskmanager-num is set to a value greater than
hackergin commented on code in PR #24183:
URL: https://github.com/apache/flink/pull/24183#discussion_r146949
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/FlinkConvertletTable.java:
##
@@ -69,6 +72,10 @@ public SqlRexConvertlet
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
[
https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
junzhong qin updated FLINK-34261:
-
Description:
Redundant task managers are extra task managers started by Flink, to speed up
job
junzhong qin created FLINK-34261:
Summary: When slotmanager.redundant-taskmanager-num is set to a
value greater than 1, redundant task managers may be repeatedly released and
requested
Key: FLINK-34261
URL:
boring-cyborg[bot] commented on PR #40:
URL:
https://github.com/apache/flink-connector-opensearch/pull/40#issuecomment-1914303769
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please
leonardBang merged PR #40:
URL: https://github.com/apache/flink-connector-opensearch/pull/40
--
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:
boring-cyborg[bot] commented on PR #22:
URL:
https://github.com/apache/flink-connector-gcp-pubsub/pull/22#issuecomment-1914302574
Awesome work, congrats on your first merged pull request!
--
This is an automated message from the Apache Git Service.
To respond to the message, please
leonardBang merged PR #22:
URL: https://github.com/apache/flink-connector-gcp-pubsub/pull/22
--
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:
leonardBang merged PR #25:
URL: https://github.com/apache/flink-connector-cassandra/pull/25
--
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:
ruanhang1993 commented on code in PR #76:
URL:
https://github.com/apache/flink-connector-kafka/pull/76#discussion_r1469304314
##
flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilder.java:
##
@@ -350,6 +352,26 @@ public
flinkbot commented on PR #24215:
URL: https://github.com/apache/flink/pull/24215#issuecomment-1914293011
## CI report:
* 9f266bd28c6613f43740f2d879a2cf8d206989f2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-33490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang closed FLINK-33490.
-
Resolution: Fixed
> Validate the name conflicts when creating view
>
leonardBang merged PR #24:
URL: https://github.com/apache/flink-connector-mongodb/pull/24
--
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-33899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-33899.
Resolution: Implemented
flink-connector-mongodb(main): ed1ea77d14846a0f751ddb8425fcc7dca949bf55
[
https://issues.apache.org/jira/browse/FLINK-34258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-34258:
---
Labels: pull-request-available (was: )
> Incorrect example of accumulator usage within
LadyForest opened a new pull request, #24215:
URL: https://github.com/apache/flink/pull/24215
## What is the purpose of the change
This PR corrects the Retract Example in
[
https://issues.apache.org/jira/browse/FLINK-33899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-33899:
--
Assignee: Jiabao Sun
> Java 17 and 21 support for mongodb connector
>
leonardBang merged PR #21:
URL: https://github.com/apache/flink-connector-mongodb/pull/21
--
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-34253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811774#comment-17811774
]
Martijn Visser commented on FLINK-34253:
[~1028344...@qq.com] Have you configured an offset
[
https://issues.apache.org/jira/browse/FLINK-34258?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811775#comment-17811775
]
Jane Chan commented on FLINK-34258:
---
The generated AggHandler can be found in the attachment.
To
[
https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811771#comment-17811771
]
Martijn Visser commented on FLINK-34252:
[~dchristle] If I look at
[
https://issues.apache.org/jira/browse/FLINK-34258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jane Chan updated FLINK-34258:
--
Attachment: GroupTableAggHandler$10.java
> Incorrect example of accumulator usage within
[
https://issues.apache.org/jira/browse/FLINK-34113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reassigned FLINK-34113:
--
Assignee: Jiabao Sun
> Update flink-connector-elasticsearch to be compatible with
[
https://issues.apache.org/jira/browse/FLINK-34249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
RocMarshal updated FLINK-34249:
---
Description:
pre step: https://issues.apache.org/jira/browse/FLINK-34174
The main reason for
[
https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34260:
---
Summary: Update flink-connector-aws to be compatible with updated SinkV2
interfaces (was:
[
https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34260:
---
Issue Type: Technical Debt (was: Bug)
> Update flink-connector-aws to be compatible with
Martijn Visser created FLINK-34260:
--
Summary: Make flink-connector-aws compatible with SinkV2 changes
Key: FLINK-34260
URL: https://issues.apache.org/jira/browse/FLINK-34260
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser updated FLINK-34259:
---
Fix Version/s: 1.19.0
> flink-connector-jdbc fails to compile with NPE on
[
https://issues.apache.org/jira/browse/FLINK-34259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811765#comment-17811765
]
Martijn Visser commented on FLINK-34259:
[~Zhanghao Chen] Since you worked on FLINK-34122 can
Martijn Visser created FLINK-34259:
--
Summary: flink-connector-jdbc fails to compile with NPE on
hasGenericTypesDisabled
Key: FLINK-34259
URL: https://issues.apache.org/jira/browse/FLINK-34259
[
https://issues.apache.org/jira/browse/FLINK-33545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17811763#comment-17811763
]
Martijn Visser commented on FLINK-33545:
Since the reported exception is related to the Kafka
201 - 243 of 243 matches
Mail list logo