[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * c15632cf1ee4b38d0060a87c3bedb5cb4d545264 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-25740: -- Priority: Critical (was: Major) > PulsarSourceOrderedE2ECase fails on azure > ---

[GitHub] [flink] flinkbot edited a comment on pull request #18359: [FLINK-25484][connectors/filesystem] Support inactivityInterval config in table api

flinkbot edited a comment on pull request #18359: URL: https://github.com/apache/flink/pull/18359#issuecomment-1012981632 ## CI report: * 82871d3416aefbce86d6e32e3e26a51c12841534 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] slinkydeveloper commented on a change in pull request #18353: [FLINK-25129][docs]project configuation changes in docs

slinkydeveloper commented on a change in pull request #18353: URL: https://github.com/apache/flink/pull/18353#discussion_r789423489 ## File path: docs/content/docs/dev/configuration/overview.md ## @@ -52,46 +52,36 @@ In Maven syntax, it would look like: {{< tabs "a49d57a4-27

[GitHub] [flink] slinkydeveloper commented on pull request #13081: [FLINK-18590][json] Support json array explode to multi messages

slinkydeveloper commented on pull request #13081: URL: https://github.com/apache/flink/pull/13081#issuecomment-1018272859 @poan0508 this PR is looking for someone to finalize it. Wanna take a crack at it? -- This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] JingsongLi commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

JingsongLi commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r789435121 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala ## @@ -47,21 +53,30 @@ import or

[GitHub] [flink] dawidwys commented on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

dawidwys commented on pull request #18405: URL: https://github.com/apache/flink/pull/18405#issuecomment-1018277879 Have you tried building Flink from the command line? Usually that helps with any auto generated files, at least that's what I do. -- This is an automated message from the Ap

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Summary: FLIP-182: Support native and incremental savepoints (was: Support native and incre

[jira] [Created] (FLINK-25744) Support native savepoints (w/o modifying the statebackend specific snapshot strategies)

Piotr Nowojski created FLINK-25744: -- Summary: Support native savepoints (w/o modifying the statebackend specific snapshot strategies) Key: FLINK-25744 URL: https://issues.apache.org/jira/browse/FLINK-25744

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Affects Version/s: 1.14.3 > FLIP-182: Support native and incremental savepoints > --

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Component/s: Runtime / Checkpointing > FLIP-182: Support native and incremental savepoints >

[jira] [Updated] (FLINK-25276) FLIP-182: Support native and incremental savepoints

[ https://issues.apache.org/jira/browse/FLINK-25276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-25276: --- Fix Version/s: 1.15.0 > FLIP-182: Support native and incremental savepoints > --

[jira] [Created] (FLINK-25745) Support RocksDB incremental native savepoints

Piotr Nowojski created FLINK-25745: -- Summary: Support RocksDB incremental native savepoints Key: FLINK-25745 URL: https://issues.apache.org/jira/browse/FLINK-25745 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

flinkbot edited a comment on pull request #18324: URL: https://github.com/apache/flink/pull/18324#issuecomment-1009752905 ## CI report: * 647c5b7e76e310ff363a31eb9de04c544f2effd9 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] SteNicholas closed pull request #15729: [FLINK-22234][runtime] Read savepoint before creating ExecutionGraph

SteNicholas closed pull request #15729: URL: https://github.com/apache/flink/pull/15729 -- 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: issues-uns

[GitHub] [flink] SteNicholas closed pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

SteNicholas closed pull request #13298: URL: https://github.com/apache/flink/pull/13298 -- 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: issues-uns

[GitHub] [flink] SteNicholas closed pull request #14028: [FLINK-20020][client] Make UnsuccessfulExecutionException part of the JobClient.getJobExecutionResult() contract

SteNicholas closed pull request #14028: URL: https://github.com/apache/flink/pull/14028 -- 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: issues-uns

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * 66280958ba0046cbef940e575fc61a4ec6d62253 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fapaul commented on a change in pull request #18397: [FLINK-25702][Kafka] Use the configure feature provided by the kafka Serializer/Deserializer.

fapaul commented on a change in pull request #18397: URL: https://github.com/apache/flink/pull/18397#discussion_r789453203 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/deserializer/KafkaValueOnlyDeserializerWrapper.j

[GitHub] [flink] flinkbot edited a comment on pull request #18137: [FLINK-25287][connector-testing-framework] Refactor interfaces of connector testing framework to support more scenarios

flinkbot edited a comment on pull request #18137: URL: https://github.com/apache/flink/pull/18137#issuecomment-996615034 ## CI report: * d3a3caf926f972fa7b83edc1d66d9883aba15376 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18436: [BP-1.13][FLINK-24334][k8s] Set FLINK_LOG_DIR environment for JobManager and TaskManager pod if configured via options

flinkbot edited a comment on pull request #18436: URL: https://github.com/apache/flink/pull/18436#issuecomment-1018094327 ## CI report: * f87a46d760404ab5d51b2d5ed554459d3b07fde6 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-24623) Prevent usage of EventTimeWindows when EventTime is disabled

[ https://issues.apache.org/jira/browse/FLINK-24623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479905#comment-17479905 ] Alexander Fedulov commented on FLINK-24623: --- [~Dario] Hi Dario, could you prop

[jira] [Comment Edited] (FLINK-24623) Prevent usage of EventTimeWindows when EventTime is disabled

[ https://issues.apache.org/jira/browse/FLINK-24623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479905#comment-17479905 ] Alexander Fedulov edited comment on FLINK-24623 at 1/21/22, 8:47 AM: -

[GitHub] [flink] dannycranmer commented on pull request #18421: [FLINK-25731][connectors/kinesis] Deprecated FlinkKinesisConsumer / F…

dannycranmer commented on pull request #18421: URL: https://github.com/apache/flink/pull/18421#issuecomment-1018302126 LGTM, merging -- 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] dannycranmer merged pull request #18421: [FLINK-25731][connectors/kinesis] Deprecated FlinkKinesisConsumer / F…

dannycranmer merged pull request #18421: URL: https://github.com/apache/flink/pull/18421 -- 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: issues-un

[GitHub] [flink] rkhachatryan commented on a change in pull request #18324: [FLINK-25557][checkpoint] Introduce incremental/full checkpoint size stats

rkhachatryan commented on a change in pull request #18324: URL: https://github.com/apache/flink/pull/18324#discussion_r789465033 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@

[jira] [Created] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

Jane Chan created FLINK-25746: - Summary: Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module Key: FLINK-25746 URL: https://issues.apache.org/jira/browse/FLINK-25746 Project: Fl

[jira] [Updated] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-25746: -- Attachment: image-2022-01-21-16-54-12-354.png > Failed to run ITCase locally with IDEA under flink-orc

[jira] [Updated] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-25746: -- Description: Recently, it has been observed that several integration test cases failed when running f

[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: * b29c358b51b4a803f129eab3ad8723747510d3c0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-25746: -- Attachment: image-2022-01-21-16-56-42-156.png > Failed to run ITCase locally with IDEA under flink-orc

[jira] [Commented] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479909#comment-17479909 ] Jane Chan commented on FLINK-25746: --- While it's ok when running tests from the command

[jira] [Updated] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-25746: -- Affects Version/s: 1.15.0 > Failed to run ITCase locally with IDEA under flink-orc and flink-parquet

[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: * b29c358b51b4a803f129eab3ad8723747510d3c0 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-25747) UdfStreamOperatorCheckpointingITCase hangs on AZP

Till Rohrmann created FLINK-25747: - Summary: UdfStreamOperatorCheckpointingITCase hangs on AZP Key: FLINK-25747 URL: https://issues.apache.org/jira/browse/FLINK-25747 Project: Flink Issue Typ

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479923#comment-17479923 ] Jane Chan commented on FLINK-25746: --- h4. Some observations The dependency tree is lis

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479924#comment-17479924 ] Till Rohrmann commented on FLINK-24119: --- Similar problem for {{KafkaShuffleExactl

[jira] [Commented] (FLINK-25698) Elasticsearch7DynamicSinkITCase.testWritingDocuments fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479925#comment-17479925 ] Till Rohrmann commented on FLINK-25698: --- Another instance: https://dev.azure.com/

[jira] [Assigned] (FLINK-25748) Website misses some Repositories

[ https://issues.apache.org/jira/browse/FLINK-25748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantin Knauf reassigned FLINK-25748: Assignee: Konstantin Knauf > Website misses some Repositories > -

[jira] [Created] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

Till Rohrmann created FLINK-25749: - Summary: YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP Key: FLINK-25749 URL: https://issues.apache.org/jira/browse/FLINK-25749 Project: Flink

[jira] [Created] (FLINK-25748) Website misses some Repositories

Konstantin Knauf created FLINK-25748: Summary: Website misses some Repositories Key: FLINK-25748 URL: https://issues.apache.org/jira/browse/FLINK-25748 Project: Flink Issue Type: Bug

[GitHub] [flink] zentol commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when

zentol commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789479364 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ priv

[GitHub] [flink] flinkbot edited a comment on pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

flinkbot edited a comment on pull request #18238: URL: https://github.com/apache/flink/pull/18238#issuecomment-1002686071 ## CI report: * ba54b091609f7e51792a911192e89e0eb7b6d1d7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25749) YARNSessionFIFOSecuredITCase.testDetachedMode fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479930#comment-17479930 ] Till Rohrmann commented on FLINK-25749: --- Another instance: https://dev.azure.com/

[jira] [Commented] (FLINK-25746) Failed to run ITCase locally with IDEA under flink-orc and flink-parquet module

[ https://issues.apache.org/jira/browse/FLINK-25746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479931#comment-17479931 ] Jane Chan commented on FLINK-25746: --- By simply adding the guava as test dependencies t

[jira] [Commented] (FLINK-25748) Website misses some Repositories

[ https://issues.apache.org/jira/browse/FLINK-25748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479933#comment-17479933 ] Chesnay Schepler commented on FLINK-25748: -- I'm wondering if we should just lin

[jira] [Commented] (FLINK-25748) Website misses some Repositories

[ https://issues.apache.org/jira/browse/FLINK-25748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479934#comment-17479934 ] Chesnay Schepler commented on FLINK-25748: -- Especially since we're gonna be add

[jira] [Created] (FLINK-25750) Performance regression on 20.01.2021 in globalWindow and stateBackend benchmarks

Roman Khachatryan created FLINK-25750: - Summary: Performance regression on 20.01.2021 in globalWindow and stateBackend benchmarks Key: FLINK-25750 URL: https://issues.apache.org/jira/browse/FLINK-25750

[GitHub] [flink] zentol commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when

zentol commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789479364 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ priv

[jira] [Commented] (FLINK-25748) Website misses some Repositories

[ https://issues.apache.org/jira/browse/FLINK-25748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479936#comment-17479936 ] Konstantin Knauf commented on FLINK-25748: -- Good point. I'd say we list the mai

[GitHub] [flink] flinkbot edited a comment on pull request #18238: WIP: [FLINK-XXXXX] Task local recovery for the reactive mode.

flinkbot edited a comment on pull request #18238: URL: https://github.com/apache/flink/pull/18238#issuecomment-1002686071 ## CI report: * ba54b091609f7e51792a911192e89e0eb7b6d1d7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18414: [hotfix][docs]fix flink sql Cascading Window TVF Aggregation exception

flinkbot edited a comment on pull request #18414: URL: https://github.com/apache/flink/pull/18414#issuecomment-1017182067 ## CI report: * 2d7b1b7425be2b9cfb9020d92cf08cc6d5596ef6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] dmvk commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when t

dmvk commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789487585 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ privat

[jira] [Commented] (FLINK-25470) Add/Expose/Differentiate metrics of checkpoint size between changelog size vs materialization size

[ https://issues.apache.org/jira/browse/FLINK-25470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479939#comment-17479939 ] Roman Khachatryan commented on FLINK-25470: --- > How much Data Size increases/ex

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25750) Performance regression on 20.01.2021 in globalWindow and stateBackend benchmarks

[ https://issues.apache.org/jira/browse/FLINK-25750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-25750: - Assignee: Roman Khachatryan > Performance regression on 20.01.2021 in globalWin

[GitHub] [flink] flinkbot edited a comment on pull request #18427: [FLINK-25386][table] Harden table persisted plan

flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * a69e8836becd5bbdedd183376c67dae35afc2960 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] fapaul merged pull request #18411: [FLINK-23944][test][pulsar] 1. change the Matcher to validate both size and data 2. pulsar IT test generate deterministic data

fapaul merged pull request #18411: URL: https://github.com/apache/flink/pull/18411 -- 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: issues-unsubscr

[GitHub] [flink] fapaul merged pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

fapaul merged pull request #18288: URL: https://github.com/apache/flink/pull/18288 -- 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: issues-unsubscr

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479944#comment-17479944 ] Fabian Paul commented on FLINK-20188: - Merged in master: 3dbb4974a4d9bd5d77be7b57dde

[GitHub] [flink] fapaul merged pull request #18373: [FLINK-20188][BP 1.14][Connectors][Docs][FileSystem] Added documentation for FileSource

fapaul merged pull request #18373: URL: https://github.com/apache/flink/pull/18373 -- 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: issues-unsubscr

[jira] [Resolved] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul resolved FLINK-20188. - Fix Version/s: 1.14.4 Resolution: Fixed > Add Documentation for new File Source > ---

[jira] [Commented] (FLINK-20188) Add Documentation for new File Source

[ https://issues.apache.org/jira/browse/FLINK-20188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479945#comment-17479945 ] Fabian Paul commented on FLINK-20188: - Merged in release-1.14: 303e3064f27d8d648f6b7

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 6a5494ae1f78bae86a9a5612d4a0e6ab973005db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18427: [FLINK-25386][table] Harden table persisted plan

flinkbot edited a comment on pull request #18427: URL: https://github.com/apache/flink/pull/18427#issuecomment-1017644617 ## CI report: * a69e8836becd5bbdedd183376c67dae35afc2960 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] LadyForest opened a new pull request #18438: [hotfix][filesystem] Fix the typo in InProgressFileWriter

LadyForest opened a new pull request #18438: URL: https://github.com/apache/flink/pull/18438 ## What is the purpose of the change This PR is trivial, nothing but fixing a typo in `InProgressFileWriter` ## Brief changelog `InProgressFileWriter` - a element => an

[GitHub] [flink] zentol commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when

zentol commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789500760 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ priv

[GitHub] [flink] flinkbot commented on pull request #18438: [hotfix][filesystem] Fix the typo in InProgressFileWriter

flinkbot commented on pull request #18438: URL: https://github.com/apache/flink/pull/18438#issuecomment-1018341455 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 pr

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479947#comment-17479947 ] Martijn Visser commented on FLINK-23944: Merged b4fc1c8ab69a6bfaec27d5044d1aef7c

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] zentol commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when

zentol commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789500760 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ priv

[GitHub] [flink] zentol commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when

zentol commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789500760 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ priv

[GitHub] [flink] zentol commented on a change in pull request #18416: [FLINK-25715][clients] Add deployment option (`execution.submit-failed-job-on-application-error`) for submitting a failed job when

zentol commented on a change in pull request #18416: URL: https://github.com/apache/flink/pull/18416#discussion_r789500760 ## File path: flink-clients/src/main/java/org/apache/flink/client/deployment/application/ApplicationDispatcherBootstrap.java ## @@ -266,10 +271,22 @@ priv

[jira] [Assigned] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25740: -- Assignee: Yufei Zhang > PulsarSourceOrderedE2ECase fails on azure > -

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 6a5494ae1f78bae86a9a5612d4a0e6ab973005db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-25740) PulsarSourceOrderedE2ECase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-25740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479948#comment-17479948 ] Martijn Visser commented on FLINK-25740: Merged b4fc1c8ab69a6bfaec27d5044d1aef7c

[GitHub] [flink] flinkbot edited a comment on pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

flinkbot edited a comment on pull request #18394: URL: https://github.com/apache/flink/pull/18394#issuecomment-1015323011 ## CI report: * 7da11c60c656bfab79cf3ae76bc56cc729ae24a6 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18405: [FLINK-25683][streaming-java] wrong result if table transfrom to Data…

flinkbot edited a comment on pull request #18405: URL: https://github.com/apache/flink/pull/18405#issuecomment-1017071379 ## CI report: * cb55e79c59c1d03f8aa3c883a97d55a004a28860 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot commented on pull request #18438: [hotfix][filesystem] Fix the typo in InProgressFileWriter

flinkbot commented on pull request #18438: URL: https://github.com/apache/flink/pull/18438#issuecomment-1018343137 ## CI report: * 4265d8adf7ac94568ba86adf9303300696ec6424 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] afedulov commented on a change in pull request #17598: [FLINK-24703][connectors][formats] Add CSV format support for filesystem based on StreamFormat and BulkWriter interfaces.

afedulov commented on a change in pull request #17598: URL: https://github.com/apache/flink/pull/17598#discussion_r789503305 ## File path: flink-formats/flink-csv/pom.xml ## @@ -77,6 +77,14 @@ under the License. + Review comment: Good

[GitHub] [flink] vahmed-hamdy closed pull request #17907: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

vahmed-hamdy closed pull request #17907: URL: https://github.com/apache/flink/pull/17907 -- 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: issues-un

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 08fa0c4904a5a3712b896210a4d2e224e3f1

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 6a5494ae1f78bae86a9a5612d4a0e6ab973005db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18438: [hotfix][filesystem] Fix the typo in InProgressFileWriter

flinkbot edited a comment on pull request #18438: URL: https://github.com/apache/flink/pull/18438#issuecomment-1018343137 ## CI report: * 4265d8adf7ac94568ba86adf9303300696ec6424 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-25098) Jobmanager CrashLoopBackOff in HA configuration

[ https://issues.apache.org/jira/browse/FLINK-25098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Enrique Lacal updated FLINK-25098: -- Attachment: JM-FlinkException-checkpointHA.txt > Jobmanager CrashLoopBackOff in HA configurati

[GitHub] [flink] LadyForest commented on a change in pull request #18394: [FLINK-25520][Table SQL/API] Implement "ALTER TABLE ... COMPACT" SQL

LadyForest commented on a change in pull request #18394: URL: https://github.com/apache/flink/pull/18394#discussion_r789511549 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/utils/TableTestBase.scala ## @@ -47,21 +53,30 @@ import or

[jira] [Commented] (FLINK-25098) Jobmanager CrashLoopBackOff in HA configuration

[ https://issues.apache.org/jira/browse/FLINK-25098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17479958#comment-17479958 ] Enrique Lacal commented on FLINK-25098: --- Hi [~trohrmann] , I didn't manage to re

[GitHub] [flink] flinkbot edited a comment on pull request #18268: [FLINK-14902][connector] Supports jdbc async lookup join

flinkbot edited a comment on pull request #18268: URL: https://github.com/apache/flink/pull/18268#issuecomment-1005479356 ## CI report: * fe7d298f1ac142a2fa53241df09eaf93b44ec4be Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18169: [FLINK-25277] add shutdown hook to stop TaskExecutor on SIGTERM

flinkbot edited a comment on pull request #18169: URL: https://github.com/apache/flink/pull/18169#issuecomment-998925832 ## CI report: * 35011a0fb8ca36b38d854e88a2937357b8736f4d UNKNOWN * fc7193f9336b272ced363c100517ad4f4f793804 UNKNOWN * 08fa0c4904a5a3712b896210a4d2e224e3f1

[GitHub] [flink] flinkbot edited a comment on pull request #18348: [FLINK-24905][connectors/kinesis] Adding support for Kinesis DataStream sink as kinesis table connector sink.

flinkbot edited a comment on pull request #18348: URL: https://github.com/apache/flink/pull/18348#issuecomment-1011977937 ## CI report: * 6a5494ae1f78bae86a9a5612d4a0e6ab973005db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18437: [FLINK-25712][connector/tests] Merge flink-connector-testing into flink-connector-test-utils

flinkbot edited a comment on pull request #18437: URL: https://github.com/apache/flink/pull/18437#issuecomment-1018174136 ## CI report: * be3d03d337bb7358ee949445f0530a73d02c43dc Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

  1   2   3   4   5   >