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

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

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1034927154 -- 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.

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * e882713639b8f7541793d802c52d8c354ddf9ea2 Azure:

[GitHub] [flink] RocMarshal closed pull request #17820: [FLINK-24931][flink-scala] Remove deprecated/unused class files in flink-scala module.

2022-02-10 Thread GitBox
RocMarshal closed pull request #17820: URL: https://github.com/apache/flink/pull/17820 -- 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] flinkbot edited a comment on pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * fc2c5d6d82d21eb7dc97ae6556e797d8fd2675ac Azure:

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

2022-02-10 Thread GitBox
twalthr commented on a change in pull request #18701: URL: https://github.com/apache/flink/pull/18701#discussion_r803676773 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala ## @@ -129,14 +134,48 @@

[GitHub] [flink] RocMarshal closed pull request #18178: [FLINK-5080][connectors/cassandra] Cassandra connector ignores saveAsync result onSuccess.

2022-02-10 Thread GitBox
RocMarshal closed pull request #18178: URL: https://github.com/apache/flink/pull/18178 -- 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] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1034925075 -- 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.

[GitHub] [flink] zentol commented on a change in pull request #18704: [FLINK-26054][table-planner][build] Add enforcer rule to disable direct dependency on table planner

2022-02-10 Thread GitBox
zentol commented on a change in pull request #18704: URL: https://github.com/apache/flink/pull/18704#discussion_r803675502 ## File path: flink-connectors/flink-connector-cassandra/pom.xml ## @@ -43,6 +43,23 @@ under the License. +

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

2022-02-10 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803675720 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -298,19 +306,24 @@

[GitHub] [flink] twalthr commented on a change in pull request #18667: [FLINK-25990][table] Expose uid generator for DataStream/Transformation providers

2022-02-10 Thread GitBox
twalthr commented on a change in pull request #18667: URL: https://github.com/apache/flink/pull/18667#discussion_r803659709 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/connector/ProviderContext.java ## @@ -0,0 +1,41 @@ +/* + *

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

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

[GitHub] [flink] CrynetLogistics commented on pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18686: URL: https://github.com/apache/flink/pull/18686#issuecomment-1034924314 All comments addressed. -- 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

[GitHub] [flink] dmvk 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 configuration

2022-02-10 Thread GitBox
dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803674534 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803673946 ## File path:

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

2022-02-10 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803673802 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -71,20 +76,30 @@ public

[GitHub] [flink] dmvk 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 configuration

2022-02-10 Thread GitBox
dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803673665 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] dmvk 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 configuration

2022-02-10 Thread GitBox
dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803673665 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

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

2022-02-10 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803672817 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -298,19 +306,24 @@ void

[GitHub] [flink] flinkbot edited a comment on pull request #18704: [FLINK-26054][table-planner][build] Add enforcer rule to disable direct dependency on table planner

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18704: URL: https://github.com/apache/flink/pull/18704#issuecomment-1034913098 ## CI report: * 385d41344c4a95ddc7041b05ff2c622d9de2c6ce Azure:

[GitHub] [flink] rkhachatryan commented on pull request #18693: [FLINK-25987][state/changelog] Make lastAppendedSqn optional

2022-02-10 Thread GitBox
rkhachatryan commented on pull request #18693: URL: https://github.com/apache/flink/pull/18693#issuecomment-1034920729 Rebased to include FLINK-26065 fix. -- 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

