[GitHub] [flink] pnowojski commented on pull request #16628: [FLINK-23453][streaming] Created the buffer size calculator for the ability to automatically change the buffer size based on the throughput

2021-08-03 Thread GitBox
pnowojski commented on pull request #16628: URL: https://github.com/apache/flink/pull/16628#issuecomment-891958262 Thanks for the update. Could you maybe squash the commits before the final pass? -- This is an automated message from the Apache Git Service. To respond to the message, plea

[GitHub] [flink] flinkbot edited a comment on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891705792 ## CI report: * f7b6b4f40bdbbe148be7b5d59dd1307e1af99e57 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16689: [FLINK-21290][table-planner] Support project push down for window TVF.

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16689: URL: https://github.com/apache/flink/pull/16689#issuecomment-891706045 ## CI report: * c4d0e9cdfb13e7ad24f2631629eea291bf47ed60 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * 6287ea41e01d215a3974dca0ae037537a7f3d4bb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16654: [FLINK-23492][runtime] harden testCachedStatsCleanedAfterCleanupInterval

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16654: URL: https://github.com/apache/flink/pull/16654#issuecomment-890035133 ## CI report: * 540883274c16e5b0c97f93674fc2d24c14f26c7d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16688: [FLINK-22773][coordination] Optimize the construction of pipelined regions

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16688: URL: https://github.com/apache/flink/pull/16688#issuecomment-891705944 ## CI report: * 43208da2eb35e121e75d68c5f291722155383f81 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16652: URL: https://github.com/apache/flink/pull/16652#issuecomment-889863499 ## CI report: * bec31db7e5954054997b68fc2eaceb3556ea7200 UNKNOWN * c9149e8af1cdef4b615c7c83a3dc69054ddbdaae Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-889045676 ## CI report: * 46332f2c7aa2e4d4b6489f94eccdd866fbea79f1 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16626: [FLINK-23498][table] Introduce a full PlannerConfiguration

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16626: URL: https://github.com/apache/flink/pull/16626#issuecomment-888274470 ## CI report: * b7a07005f53c491bbd2eb9437c479ef31581bf2a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * ae9a98b727dba02d7aa7e9ff8f58cde9d75f8598 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-878058026 ## CI report: * 758e058554d003959bb42ca3988a306389e1b9d3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zhuzhurk commented on a change in pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

2021-08-03 Thread GitBox
zhuzhurk commented on a change in pull request #16679: URL: https://github.com/apache/flink/pull/16679#discussion_r681877463 ## File path: flink-core/src/main/java/org/apache/flink/api/common/BatchShuffleMode.java ## @@ -41,7 +41,7 @@ * to run upstream and downstream tasks s

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN * d326abc93378bb3c4b53616e7717c409d987

[jira] [Commented] (FLINK-23317) Only keep the latest checkpoint in CompletedCheckpointStore

2021-08-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392363#comment-17392363 ] Till Rohrmann commented on FLINK-23317: --- I am not sure whether this improvement ju

