[jira] [Comment Edited] (FLINK-25443) Embedded statefulfunction jakson /java8 date time issue

[ https://issues.apache.org/jira/browse/FLINK-25443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486243#comment-17486243 ] Ashok edited comment on FLINK-25443 at 2/3/22, 6:31 AM: Hi  Thanks for the

[jira] [Commented] (FLINK-25443) Embedded statefulfunction jakson /java8 date time issue

[ https://issues.apache.org/jira/browse/FLINK-25443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486243#comment-17486243 ] Ashok commented on FLINK-25443: --- Hi  Thanks for the response .Could you pls fix the github link issue on 

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 40b7b444a0d0492677db15f5a841340e810ce0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 40b7b444a0d0492677db15f5a841340e810ce0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * fa688437fdd22ff09b47336bef640fe6e3440031 Azure:

[jira] [Commented] (FLINK-25893) ResourceManagerServiceImpl's lifecycle can lead to exceptions

[ https://issues.apache.org/jira/browse/FLINK-25893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486189#comment-17486189 ] Xintong Song commented on FLINK-25893: -- Hi [~trohrmann], For problem 2, I think it is indeed a

[GitHub] [flink] syhily removed a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily removed a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1028443462 @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

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 40b7b444a0d0492677db15f5a841340e810ce0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 3fc754fb2f261ffd05f331a982f893dbf9b1828d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 40b7b444a0d0492677db15f5a841340e810ce0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 40b7b444a0d0492677db15f5a841340e810ce0ff Azure:

[GitHub] [flink] syhily commented on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily commented on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1028443462 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

flinkbot edited a comment on pull request #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1023343281 ## CI report: * 9c7419bc5c568b597078f497da41d1039c994bf3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

flinkbot edited a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-940136217 ## CI report: * 40b7b444a0d0492677db15f5a841340e810ce0ff Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] XComp commented on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1028407230 There's another test failure `ZooKeeperDefaultDispatcherRunnerTest.testResourceCleanupUnderLeadershipChange` that is caused by the sequential call of local and global cleanup in

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 16c8c1a02e427053103449b6a5a2f89439e69923 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[jira] [Comment Edited] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486119#comment-17486119 ] Igal Shilman edited comment on FLINK-25866 at 2/2/22, 9:38 PM: --- Great

[jira] [Commented] (FLINK-25866) Support additional TLS configuration.

[ https://issues.apache.org/jira/browse/FLINK-25866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486119#comment-17486119 ] Igal Shilman commented on FLINK-25866: -- Great [~Fil Karnicki], I hope you'll get the necessary

[GitHub] [flink] flinkbot edited a comment on pull request #18613: [FLINK-25574][connectors/async] Migrate AsyncSink connectors to decomposed SinkV2

flinkbot edited a comment on pull request #18613: URL: https://github.com/apache/flink/pull/18613#issuecomment-1028270481 ## CI report: * 6a76477f3cf45c95917850e63fec52928b7a7b79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 8f4369d6f778a1600b10798cf4a8895506285991 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink] XComp commented on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1028369031 I had to add some fix to the last Dispatcher fix commit. The failure on submission wasn't handled properly first. This is fixed now. -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * cc85b9a05417c8c69d6ae57ae012aad22f1ece24 Azure:

[GitHub] [flink-statefun-playground] igalshilman commented on a change in pull request #17: Fix the Kubernetes example

igalshilman commented on a change in pull request #17: URL: https://github.com/apache/flink-statefun-playground/pull/17#discussion_r798008958 ## File path: deployments/k8s/04-statefun/00-module.yaml ## @@ -5,11 +5,12 @@ metadata: name: module-config data: module.yaml:

[jira] [Updated] (FLINK-25936) MutableTypeCell is not setting correctly the value's type_name

[ https://issues.apache.org/jira/browse/FLINK-25936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25936: --- Labels: pull-request-available (was: ) > MutableTypeCell is not setting correctly the

[GitHub] [flink-statefun] igalshilman opened a new pull request #297: [FLINK-25936][java-sdk] Set value type name correctly in a MutableTypeCell.

igalshilman opened a new pull request #297: URL: https://github.com/apache/flink-statefun/pull/297 This PR fixes a bug in the remote java SDK that affects types without an `IMMUTABLE_VALUE` type characteristics. (this Is only affect custom implementations of the `Type` interface)

[jira] [Updated] (FLINK-25936) MutableTypeCell is not setting correctly the value's type_name

[ https://issues.apache.org/jira/browse/FLINK-25936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-25936: - Component/s: Stateful Functions > MutableTypeCell is not setting correctly the value's

[jira] [Created] (FLINK-25936) MutableTypeCell is not setting correctly the value's type_name

Igal Shilman created FLINK-25936: Summary: MutableTypeCell is not setting correctly the value's type_name Key: FLINK-25936 URL: https://issues.apache.org/jira/browse/FLINK-25936 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #18476: [FLINK-25726][streaming] Add Global Committer as post commit topology

flinkbot edited a comment on pull request #18476: URL: https://github.com/apache/flink/pull/18476#issuecomment-1020132926 ## CI report: * 29edb42b88b261b13456e7d2c486d9ed395fc80a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * e33ad31f47e113b480de1c4f6ac6efc40992084b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 96d5cf58549ae5b0611a741c5801afc7fbd80038 Azure:

[jira] [Updated] (FLINK-25934) Modernize statefun playground examples

[ https://issues.apache.org/jira/browse/FLINK-25934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Igal Shilman updated FLINK-25934: - Description: It is about time to touch up abit the examples in playground. Most of the

[jira] [Created] (FLINK-25935) Add a harness based entry point to simply getting started.

Igal Shilman created FLINK-25935: Summary: Add a harness based entry point to simply getting started. Key: FLINK-25935 URL: https://issues.apache.org/jira/browse/FLINK-25935 Project: Flink

[GitHub] [flink] fapaul commented on a change in pull request #18545: [FLINK-25927][connectors] Make flink-connector-base dependency usage consistent across all connectors

fapaul commented on a change in pull request #18545: URL: https://github.com/apache/flink/pull/18545#discussion_r797966208 ## File path: flink-end-to-end-tests/test-scripts/test_quickstarts.sh ## @@ -41,7 +41,7 @@ mkdir -p "${TEST_DATA_DIR}" cd "${TEST_DATA_DIR}"

[jira] [Created] (FLINK-25934) Modernize statefun playground examples

Igal Shilman created FLINK-25934: Summary: Modernize statefun playground examples Key: FLINK-25934 URL: https://issues.apache.org/jira/browse/FLINK-25934 Project: Flink Issue Type:

[jira] [Updated] (FLINK-25573) Update Kafka Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25573: --- Labels: pull-request-available (was: ) > Update Kafka Sink to use decomposed interfaces >

[GitHub] [flink] flinkbot edited a comment on pull request #18612: [FLINK-25573][kafka] Migrate KafkaSink to SinkV2

flinkbot edited a comment on pull request #18612: URL: https://github.com/apache/flink/pull/18612#issuecomment-1028184927 ## CI report: * 54d2712f829412110a7b71254710a7d1a8ea38b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18572: [FLINK-25895][table-planner] Splitted ExecNodeGraphJsonPlanGenerator

flinkbot edited a comment on pull request #18572: URL: https://github.com/apache/flink/pull/18572#issuecomment-1025854469 ## CI report: * 1eafd7f11fcb745bbbd4a783f5e7d7d437cb7850 Azure:

[jira] [Created] (FLINK-25933) Allow configuring different transports in RequestReplyFunctionBuilder

Igal Shilman created FLINK-25933: Summary: Allow configuring different transports in RequestReplyFunctionBuilder Key: FLINK-25933 URL: https://issues.apache.org/jira/browse/FLINK-25933 Project: Flink

[jira] [Commented] (FLINK-21752) NullPointerException on restore in PojoSerializer

[ https://issues.apache.org/jira/browse/FLINK-21752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17486052#comment-17486052 ] Alexis Sarda-Espinosa commented on FLINK-21752: --- Original thread in the new archive:

[GitHub] [flink] flinkbot edited a comment on pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * 4fbff6590304f5f5eb4c138b58617b5fe3e194f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * f3b62f8869e599ac553e889b64ef33ea617c6f5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18611: [FLINK-24385][table] Introduce TRY_CAST

flinkbot edited a comment on pull request #18611: URL: https://github.com/apache/flink/pull/18611#issuecomment-1028155639 ## CI report: * 86d76141ac6a27bd1603ef651f91f0f7d283b97e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * f3b62f8869e599ac553e889b64ef33ea617c6f5d Azure:

[GitHub] [flink] flinkbot commented on pull request #18613: [FLINK-25574][connectors/async] Migrate AsyncSink connectors to decomposed SinkV2

flinkbot commented on pull request #18613: URL: https://github.com/apache/flink/pull/18613#issuecomment-1028274692 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot edited a comment on pull request #18613: [FLINK-25574][connectors/async] Migrate AsyncSink connectors to decomposed SinkV2

flinkbot edited a comment on pull request #18613: URL: https://github.com/apache/flink/pull/18613#issuecomment-1028270481 ## CI report: * 6a76477f3cf45c95917850e63fec52928b7a7b79 Azure:

[GitHub] [flink] flinkbot commented on pull request #18613: [FLINK-25574][connectors/async] Migrate AsyncSink connectors to decomposed SinkV2

flinkbot commented on pull request #18613: URL: https://github.com/apache/flink/pull/18613#issuecomment-1028270481 ## CI report: * 6a76477f3cf45c95917850e63fec52928b7a7b79 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25574) Update Async Sink to use decomposed interfaces

[ https://issues.apache.org/jira/browse/FLINK-25574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25574: --- Labels: pull-request-available (was: ) > Update Async Sink to use decomposed interfaces >

[GitHub] [flink] fapaul opened a new pull request #18613: [FLINK-25574][connectors/async] Migrate AsyncSink connectors to decomposed SinkV2

fapaul opened a new pull request #18613: URL: https://github.com/apache/flink/pull/18613 ## What is the purpose of the change This PR migrates the connectors based on the AsyncSink to the new decompose Sink interfaces. Only 6a76477f3cf45c95917850e63fec52928b7a7b79 is

[jira] [Closed] (FLINK-25899) Add Java connected components example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-25899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-25899. - Resolution: Fixed Fixed via statefun-3.1.2: 9c666fdc934580786cecf58adaa27b496907ca47

[GitHub] [flink] flinkbot edited a comment on pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * f3b62f8869e599ac553e889b64ef33ea617c6f5d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18476: [FLINK-25726][streaming] Add Global Committer as post commit topology

flinkbot edited a comment on pull request #18476: URL: https://github.com/apache/flink/pull/18476#issuecomment-1020132926 ## CI report: * 1709b283ef99b7ddb1ea3d76a585a4996b17423b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18608: [FLINK-25925][tests] Require slot pool to only accept the same set of slots as before

flinkbot edited a comment on pull request #18608: URL: https://github.com/apache/flink/pull/18608#issuecomment-1027977054 ## CI report: * bfde4f08a09e7fda17967b1ed139e40926e604a5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink-statefun-playground] tillrohrmann merged pull request #19: [FLINK-25899] Add connected components example

tillrohrmann merged pull request #19: URL: https://github.com/apache/flink-statefun-playground/pull/19 -- 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,

[jira] [Updated] (FLINK-25899) Add Java connected components example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-25899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25899: -- Fix Version/s: statefun-3.1.2 statefun-3.3.0

[jira] [Updated] (FLINK-25899) Add Java connected components example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-25899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25899: -- Affects Version/s: statefun-3.3.0 > Add Java connected components example to

[jira] [Updated] (FLINK-25899) Add Java connected components example to flink-statefun-playground

[ https://issues.apache.org/jira/browse/FLINK-25899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25899: -- Affects Version/s: statefun-3.2.0 > Add Java connected components example to

[GitHub] [flink-statefun-playground] tillrohrmann commented on pull request #19: [FLINK-25899] Add connected components example

tillrohrmann commented on pull request #19: URL: https://github.com/apache/flink-statefun-playground/pull/19#issuecomment-1028237525 Thanks for the review @igalshilman. I've addressed your comments and pushed an update. Merging this PR now into `release-3.1`, `release-3.2` and `dev`. --

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 58d96bb090b5260fffedf68718c8e77087938cf3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 58d96bb090b5260fffedf68718c8e77087938cf3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] XComp commented on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1028226848 Rebased the branch fixing the `master` conflict -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

flinkbot edited a comment on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1023152110 ## CI report: * 58d96bb090b5260fffedf68718c8e77087938cf3 Azure:

[GitHub] [flink] XComp commented on pull request #18536: [FLINK-25432] Introduces ResourceCleaner to be used in the Dispatcher

XComp commented on pull request #18536: URL: https://github.com/apache/flink/pull/18536#issuecomment-1028220308 Thanks @dmvk . I addressed all your changes and put them in individual commits labeled as `[runtime][review]`. The commits labeled without `[runtime]`are the once refactoring

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

flinkbot edited a comment on pull request #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1023343281 ## CI report: * 79fab9dc03652671ebc8fded5a35a63ea317a6c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] syhily removed a comment on pull request #17452: [FLINK-20732][connector/pulsar] Introduction of Pulsar Sink

syhily removed a comment on pull request #17452: URL: https://github.com/apache/flink/pull/17452#issuecomment-1027998488 @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

[GitHub] [flink] flinkbot edited a comment on pull request #18541: [FLINK-25756] [connectors] Dedicated Opensearch connectors

flinkbot edited a comment on pull request #18541: URL: https://github.com/apache/flink/pull/18541#issuecomment-1023343281 ## CI report: * 79fab9dc03652671ebc8fded5a35a63ea317a6c0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18476: [FLINK-25726][streaming] Add Global Committer as post commit topology

flinkbot edited a comment on pull request #18476: URL: https://github.com/apache/flink/pull/18476#issuecomment-1020132926 ## CI report: * af6a0f5f4aef4386d553aaf8bd5b85f2befbafe0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 1845471184d68e8edd89fd19a591030290695cf3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18601: [FLINK-25699][table] Use HashMap for MAP value constructors

flinkbot edited a comment on pull request #18601: URL: https://github.com/apache/flink/pull/18601#issuecomment-1027812195 ## CI report: * 24a77931358d1b4ba38c4e4704fcb84adb36ac5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18476: [FLINK-25726][streaming] Add Global Committer as post commit topology

flinkbot edited a comment on pull request #18476: URL: https://github.com/apache/flink/pull/18476#issuecomment-1020132926 ## CI report: * af6a0f5f4aef4386d553aaf8bd5b85f2befbafe0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18353: [FLINK-25129][docs]project configuation changes in docs

flinkbot edited a comment on pull request #18353: URL: https://github.com/apache/flink/pull/18353#issuecomment-1012981377 ## CI report: * 1845471184d68e8edd89fd19a591030290695cf3 Azure:

  1   2   3   4   5   >