[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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18701: URL: https://github.com/apache/flink/pull/18701#issuecomment-1034766277 ## CI report: * 1dd05d2b0f15ae91f251248c9eb6a48cd87fe0ba Azure:

[jira] [Commented] (FLINK-25937) SQL Client end-to-end test e2e fails on AZP

2022-02-10 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17490219#comment-17490219 ] Robert Metzger commented on FLINK-25937: [~dmvk] The only thing that I can add as additional

[GitHub] [flink] flinkbot edited a comment on pull request #18700: [FLINK-26070][Python] Update dependency numpy to >=1.21.0,<1.22

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18700: URL: https://github.com/apache/flink/pull/18700#issuecomment-1034649114 ## CI report: * a03576e0a414443a0174b4f3240aedb5520fe3b5 Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * e882713639b8f7541793d802c52d8c354ddf9ea2 Azure:

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

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

[jira] [Created] (FLINK-26073) Remove Twitter connector

2022-02-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26073: -- Summary: Remove Twitter connector Key: FLINK-26073 URL: https://issues.apache.org/jira/browse/FLINK-26073 Project: Flink Issue Type: Technical Debt

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

2022-02-10 Thread GitBox
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 #18553: [FLINK-25846][FLINK-25848] Async Sink does not gracefully shutdown on Cancel, KDS Sink does not fast fail when invalid configuration

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ea3d874c8d4ffe5f9b0c092c16e72a6f17f38b3b Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * fc2c5d6d82d21eb7dc97ae6556e797d8fd2675ac Azure:

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

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

[jira] [Created] (FLINK-26072) Mark NiFi connector as deprecated

2022-02-10 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-26072: -- Summary: Mark NiFi connector as deprecated Key: FLINK-26072 URL: https://issues.apache.org/jira/browse/FLINK-26072 Project: Flink Issue Type: Technical

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

2022-02-10 Thread GitBox
slinkydeveloper commented on a change in pull request #18701: URL: https://github.com/apache/flink/pull/18701#discussion_r803667994 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java ## @@ -1266,6 +1266,12 @@ void

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

2022-02-10 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803667329 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java ## @@ -44,23 +46,42 @@

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

2022-02-10 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r80321 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendHandle.java ## @@ -71,20 +76,30 @@ public

[GitHub] [flink] flinkbot commented on pull request #18704: [FLINK-26054][table-planner][build] Add enforcer rule to disable direct dependency on table planner

2022-02-10 Thread GitBox
flinkbot commented on pull request #18704: URL: https://github.com/apache/flink/pull/18704#issuecomment-1034913440 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 commented on pull request #18704: [FLINK-26054][table-planner][build] Add enforcer rule to disable direct dependency on table planner

2022-02-10 Thread GitBox
flinkbot commented on pull request #18704: URL: https://github.com/apache/flink/pull/18704#issuecomment-1034913098 ## CI report: * 385d41344c4a95ddc7041b05ff2c622d9de2c6ce UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

2022-02-10 Thread GitBox
slinkydeveloper commented on a change in pull request #18701: URL: https://github.com/apache/flink/pull/18701#discussion_r803664883 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala ## @@ -129,14 +134,48

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

2022-02-10 Thread GitBox
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 #18656: [FLINK-25249][connector/kafka] Reimplement KafkaTestEnvironment with KafkaContainer

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18656: URL: https://github.com/apache/flink/pull/18656#issuecomment-1032337760 ## CI report: * 044dfe6025fb3e59e6b84f44c6116d784af328e2 Azure:

[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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ea3d874c8d4ffe5f9b0c092c16e72a6f17f38b3b Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * fc2c5d6d82d21eb7dc97ae6556e797d8fd2675ac Azure:

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

2022-02-10 Thread GitBox
slinkydeveloper commented on a change in pull request #18701: URL: https://github.com/apache/flink/pull/18701#discussion_r803663446 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java ## @@ -79,25 +79,37 @@ default void

[jira] [Updated] (FLINK-26054) Enable maven-enforcer to disable table-planner and table-runtime as dependencies

2022-02-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26054: --- Labels: pull-request-available (was: ) > Enable maven-enforcer to disable table-planner

[GitHub] [flink] slinkydeveloper opened a new pull request #18704: [FLINK-26054][table-planner][build] Add enforcer rule to disable direct dependency on table planner

2022-02-10 Thread GitBox
slinkydeveloper opened a new pull request #18704: URL: https://github.com/apache/flink/pull/18704 ## What is the purpose of the change Add a maven enforcer rule to disable direct dependency on table planner. Added exclusions to modules depending directly on table planner --

[GitHub] [flink] flinkbot edited a comment on pull request #18703: [FLINK-25870][table] Introduce ContextResolvedFunction similar to ContextResolvedTable

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18703: URL: https://github.com/apache/flink/pull/18703#issuecomment-1034899976 ## CI report: * 2014ead9cb14bdaafabf8afbd7c54cc277f9a7e0 Azure:

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

2022-02-10 Thread GitBox
rkhachatryan commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803659360 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -298,19 +306,24 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18680: [FLINK-25583] Support compacting small files for FileSink.

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18680: URL: https://github.com/apache/flink/pull/18680#issuecomment-1033512635 ## CI report: * d3ecea69aa562e4be5e92a68bfb2617dde45e4e7 Azure:

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

2022-02-10 Thread GitBox
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 #18603: [FLINK-25610][connector/firehose] Adding table api base for kinesis firehose

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 8b6adf5e05234f15048390cae6f97355d286944d Azure:

[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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ea3d874c8d4ffe5f9b0c092c16e72a6f17f38b3b Azure:

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

2022-02-10 Thread GitBox
twalthr commented on a change in pull request #18701: URL: https://github.com/apache/flink/pull/18701#discussion_r803652218 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java ## @@ -79,25 +79,37 @@ default void

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * fc2c5d6d82d21eb7dc97ae6556e797d8fd2675ac Azure:

[GitHub] [flink] MrWhiteSike commented on a change in pull request #13812: [FLINK-19674][docs-zh] Translate "Docker" of "Clusters & Depolyment" page into Chinese

2022-02-10 Thread GitBox
MrWhiteSike commented on a change in pull request #13812: URL: https://github.com/apache/flink/pull/13812#discussion_r803634749 ## File path: docs/ops/deployment/docker.zh.md ## @@ -23,72 +23,71 @@ specific language governing permissions and limitations under the License.

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-10 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r803656678 ## File path: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/common/ElasticsearchUtil.java ##

[GitHub] [flink] flinkbot commented on pull request #18703: [FLINK-25870][table] Introduce ContextResolvedFunction similar to ContextResolvedTable

2022-02-10 Thread GitBox
flinkbot commented on pull request #18703: URL: https://github.com/apache/flink/pull/18703#issuecomment-1034899976 ## CI report: * 2014ead9cb14bdaafabf8afbd7c54cc277f9a7e0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18691: Flink 25846 25848 25977 25792 compound

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18691: URL: https://github.com/apache/flink/pull/18691#issuecomment-1034110616 ## CI report: * 84f974662b25cb8ecd1f2c644fa50a9b4625cd2d Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18603: URL: https://github.com/apache/flink/pull/18603#issuecomment-1027853740 ## CI report: * 8b6adf5e05234f15048390cae6f97355d286944d Azure:

[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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ea3d874c8d4ffe5f9b0c092c16e72a6f17f38b3b Azure:

[GitHub] [flink] flinkbot commented on pull request #18703: [FLINK-25870][table] Introduce ContextResolvedFunction similar to ContextResolvedTable

2022-02-10 Thread GitBox
flinkbot commented on pull request #18703: URL: https://github.com/apache/flink/pull/18703#issuecomment-1034894388 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 #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 146d81ca276cd3189fbf26b073d513b588b571fa Azure:

[jira] [Updated] (FLINK-25870) Introduce ContextResolvedFunction similar to ContextResolvedTable

2022-02-10 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25870: --- Labels: pull-request-available (was: ) > Introduce ContextResolvedFunction similar to

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18670: URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650 ## CI report: * b87fb6bf4a43eeb1b10d3516493959f43ff901af Azure:

[GitHub] [flink] twalthr opened a new pull request #18703: [FLINK-25870][table] Introduce ContextResolvedFunction similar to ContextResolvedTable

2022-02-10 Thread GitBox
twalthr opened a new pull request #18703: URL: https://github.com/apache/flink/pull/18703 ## What is the purpose of the change This performs a similar refactoring as done for `ContextResolvedTable`. ## Brief change log - Introduce `ContextResolvedFunction` to

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * fc2c5d6d82d21eb7dc97ae6556e797d8fd2675ac Azure:

[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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ea3d874c8d4ffe5f9b0c092c16e72a6f17f38b3b Azure:

[GitHub] [flink] bgeng777 edited a comment on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

2022-02-10 Thread GitBox
bgeng777 edited a comment on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1034889669 The azure test pipeline is broken for now and no e2e tests can succeed for all PRs for now. Will run azure test tomorrow if it works. -- This is an automated message

[GitHub] [flink] bgeng777 commented on pull request #18531: [FLINK-24897] Enable application mode on YARN to use usrlib

2022-02-10 Thread GitBox
bgeng777 commented on pull request #18531: URL: https://github.com/apache/flink/pull/18531#issuecomment-1034889669 The azure test pipeline is broken for now and no e2e tests can succeed for all tests for now. Will run azure test tomorrow if it works. -- This is an automated message from

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

2022-02-10 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803643617 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateHandleStreamImpl.java ## @@ -44,23 +46,42 @@

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18678: URL: https://github.com/apache/flink/pull/18678#issuecomment-1033466685 ## CI report: * 146d81ca276cd3189fbf26b073d513b588b571fa Azure:

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

2022-02-10 Thread GitBox
Myasuka commented on a change in pull request #18391: URL: https://github.com/apache/flink/pull/18391#discussion_r803640099 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java ## @@ -298,19 +306,24 @@ void

[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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1024127153 ## CI report: * eae81dc84402215df5d19aa0687ae2f4a0e376fd UNKNOWN * ea3d874c8d4ffe5f9b0c092c16e72a6f17f38b3b Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18153: URL: https://github.com/apache/flink/pull/18153#issuecomment-997756404 ## CI report: * fc2c5d6d82d21eb7dc97ae6556e797d8fd2675ac Azure:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803636279 ## File path:

[GitHub] [flink] CrynetLogistics commented on a change in pull request #18686: [FLINK-25977][connectors/kinesis] Closing http & sdk clients in sink …

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18686: URL: https://github.com/apache/flink/pull/18686#discussion_r803635778 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 34a2b1811fd7bc75e2c1e9c8462ab9573d506559 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18672: [FLINK-25996][runtime] Introduce job property isDynamicGraph to ExecutionConfig

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18672: URL: https://github.com/apache/flink/pull/18672#issuecomment-1033272608 ## CI report: * e88e25f069efe98417e027028d3fdf202379dd92 Azure:

[GitHub] [flink] dmvk 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 configuration

2022-02-10 Thread GitBox
dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803633445 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

[GitHub] [flink] dmvk 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 configuration

2022-02-10 Thread GitBox
dmvk commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803633445 ## File path: flink-connectors/flink-connector-aws-kinesis-firehose/src/test/java/org/apache/flink/connector/firehose/sink/KinesisFirehoseSinkITCase.java

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999 ## CI report: * 82860fda96c0e0d5931be169f1e664ec61349564 Azure:

[GitHub] [flink] alpreu commented on a change in pull request #18153: [FLINK-25568][connectors/elasticsearch] Add Elasticsearch 7 Source

2022-02-10 Thread GitBox
alpreu commented on a change in pull request #18153: URL: https://github.com/apache/flink/pull/18153#discussion_r803632122 ## File path: flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/connector/elasticsearch/source/reader/Elasticsearch7SplitReader.java

[GitHub] [flink] CrynetLogistics commented 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

2022-02-10 Thread GitBox
CrynetLogistics commented on pull request #18553: URL: https://github.com/apache/flink/pull/18553#issuecomment-1034875975 All comments addressed. Thank you. -- 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] 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

2022-02-10 Thread GitBox
CrynetLogistics commented on a change in pull request #18553: URL: https://github.com/apache/flink/pull/18553#discussion_r803629071 ## File path:

[GitHub] [flink] flinkbot edited a comment on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 34a2b1811fd7bc75e2c1e9c8462ab9573d506559 Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18669: URL: https://github.com/apache/flink/pull/18669#issuecomment-1033040800 ## CI report: * 17b33c5cff12c7a0523e4644a7fec0be0bf608f3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16584: [FLINK-22781][table-planner-blink] Fix bug that when implements the L…

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #16584: URL: https://github.com/apache/flink/pull/16584#issuecomment-885710999 ## CI report: * 82860fda96c0e0d5931be169f1e664ec61349564 Azure:

[GitHub] [flink] rmetzger commented on pull request #18692: [FLINK-26015] Fixes object store bug

2022-02-10 Thread GitBox
rmetzger commented on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034867973 Sadly, the JRS still doesn't work on K8s, using a minio s3 implementation: ``` 2022-02-10 12:20:23,679 INFO

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

2022-02-10 Thread GitBox
rmetzger removed a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034859586 Sadly, the JRS still doesn't work on K8s, using a minio s3 implementation: ``` 2022-02-10 12:20:23,679 INFO

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

2022-02-10 Thread GitBox
rmetzger edited a comment on pull request #18692: URL: https://github.com/apache/flink/pull/18692#issuecomment-1034859586 Sadly, the JRS still doesn't work on K8s, using a minio s3 implementation: ``` 2022-02-10 12:20:23,679 INFO

[GitHub] [flink] autophagy commented on a change in pull request #18678: [FLINK-24474] Default rest.bind-address to localhost in flink-conf.yaml

2022-02-10 Thread GitBox
autophagy commented on a change in pull request #18678: URL: https://github.com/apache/flink/pull/18678#discussion_r803623338 ## File path: flink-end-to-end-tests/test-scripts/common_kubernetes.sh ## @@ -225,4 +225,9 @@ function get_host_machine_address { fi }

[GitHub] [flink] MrWhiteSike commented on a change in pull request #17943: [FLINK-24693][docs-zh] Translate "checkpoints" and "checkpointing" page to Chinese

2022-02-10 Thread GitBox
MrWhiteSike commented on a change in pull request #17943: URL: https://github.com/apache/flink/pull/17943#discussion_r803621040 ## File path: docs/content.zh/docs/ops/state/checkpoints.md ## @@ -74,15 +129,24 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18697: [FLINK-26034][Build System]Add maven wrapper for flink

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18697: URL: https://github.com/apache/flink/pull/18697#issuecomment-1034510296 ## CI report: * 34a2b1811fd7bc75e2c1e9c8462ab9573d506559 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18688: [FLINK-26060][table-planner] Remove persisted plan feature support for Python UDFs

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18688: URL: https://github.com/apache/flink/pull/18688#issuecomment-1033917965 ## CI report: * f2aeb29764801267d7cb8463724464e49774ee28 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18670: [FLINK-25999] Deprecate Per-Job Mode

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18670: URL: https://github.com/apache/flink/pull/18670#issuecomment-1033075650 ## CI report: * 360c74aff2caa70284a90375a17519dc4843d4b2 Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18664: URL: https://github.com/apache/flink/pull/18664#issuecomment-1032585099 ## CI report: * e882713639b8f7541793d802c52d8c354ddf9ea2 Azure:

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

2022-02-10 Thread GitBox
flinkbot edited a comment on pull request #18649: URL: https://github.com/apache/flink/pull/18649#issuecomment-1031570072 ## CI report: * 414d103b5b3cd2960b910198c40a7aeb83aed868 Azure:

<    3   4   5   6   7   8   9   10   11   >