[GitHub] [flink] flinkbot edited a comment on pull request #18058: [FLINK-24571][connectors/elasticsearch] Supports a system time function(now() and current_timestamp) in index pattern

flinkbot edited a comment on pull request #18058: URL: https://github.com/apache/flink/pull/18058#issuecomment-988949831 ## CI report: * 93c33001cf55690369281de939bd79bb3727ad9a UNKNOWN * 107f4c437fb8f4af9a8dd143a2c3e68e72b66ceb Azure:

[jira] [Updated] (FLINK-26077) Support operators send request to Coordinator and return a response

[ https://issues.apache.org/jira/browse/FLINK-26077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-26077: Component/s: Runtime / Coordination > Support operators send request to Coordinator and return a response

[jira] [Created] (FLINK-26077) Support operators send request to Coordinator and return a response

Jark Wu created FLINK-26077: --- Summary: Support operators send request to Coordinator and return a response Key: FLINK-26077 URL: https://issues.apache.org/jira/browse/FLINK-26077 Project: Flink

[jira] [Commented] (FLINK-25600) Support new statement set syntax in sql client and update docs

[ https://issues.apache.org/jira/browse/FLINK-25600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490329#comment-17490329 ] Francesco Guardiani commented on FLINK-25600: - Hi [~wenlong.lwl] any updates on this one? >

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803795941 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -415,7 +440,7 @@

[GitHub] [flink] flinkbot commented on pull request #18710: [FLINK-26055][table][annotations] Modified CompiledPlan#getFlinkVersion return type to FlinkVersion

flinkbot commented on pull request #18710: URL: https://github.com/apache/flink/pull/18710#issuecomment-1035051190 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] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803794145 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger

[GitHub] [flink] flinkbot commented on pull request #18709: [FLINK-26076] Fix ArchUnit violations in Source(Sink)MetricsITCase

flinkbot commented on pull request #18709: URL: https://github.com/apache/flink/pull/18709#issuecomment-1035050631 ## CI report: * 17f2ffbe7f9a8dd9315e7ee8c1cc3acad30728bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18708: Flink 25610 firehose connector backup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[jira] [Updated] (FLINK-26055) Use new FlinkVersion enum for serde plans

[ https://issues.apache.org/jira/browse/FLINK-26055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-26055: Component/s: Table SQL / API > Use new FlinkVersion enum for serde plans >

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18696: [hotfix][docs] project config pages

flinkbot edited a comment on pull request #18696: URL: https://github.com/apache/flink/pull/18696#issuecomment-1034481691 ## CI report: * 2921ed917d22b64cb99f05dfdd0f7e119dd86880 Azure:

[jira] [Updated] (FLINK-26060) Make Python specific exec nodes unsupported

[ https://issues.apache.org/jira/browse/FLINK-26060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani updated FLINK-26060: Component/s: Table SQL / Runtime > Make Python specific exec nodes unsupported >

[GitHub] [flink] flinkbot edited a comment on pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

flinkbot edited a comment on pull request #18667: URL: https://github.com/apache/flink/pull/18667#issuecomment-1032823071 ## CI report: * 4af7f825a1bcbed0a6fda02c9445d9288a175e30 Azure:

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803790449 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger

[jira] [Updated] (FLINK-26055) Use new FlinkVersion enum for serde plans

[ https://issues.apache.org/jira/browse/FLINK-26055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26055: --- Labels: pull-request-available (was: ) > Use new FlinkVersion enum for serde plans >

[GitHub] [flink] flinkbot commented on pull request #18709: [FLINK-26076] Fix ArchUnit violations in Source(Sink)MetricsITCase

flinkbot commented on pull request #18709: URL: https://github.com/apache/flink/pull/18709#issuecomment-1035047288 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] slinkydeveloper opened a new pull request #18710: [FLINK-26055][table][annotations] Modified CompiledPlan#getFlinkVersion return type to FlinkVersion

slinkydeveloper opened a new pull request #18710: URL: https://github.com/apache/flink/pull/18710 ## What is the purpose of the change This PR exposes and persists the flink version in `CompiledPlan` from the `FlinkVersion` enum, rather than from the resource file in `flink-runtime`

[GitHub] [flink] dawidwys merged pull request #18643: [hotfix][docs] replace deprecated class and fix typos

dawidwys merged pull request #18643: URL: https://github.com/apache/flink/pull/18643 -- 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:

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803786630 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger

[jira] [Updated] (FLINK-26076) Fix ArchUnit violations in Source(Sink)MetricsITCase

[ https://issues.apache.org/jira/browse/FLINK-26076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26076: --- Labels: pull-request-available (was: ) > Fix ArchUnit violations in

[GitHub] [flink] dawidwys opened a new pull request #18709: [FLINK-26076] Fix ArchUnit violations in Source(Sink)MetricsITCase

dawidwys opened a new pull request #18709: URL: https://github.com/apache/flink/pull/18709 ## What is the purpose of the change Fix ArchUnit violations regarding InMemoryReporter ## Brief change log * parameterize search methods with JobID instead of recreating the

[jira] [Commented] (FLINK-24275) Allow idempotent job cancellation

[ https://issues.apache.org/jira/browse/FLINK-24275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490322#comment-17490322 ] Chesnay Schepler commented on FLINK-24275: -- IMO we should only document things (in particular

[GitHub] [flink] dawidwys commented on pull request #18709: [FLINK-26076] Fix ArchUnit violations in Source(Sink)MetricsITCase

dawidwys commented on pull request #18709: URL: https://github.com/apache/flink/pull/18709#issuecomment-1035041800 Do you mind taking a look @zentol @JingGe ? -- 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 commented on pull request #18708: Flink 25610 firehose connector backup

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

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18696: [hotfix][docs] project config pages

flinkbot edited a comment on pull request #18696: URL: https://github.com/apache/flink/pull/18696#issuecomment-1034481691 ## CI report: * 2921ed917d22b64cb99f05dfdd0f7e119dd86880 Azure:

[jira] [Updated] (FLINK-26076) Fix ArchUnit violations in Source(Sink)MetricsITCase

[ https://issues.apache.org/jira/browse/FLINK-26076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-26076: - Summary: Fix ArchUnit violations in Source(Sink)MetricsITCase (was: Fix ArchUnit

[GitHub] [flink] rkhachatryan commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803781575 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -415,7 +440,7 @@

[jira] [Created] (FLINK-26076) Fix ArchUnit violations in SourceMetricsITCase

Dawid Wysakowicz created FLINK-26076: Summary: Fix ArchUnit violations in SourceMetricsITCase Key: FLINK-26076 URL: https://issues.apache.org/jira/browse/FLINK-26076 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #18708: Flink 25610 firehose connector backup

flinkbot commented on pull request #18708: URL: https://github.com/apache/flink/pull/18708#issuecomment-1035036984 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 #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * f34977eb02ad9dceb02c108cdbf344ebcf75e737 Azure:

[GitHub] [flink] pnowojski commented on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

pnowojski commented on pull request #18702: URL: https://github.com/apache/flink/pull/18702#issuecomment-1035032817 The initial version was causing a small performance regression. After a couple of optimisations there is no visible regression when the watermark alignment is not used.

[GitHub] [flink] vahmed-hamdy opened a new pull request #18708: Flink 25610 firehose connector backup

vahmed-hamdy opened a new pull request #18708: URL: https://github.com/apache/flink/pull/18708 ## 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

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

slinkydeveloper commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r803774457 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18705: [FLINK-26073][Connectors][Twitter] Remove Twitter connector

flinkbot edited a comment on pull request #18705: URL: https://github.com/apache/flink/pull/18705#issuecomment-1034936625 ## CI report: * 0559b7a557c7e34f4564c4280ae0b9d2977b42da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 5a104bf0fe75823e4946852d66fb5ad117d585b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18664: [FLINK-25907][runtime][security] Add pluggable delegation token manager

flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * 357ed24c86356875da2a328ea57546ff86b39d5f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 764c5fdf856b0930f7fdf8d470256e84d05a646a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18649: [FLINK-25844][table-api-java] Introduce StatementSet#compilePlan

flinkbot edited a comment on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072 ## CI report: * 114478aae924d51669e7809bc26c6c82c4d5955a Azure:

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803770073 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StopWithSavepoint.java ## @@ -134,30 +143,53 @@ public JobStatus

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * f34977eb02ad9dceb02c108cdbf344ebcf75e737 Azure:

[GitHub] [flink] Myasuka commented on a change in pull request #18391: [FLINK-25478][chaneglog] Correct the state register logic of ChangelogStateBackendHandle

Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803767353 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -415,7 +440,7 @@

[GitHub] [flink] MartijnVisser commented on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

MartijnVisser commented on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1035022729 > They should also be marked as deprecate in the documentation. Thanks, I've added a deprecation warning to the docs. -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18705: [FLINK-26073][Connectors][Twitter] Remove Twitter connector

flinkbot edited a comment on pull request #18705: URL: https://github.com/apache/flink/pull/18705#issuecomment-1034936625 ## CI report: * 0559b7a557c7e34f4564c4280ae0b9d2977b42da Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 7645e2a83b9789816399536fbf369dc65eafcbf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

[GitHub] [flink] dmvk commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

dmvk commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803761345 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public Logger

[GitHub] [flink] flinkbot edited a comment on pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

flinkbot edited a comment on pull request #18653: URL: https://github.com/apache/flink/pull/18653#issuecomment-1032212433 ## CI report: * 764c5fdf856b0930f7fdf8d470256e84d05a646a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 5a104bf0fe75823e4946852d66fb5ad117d585b6 Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #18653: [FLINK-25825][connector-jdbc] MySqlCatalogITCase fails on azure

RocMarshal commented on a change in pull request #18653: URL: https://github.com/apache/flink/pull/18653#discussion_r803760543 ## File path: flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/table/UnsignedTypeConversionITCase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 429fe69c2ea086a2e13a7b99d922085618299396 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * f34977eb02ad9dceb02c108cdbf344ebcf75e737 Azure:

[jira] [Commented] (FLINK-24275) Allow idempotent job cancellation

[ https://issues.apache.org/jira/browse/FLINK-24275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490310#comment-17490310 ] Joe Moser commented on FLINK-24275: --- [~chesnay] i was referring to {_}409{_}, so not a successful

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18692: [FLINK-26015] Fixes object store bug

flinkbot edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034131249 ## CI report: * 7645e2a83b9789816399536fbf369dc65eafcbf7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

flinkbot edited a comment on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883 ## CI report: * 71fd9a5a7917a6bc423a45ca3deec8b84007c9e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 5a104bf0fe75823e4946852d66fb5ad117d585b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

flinkbot edited a comment on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1030235273 ## CI report: * 429fe69c2ea086a2e13a7b99d922085618299396 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * f34977eb02ad9dceb02c108cdbf344ebcf75e737 Azure:

[GitHub] [flink] XComp commented on pull request #18637: [FLINK-25433][runtime] Adds retry mechanism to DefaultResourceCleaner

XComp commented on pull request #18637: URL: https://github.com/apache/flink/pull/18637#issuecomment-1035005706 Rebased the branch after FLINK-26065 is resolved. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803748913 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/Executing.java ## @@ -80,49 +89,53 @@ public void cancel() {

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803748090 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -1576,4 +1576,15 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot edited a comment on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

flinkbot edited a comment on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883 ## CI report: * 71fd9a5a7917a6bc423a45ca3deec8b84007c9e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 5a104bf0fe75823e4946852d66fb5ad117d585b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

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

[GitHub] [flink] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * f34977eb02ad9dceb02c108cdbf344ebcf75e737 Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid co

CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803742615 ## File path:

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803742746 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public

[GitHub] [flink] zentol commented on a change in pull request #18705: [FLINK-26073][Connectors][Twitter] Remove Twitter connector

zentol commented on a change in pull request #18705: URL: https://github.com/apache/flink/pull/18705#discussion_r803742070 ## File path: flink-examples/flink-examples-streaming/pom.xml ## @@ -168,20 +162,6 @@ under the License.

[GitHub] [flink] dannycranmer commented on a change in pull request #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

dannycranmer commented on a change in pull request #18603: URL: https://github.com/apache/flink/pull/18603#discussion_r803703950 ## File path:

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803741134 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -148,6 +162,33 @@ public

[GitHub] [flink] metaswirl commented on a change in pull request #18689: [FLINK-21439][runtime] Exception history adaptive scheduler

metaswirl commented on a change in pull request #18689: URL: https://github.com/apache/flink/pull/18689#discussion_r803739789 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StopWithSavepoint.java ## @@ -134,30 +143,53 @@ public JobStatus

[GitHub] [flink] flinkbot commented on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot commented on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034994010 ## CI report: * 5e2128cc02aa0cfdb9b074edd5b0cab02c3daed6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18706: [FLINK-26072][Connectors][NiFi] Mark NiFi Source and Sink as deprecated

flinkbot edited a comment on pull request #18706: URL: https://github.com/apache/flink/pull/18706#issuecomment-1034953890 ## CI report: * bf78620ba038d62e133c9ef66eb39e0e2313561f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

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

[GitHub] [flink] flinkbot edited a comment on pull request #18701: [FLINK-26071][table-api-java][table-planner] Now Planner#compilePlan fails if the plan cannot be serialized

flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * a3fdc9763094051769e040d5211db40196fe493c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

flinkbot edited a comment on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034140883 ## CI report: * 71fd9a5a7917a6bc423a45ca3deec8b84007c9e3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18669: [FLINK-25943][connector/common] Add buffered requests to snapshot state in AsyncSyncWriter.

flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 5a104bf0fe75823e4946852d66fb5ad117d585b6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18624: [FLINK-25388][table-planner] Add consumedOptions to ExecNodeMetadata

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

[GitHub] [flink] flinkbot commented on pull request #18707: [FLINK-25995][table-planner] Make implicit assumption of SQL local hash explicit

flinkbot commented on pull request #18707: URL: https://github.com/apache/flink/pull/18707#issuecomment-1034991788 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] dawidwys commented on a change in pull request #18702: [FLINK-24441][source] Block SourceOperator when watermarks are out of alignment

dawidwys commented on a change in pull request #18702: URL: https://github.com/apache/flink/pull/18702#discussion_r803735949 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorAlignmentTest.java ## @@ -0,0 +1,155 @@ +/*

<    1   2   3   4   5   6   7   8   9   10   >