[GitHub] [flink] gaborgsomogyi edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
gaborgsomogyi edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days, please see [this](https://g

[GitHub] [flink] gaborgsomogyi edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
gaborgsomogyi edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days (I don't thing renew worth t

[GitHub] [flink] gaborgsomogyi edited a comment on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
gaborgsomogyi edited a comment on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days (I don't thing renew worth t

[GitHub] [flink] gaborgsomogyi commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
gaborgsomogyi commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891938008 As I see this is not solving 2 major issues which belongs to this area: * DTs not re-obtained which makes workloads fail after 7 days (I don't thing renew worth the hass

[GitHub] [flink] twalthr commented on a change in pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

2021-08-03 Thread GitBox
twalthr commented on a change in pull request #16679: URL: https://github.com/apache/flink/pull/16679#discussion_r681864349 ## File path: flink-core/src/main/java/org/apache/flink/api/common/BatchShuffleMode.java ## @@ -41,7 +41,7 @@ * to run upstream and downstream tasks si

[GitHub] [flink] godfreyhe commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-03 Thread GitBox
godfreyhe commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r681731759 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -128,32 +155,16

[GitHub] [flink] flinkbot edited a comment on pull request #16688: [FLINK-22773][coordination] Optimize the construction of pipelined regions

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16688: URL: https://github.com/apache/flink/pull/16688#issuecomment-891705944 ## CI report: * 43208da2eb35e121e75d68c5f291722155383f81 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891705792 ## CI report: * f7b6b4f40bdbbe148be7b5d59dd1307e1af99e57 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * 6287ea41e01d215a3974dca0ae037537a7f3d4bb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 014925a112fb27200e11defad7d698a2f13c2c8f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16652: URL: https://github.com/apache/flink/pull/16652#issuecomment-889863499 ## CI report: * bec31db7e5954054997b68fc2eaceb3556ea7200 UNKNOWN * c9149e8af1cdef4b615c7c83a3dc69054ddbdaae Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16636: [FLINK-23529] Add Flink 1.13 MigrationVersion

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16636: URL: https://github.com/apache/flink/pull/16636#issuecomment-889045676 ## CI report: * e9e38d1691adb5e17daee075ef97a11f83278d4c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #16626: [FLINK-23498][table] Introduce a full PlannerConfiguration

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16626: URL: https://github.com/apache/flink/pull/16626#issuecomment-888274470 ## CI report: * b7a07005f53c491bbd2eb9437c479ef31581bf2a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] gaborgsomogyi commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
gaborgsomogyi commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891919782 @tillrohrmann Thanks for pinging, this is definitely interesting topic because proper DT handling is a key feature to many ppls including us. @JackWangCS since this

[GitHub] [flink] Thesharing commented on pull request #16688: [FLINK-22773][coordination] Optimize the construction of pipelined regions

2021-08-03 Thread GitBox
Thesharing commented on pull request #16688: URL: https://github.com/apache/flink/pull/16688#issuecomment-891919089 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] flinkbot edited a comment on pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16523: URL: https://github.com/apache/flink/pull/16523#issuecomment-881941982 ## CI report: * ae9a98b727dba02d7aa7e9ff8f58cde9d75f8598 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] Thesharing commented on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

2021-08-03 Thread GitBox
Thesharing commented on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891918659 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] flinkbot edited a comment on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-878058026 ## CI report: * 758e058554d003959bb42ca3988a306389e1b9d3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN * d326abc93378bb3c4b53616e7717c409d987

[GitHub] [flink] flinkbot edited a comment on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891870165 ## CI report: * dcebe54c19ee58530db300a6919e9c43589a6753 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-891870309 ## CI report: * 17de24375718fd602b26c77a8428b89ac8c8bb9d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16693: URL: https://github.com/apache/flink/pull/16693#issuecomment-891870243 ## CI report: * f44a2c2b644a85c2685ad4cd65e820bc65c20b62 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * d18ceb9ff7ec9aa53cda4a1d29cb104c4aab91d2 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16658: [FLINK-23560][streaming] Replaced systemTimerService by timerService for launching the throughput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16658: URL: https://github.com/apache/flink/pull/16658#issuecomment-890336326 ## CI report: * 014925a112fb27200e11defad7d698a2f13c2c8f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Comment Edited] (FLINK-23593) Performance regression on 15.07.2021

2021-08-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392337#comment-17392337 ] Timo Walther edited comment on FLINK-23593 at 8/3/21, 2:35 PM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16650: URL: https://github.com/apache/flink/pull/16650#issuecomment-889769193 ## CI report: * 307eba2a3d948c98bf5fdb358734a5f7173ef070 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-17597 ## CI report: * 5b6bb3991aceb44fd454d6b4fe6665ed8298166b Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * e6b0b05fadd9d6724a424c313a7b9617a854955f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16551: [FLINK-23255][test] Introduce JUnit 5 dependencies

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16551: URL: https://github.com/apache/flink/pull/16551#issuecomment-883977463 ## CI report: * 58f4488addd2d970403e2401f3bf105d0c1b1d9f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-878058026 ## CI report: * 758e058554d003959bb42ca3988a306389e1b9d3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23593) Performance regression on 15.07.2021

2021-08-03 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392337#comment-17392337 ] Timo Walther commented on FLINK-23593: -- I performed a couple of benchmarks locally

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-803430086 ## CI report: * 04da1862ec1f107c74017283c916229b560d9731 UNKNOWN * 4dcee9f07135401160aae3f0d01bd480630f808f UNKNOWN * d326abc93378bb3c4b53616e7717c409d987

[jira] [Commented] (FLINK-23557) 'Resuming Externalized Checkpoint (hashmap, sync, no parallelism change) end-to-end test' fails on Azure

2021-08-03 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392334#comment-17392334 ] Robert Metzger commented on FLINK-23557: The issue most likely started occurring

[GitHub] [flink] tillrohrmann commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
tillrohrmann commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891889399 cc @gaborgsomogyi. Maybe you can help with this effort. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] fapaul commented on a change in pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

2021-08-03 Thread GitBox
fapaul commented on a change in pull request #16676: URL: https://github.com/apache/flink/pull/16676#discussion_r681803300 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -78,6 +78,18 @@ under the License. ${kafka.version}

[GitHub] [flink] KarlManong commented on a change in pull request #16674: [FLINK-23587][deployment] Set Deployment's Annotation when using kubernetes

2021-08-03 Thread GitBox
KarlManong commented on a change in pull request #16674: URL: https://github.com/apache/flink/pull/16674#discussion_r681798155 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/factory/KubernetesJobManagerFactory.java ## @@ -106,6 +106,7 @@ pr

[GitHub] [flink] rkhachatryan commented on a change in pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

2021-08-03 Thread GitBox
rkhachatryan commented on a change in pull request #16523: URL: https://github.com/apache/flink/pull/16523#discussion_r681797951 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ## @@ -1435,8 +1437,18 @@ private boolean transitio

[GitHub] [flink] fapaul commented on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
fapaul commented on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891879866 @RainerMatthiasS We also discussed testing it briefly and came to the conclusion that relying on the fragile reflection logic in the first place is already not ideal but adding m

[GitHub] [flink] tsreaper commented on a change in pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window in plan.

2021-08-03 Thread GitBox
tsreaper commented on a change in pull request #16669: URL: https://github.com/apache/flink/pull/16669#discussion_r681794126 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/SqlSessionTableFunction.java ## @@ -0,0 +1,69 @

[GitHub] [flink] yulei0824 edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
yulei0824 edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-891834559 @zentol There is a problem in SQLClientSchemaRegistryITCase. (https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=21380&view=logs&j=c88eea3b-64

[GitHub] [flink] syhily commented on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

2021-08-03 Thread GitBox
syhily commented on pull request #15304: URL: https://github.com/apache/flink/pull/15304#issuecomment-891876684 @AHeise Can you start the second review? -- 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

[GitHub] [flink] RainerMatthiasS commented on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
RainerMatthiasS commented on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891875270 Thanks Fabian, this is the change I wanted to propose. I'm not aware how in Flink community we check for regressions, given that there is no specific test yet that cover

[jira] [Created] (FLINK-23606) Add safety guards in StreamTask(s) if a global failover for a synchronous savepoint should've happen

2021-08-03 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23606: Summary: Add safety guards in StreamTask(s) if a global failover for a synchronous savepoint should've happen Key: FLINK-23606 URL: https://issues.apache.org/jira/browse/F

[jira] [Updated] (FLINK-23553) Trigger global failover for synchronous savepoints

2021-08-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23553: - Description: We should trigger a global job failover in case of a {{stop-with-savepoint

[jira] [Updated] (FLINK-23553) Trigger global failover for synchronous savepoints on CheckpointCoordinator

2021-08-03 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-23553: - Summary: Trigger global failover for synchronous savepoints on CheckpointCoordinator (w

[GitHub] [flink] tillrohrmann commented on pull request #14841: [FLINK-21232][YARN][Common] Introduce pluggable Hadoop delegation token providers

2021-08-03 Thread GitBox
tillrohrmann commented on pull request #14841: URL: https://github.com/apache/flink/pull/14841#issuecomment-891870529 Sorry for the slow response @JackWangCS. At the moment, I don't have time for it unfortunately because of the upcoming feature freeze. I probably won't be able to help unti

[GitHub] [flink] flinkbot commented on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891870165 ## CI report: * dcebe54c19ee58530db300a6919e9c43589a6753 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-891870309 ## CI report: * 17de24375718fd602b26c77a8428b89ac8c8bb9d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16693: URL: https://github.com/apache/flink/pull/16693#issuecomment-891870243 ## CI report: * f44a2c2b644a85c2685ad4cd65e820bc65c20b62 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16691: [FLINK-16200][table] Introduce JSON_EXISTS to Table API & SQL

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16691: URL: https://github.com/apache/flink/pull/16691#issuecomment-891851095 ## CI report: * 04c6f36ee2417c8354cd73a207e7b15bc9973a64 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16686: [FLINK-23599] Remove JobVertex#connectIdInput

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16686: URL: https://github.com/apache/flink/pull/16686#issuecomment-891705792 ## CI report: * f7b6b4f40bdbbe148be7b5d59dd1307e1af99e57 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16679: [FLINK-23402][streaming-java] Simplify shuffle mode for batch execution

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16679: URL: https://github.com/apache/flink/pull/16679#issuecomment-891160011 ## CI report: * 6f1e2773940a4657d6072f1f888ec63a590b66e1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window in plan.

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16650: URL: https://github.com/apache/flink/pull/16650#issuecomment-889769193 ## CI report: * 307eba2a3d948c98bf5fdb358734a5f7173ef070 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

2021-08-03 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392320#comment-17392320 ] Till Rohrmann commented on FLINK-23449: --- Updating/extending the documentation make

[jira] [Created] (FLINK-23605) An exception was thrown when the metric was reported by PrometheusPushGatewayReporter

2021-08-03 Thread JasonLee (Jira)
JasonLee created FLINK-23605: Summary: An exception was thrown when the metric was reported by PrometheusPushGatewayReporter Key: FLINK-23605 URL: https://issues.apache.org/jira/browse/FLINK-23605 Project

[GitHub] [flink] flinkbot edited a comment on pull request #16598: [FLINK-23501][GCP PubSub] add table source API for GCP PubSub

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16598: URL: https://github.com/apache/flink/pull/16598#issuecomment-886655820 ## CI report: * e6b0b05fadd9d6724a424c313a7b9617a854955f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN * c679fefa6bc59735ea1fb7f3ed6a5cd74685

[GitHub] [flink] yulei0824 commented on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
yulei0824 commented on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-891868779 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] flinkbot edited a comment on pull request #16551: [FLINK-23255][test] Introduce JUnit 5 dependencies

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16551: URL: https://github.com/apache/flink/pull/16551#issuecomment-883977463 ## CI report: * 58f4488addd2d970403e2401f3bf105d0c1b1d9f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #16523: [FLINK-23416][runtime] Don't log NoResourceAvailableException stacktrace

2021-08-03 Thread GitBox
tillrohrmann commented on a change in pull request #16523: URL: https://github.com/apache/flink/pull/16523#discussion_r681782400 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java ## @@ -1435,8 +1437,18 @@ private boolean transitio

[GitHub] [flink] PatrickRen commented on pull request #16551: [FLINK-23255][test] Introduce JUnit 5 dependencies

2021-08-03 Thread GitBox
PatrickRen commented on pull request #16551: URL: https://github.com/apache/flink/pull/16551#issuecomment-891863539 Thanks for the review @AHeise ! Sorry for misunderstanding the usage of ```junit-jupiter-migrationsupport```. I have removed them in the latest commit. About v

[GitHub] [flink] flinkbot commented on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-891859279 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 pro

[jira] [Commented] (FLINK-22405) Support fixed-lengh chars in the LeadLag built-in function

2021-08-03 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392308#comment-17392308 ] liwei li commented on FLINK-22405: -- In contrast to last time,I created a LeadLagAggFunc

[GitHub] [flink] flinkbot commented on pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16693: URL: https://github.com/apache/flink/pull/16693#issuecomment-891857441 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 pro

[GitHub] [flink] fapaul opened a new pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
fapaul opened a new pull request #16694: URL: https://github.com/apache/flink/pull/16694 Unchanged backport of #16692 -- 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 un

[GitHub] [flink] flinkbot commented on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
flinkbot commented on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891855614 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 pro

[GitHub] [flink-shaded] tillrohrmann commented on issue #99: force-shading source

2021-08-03 Thread GitBox
tillrohrmann commented on issue #99: URL: https://github.com/apache/flink-shaded/issues/99#issuecomment-891854452 I think the problem is that force-shading does not contain any sources. If you look at the project, then you see that it only contains the `pom.xml`. -- This is an automated

[GitHub] [flink] fapaul opened a new pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
fapaul opened a new pull request #16693: URL: https://github.com/apache/flink/pull/16693 Unchanged backport of #16692 -- 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 u

[jira] [Updated] (FLINK-23509) FlinkKafkaInternalProducer overrides static final ProducerIdAndEpoch#NONE during transaction recovery (fails)

2021-08-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23509: --- Labels: pull-request-available (was: ) > FlinkKafkaInternalProducer overrides static final

[GitHub] [flink] fapaul opened a new pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-03 Thread GitBox
fapaul opened a new pull request #16692: URL: https://github.com/apache/flink/pull/16692 …suming Kafka transaction ## What is the purpose of the change Before this change we did not create a new ProducerIdAndEpoch and rather mutated the already created one. T

[GitHub] [flink] flinkbot commented on pull request #16691: [FLINK-16200][table] Introduce JSON_EXISTS to Table API & SQL

2021-08-03 Thread GitBox
flinkbot commented on pull request #16691: URL: https://github.com/apache/flink/pull/16691#issuecomment-891851095 ## CI report: * 04c6f36ee2417c8354cd73a207e7b15bc9973a64 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #16669: [FLINK-23544][table-planner]Window TVF Supports session window in plan.

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16669: URL: https://github.com/apache/flink/pull/16669#issuecomment-890847741 ## CI report: * d64b410bf3ec0d97369c1daf60a27fd13bb9cc72 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16650: URL: https://github.com/apache/flink/pull/16650#issuecomment-889769193 ## CI report: * 307eba2a3d948c98bf5fdb358734a5f7173ef070 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16655: [FLINK-23512][runtime][checkpoint] Check for illegal modifications of JobGraph with partially finished operators

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16655: URL: https://github.com/apache/flink/pull/16655#issuecomment-890307289 ## CI report: * 621aa3b457bcab04b36828f8409c89289d867fd1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16645: URL: https://github.com/apache/flink/pull/16645#issuecomment-889643808 ## CI report: * cbbae90ac287c25df1d73ca53c6ece3a1032bf7d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16589: [FLINK-23541] Call StreamOperator#finish on EndOfData

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16589: URL: https://github.com/apache/flink/pull/16589#issuecomment-886429447 ## CI report: * 791a3f1825b2e2d5682c40e9b7e52a4cbc576429 UNKNOWN * a29a6115a578c543a9856a07d0ef58f79ebcc895 UNKNOWN * c679fefa6bc59735ea1fb7f3ed6a5cd74685

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

2021-08-03 Thread GitBox
flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 ## CI report: * 36cfdc4abcad6028059c134f323e963d455921e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-23593) Performance regression on 15.07.2021

2021-08-03 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392298#comment-17392298 ] Piotr Nowojski commented on FLINK-23593: {quote} I'd like to understand why the

[GitHub] [flink] hililiwei commented on a change in pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-03 Thread GitBox
hililiwei commented on a change in pull request #16650: URL: https://github.com/apache/flink/pull/16650#discussion_r681753079 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala ## @@ -366,7 +366,7 @@

[GitHub] [flink] hililiwei commented on a change in pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-03 Thread GitBox
hililiwei commented on a change in pull request #16650: URL: https://github.com/apache/flink/pull/16650#discussion_r681753079 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala ## @@ -366,7 +366,7 @@

[jira] [Commented] (FLINK-23603) 动态查询sql后,使用toAppendStream将动态表转化为流时报错,org.apache.flink.table.api.TableException

2021-08-03 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392293#comment-17392293 ] Ingo Bürk commented on FLINK-23603: --- [~liuhong] Could you please translate the issue t

<    1   2   3   4   5   6   >