[jira] [Commented] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-01-29 Thread Jiabao Sun (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Created] (FLINK-34262) Support to set user specified labels for Rest Service Object

2024-01-29 Thread Prabhu Joseph (Jira)
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

Re: [PR] [FLINK-32743][Connectors/Kafka] Parse data from kafka connect and convert it into regular JSON data [flink-connector-kafka]

2024-01-29 Thread via GitHub
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

[jira] [Commented] (FLINK-34193) Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Assigned] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread Rui Fan (Jira)
[ 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

Re: [PR] [FLINK-34058][table] Support optional parameters for named parameters [flink]

2024-01-29 Thread via GitHub
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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Updated] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
[ 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

[jira] [Created] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-01-29 Thread junzhong qin (Jira)
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:

Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-opensearch]

2024-01-29 Thread via GitHub
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

Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-opensearch]

2024-01-29 Thread via GitHub
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:

Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-gcp-pubsub]

2024-01-29 Thread via GitHub
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

Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-gcp-pubsub]

2024-01-29 Thread via GitHub
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:

Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-cassandra]

2024-01-29 Thread via GitHub
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:

Re: [PR] [FLINK-25509][connector/kafka] Add RecordEvaluator to dynamically stop source based on de-serialized records [flink-connector-kafka]

2024-01-29 Thread via GitHub
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

Re: [PR] [FLINK-34258][docs][table] Fix incorrect retract example for TableAggregateFunction [flink]

2024-01-29 Thread via GitHub
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`

[jira] [Closed] (FLINK-33490) Validate the name conflicts when creating view

2024-01-29 Thread Shengkai Fang (Jira)
[ 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 >

Re: [PR] [hotfix] Update copyright year to 2024 [flink-connector-mongodb]

2024-01-29 Thread via GitHub
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:

[jira] [Resolved] (FLINK-33899) Java 17 and 21 support for mongodb connector

2024-01-29 Thread Leonard Xu (Jira)
[ 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

[jira] [Updated] (FLINK-34258) Incorrect example of accumulator usage within emitUpdateWithRetract for TableAggregateFunction

2024-01-29 Thread ASF GitHub Bot (Jira)
[ 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

[PR] [FLINK-34258][docs][table] Fix incorrect retract example for TableAggregateFunction [flink]

2024-01-29 Thread via GitHub
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

[jira] [Assigned] (FLINK-33899) Java 17 and 21 support for mongodb connector

2024-01-29 Thread Leonard Xu (Jira)
[ 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 >

Re: [PR] [FLINK-33899][connectors/mongodb] Java 17 and 21 support for mongodb connector [flink-connector-mongodb]

2024-01-29 Thread via GitHub
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:

[jira] [Commented] (FLINK-34253) Offsets out of range with no configured reset policy for partitions

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Commented] (FLINK-34258) Incorrect example of accumulator usage within emitUpdateWithRetract for TableAggregateFunction

2024-01-29 Thread Jane Chan (Jira)
[ 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

[jira] [Commented] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Updated] (FLINK-34258) Incorrect example of accumulator usage within emitUpdateWithRetract for TableAggregateFunction

2024-01-29 Thread Jane Chan (Jira)
[ 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

[jira] [Assigned] (FLINK-34113) Update flink-connector-elasticsearch to be compatible with updated SinkV2 interfaces

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Updated] (FLINK-34249) Remove DefaultSlotTracker related logic.

2024-01-29 Thread RocMarshal (Jira)
[ 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

[jira] [Updated] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-01-29 Thread Martijn Visser (Jira)
[ 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:

[jira] [Updated] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Created] (FLINK-34260) Make flink-connector-aws compatible with SinkV2 changes

2024-01-29 Thread Martijn Visser (Jira)
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

[jira] [Updated] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Commented] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-29 Thread Martijn Visser (Jira)
[ 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

[jira] [Created] (FLINK-34259) flink-connector-jdbc fails to compile with NPE on hasGenericTypesDisabled

2024-01-29 Thread Martijn Visser (Jira)
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

[jira] [Commented] (FLINK-33545) KafkaSink implementation can cause dataloss during broker issue when not using EXACTLY_ONCE if there's any batching

2024-01-29 Thread Martijn Visser (Jira)
[ 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

<    1   2   3