[GitHub] [flink] flinkbot edited a comment on pull request #17413: [hotfix][FileSource] internal refactoring to remove duplicated code without API change

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17413: URL: https://github.com/apache/flink/pull/17413#issuecomment-933936118 ## CI report: * 3aef5ddd2cdaaa619d5f1897c9bbaf6004a8c07f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17413: [hotfix][FileSource] internal refactoring to remove duplicated code without API change

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17413: URL: https://github.com/apache/flink/pull/17413#issuecomment-933936118 ## CI report: * 3aef5ddd2cdaaa619d5f1897c9bbaf6004a8c07f Azure:

[GitHub] [flink] flinkbot commented on pull request #17413: [hotfix][FileSource] internal refactoring to remove duplicated code without API change

2021-10-04 Thread GitBox
flinkbot commented on pull request #17413: URL: https://github.com/apache/flink/pull/17413#issuecomment-933936118 ## CI report: * 3aef5ddd2cdaaa619d5f1897c9bbaf6004a8c07f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #17413: [hotfix][FileSource] internal refactoring to remove duplicated code without API change

2021-10-04 Thread GitBox
flinkbot commented on pull request #17413: URL: https://github.com/apache/flink/pull/17413#issuecomment-933925189 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] JingGe opened a new pull request #17413: [hotfix][FileSource] internal refactoring to remove duplicated code without API change

2021-10-04 Thread GitBox
JingGe opened a new pull request #17413: URL: https://github.com/apache/flink/pull/17413 ## What is the purpose of the change This pull request removes the duplicated code for arguments check. ## Brief change log - Consolidate the arguments check in the

[GitHub] [flink] flinkbot edited a comment on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17390: URL: https://github.com/apache/flink/pull/17390#issuecomment-930352446 ## CI report: * 247ed9c283b1e03a0866f488b5c66aef0825dc44 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17407: [FLINK-16504][dynamodb connector] DynamoDB batch connector

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17407: URL: https://github.com/apache/flink/pull/17407#issuecomment-933030338 ## CI report: * 3aab847b61c8afa8de6880204d4db9a9d3e5d625 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * 5dc334a5b4a1fd0ae61fec6654a8502f8c53eb53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 94928a167b2a189c2b3a20bbf5205fdcb016065f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17409: URL: https://github.com/apache/flink/pull/17409#issuecomment-933172900 ## CI report: * 5fdbad619ee531a30eded5563f646e6f82ea1fed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17412: [FLINK-23049][tests] Checkpoint is triggered manually for UnalignedCh…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17412: URL: https://github.com/apache/flink/pull/17412#issuecomment-933637484 ## CI report: * 736aabc438b7fa4f8e67366306eec993ddcd8a02 Azure:

[GitHub] [flink-benchmarks] dawidwys merged pull request #33: [hotfix] Upgrade to scala 2.12

2021-10-04 Thread GitBox
dawidwys merged pull request #33: URL: https://github.com/apache/flink-benchmarks/pull/33 -- 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 #17407: [FLINK-16504][dynamodb connector] DynamoDB batch connector

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17407: URL: https://github.com/apache/flink/pull/17407#issuecomment-933030338 ## CI report: * 77978dcda122768987b06f6178fd3195aa65891c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * Unknown: [CANCELED](TBD) * 5dc334a5b4a1fd0ae61fec6654a8502f8c53eb53 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17390: URL: https://github.com/apache/flink/pull/17390#issuecomment-930352446 ## CI report: * a086dfaf5d3dd7e8e2ba07dc532b405edccf1a00 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17412: [FLINK-23049][tests] Checkpoint is triggered manually for UnalignedCh…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17412: URL: https://github.com/apache/flink/pull/17412#issuecomment-933637484 ## CI report: * 736aabc438b7fa4f8e67366306eec993ddcd8a02 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17407: [FLINK-16504][dynamodb connector] DynamoDB batch connector

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17407: URL: https://github.com/apache/flink/pull/17407#issuecomment-933030338 ## CI report: * 77978dcda122768987b06f6178fd3195aa65891c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17409: URL: https://github.com/apache/flink/pull/17409#issuecomment-933172900 ## CI report: * 3c23c4f883d9bc64ecc6f6a83cc0b6c41e84052f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * Unknown: [CANCELED](TBD) * 5dc334a5b4a1fd0ae61fec6654a8502f8c53eb53 UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] flinkbot edited a comment on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17390: URL: https://github.com/apache/flink/pull/17390#issuecomment-930352446 ## CI report: * 70c10afbaa5c0ec1d7ba181d5bceb48784bdc845 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 18e0e605662773415554f5fa1c1ad7520620ab8e Azure:

[GitHub] [flink-benchmarks] dawidwys opened a new pull request #33: [hotfix] Upgrade to scala 2.12

2021-10-04 Thread GitBox
dawidwys opened a new pull request #33: URL: https://github.com/apache/flink-benchmarks/pull/33 In Flink 1.15 we will drop scala 2.11. Therefore we should upgrade benchmarks to scala 2.12 as well. -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] matriv commented on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
matriv commented on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-933644982 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Commented] (FLINK-24421) Casting from a string to a DATE and TIME allows incomplete strings

2021-10-04 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424018#comment-17424018 ] Marios Trivyzas commented on FLINK-24421: - We checked with calcite-avatica's

[jira] [Issue Comment Deleted] (FLINK-24269) Rename methods around final checkpoints

2021-10-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-24269: --- Comment: was deleted (was: This change looks like it caused a benchmark build failure:

[GitHub] [flink] flinkbot commented on pull request #17412: [FLINK-23049][tests] Checkpoint is triggered manually for UnalignedCh…

2021-10-04 Thread GitBox
flinkbot commented on pull request #17412: URL: https://github.com/apache/flink/pull/17412#issuecomment-933637484 ## CI report: * 736aabc438b7fa4f8e67366306eec993ddcd8a02 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17409: URL: https://github.com/apache/flink/pull/17409#issuecomment-933172900 ## CI report: * 3c23c4f883d9bc64ecc6f6a83cc0b6c41e84052f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17350: [FLINK-24359][table-runtime] Use ResolvedSchema in AbstractFileSystemTable

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17350: URL: https://github.com/apache/flink/pull/17350#issuecomment-926550692 ## CI report: * 18e0e605662773415554f5fa1c1ad7520620ab8e Azure:

[jira] [Commented] (FLINK-24269) Rename methods around final checkpoints

2021-10-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17424014#comment-17424014 ] Piotr Nowojski commented on FLINK-24269: This change looks like it caused a benchmark build

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 70e18ce30aa0dbb1df85d84e35c9dbaeca6ff71f Azure:

[GitHub] [flink] Aitozi commented on pull request #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
Aitozi commented on pull request #17409: URL: https://github.com/apache/flink/pull/17409#issuecomment-933629047 About the naming of `CuratorFrameworkWithUnhandledErrorListener`, I have followed you suggestion but still have some doubts that with the name of `InternalCuratorResource` we

[GitHub] [flink] Aitozi commented on pull request #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
Aitozi commented on pull request #17409: URL: https://github.com/apache/flink/pull/17409#issuecomment-933624516 @tillrohrmann Thanks for your quickly reviewing :) , I have addressed your comments. Regarding to the failure test, I have fixed it only by spying the correct

[jira] [Assigned] (FLINK-24421) Casting from a string to a DATE and TIME allows incomplete strings

2021-10-04 Thread Marios Trivyzas (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marios Trivyzas reassigned FLINK-24421: --- Assignee: Marios Trivyzas > Casting from a string to a DATE and TIME allows

[jira] [Closed] (FLINK-24230) Buffer debloating microbenchmark for single gate

2021-10-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24230. Resolution: Fixed Implemented in 69ead04f3f0e6577e5eae45ed052937e163b1567 > Buffer

[GitHub] [flink] flinkbot edited a comment on pull request #17405: [FLINK-21456][table] Copy DateTimeUtils from avatica-core and introduce StringUtils

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17405: URL: https://github.com/apache/flink/pull/17405#issuecomment-932088993 ## CI report: * fd9c5b4e3f26e20b7621dc1dbb4147e6ae5e8567 UNKNOWN * 3834856a16da89f7317eba8bae25aac80d888665 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17411: [FLINK-17914][hs] Keep archives if listStatus fails

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17411: URL: https://github.com/apache/flink/pull/17411#issuecomment-933425378 ## CI report: * 98aa68599b684b3a96152407046ac052e3337af2 Azure:

[jira] [Closed] (FLINK-24399) Make handling of DataType less verbose

2021-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-24399. Fix Version/s: 1.15.0 Resolution: Fixed Fixed in master: commit

[GitHub] [flink] twalthr closed pull request #17381: [FLINK-24399][table-common] Make handling of DataType less verbose for connector developers

2021-10-04 Thread GitBox
twalthr closed pull request #17381: URL: https://github.com/apache/flink/pull/17381 -- 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 commented on pull request #17412: [FLINK-23049][tests] Checkpoint is triggered manually for UnalignedCh…

2021-10-04 Thread GitBox
flinkbot commented on pull request #17412: URL: https://github.com/apache/flink/pull/17412#issuecomment-933607531 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

[jira] [Created] (FLINK-24448) Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ

2021-10-04 Thread Mehul Batra (Jira)
Mehul Batra created FLINK-24448: --- Summary: Tumbling Window Not working with EPOOCH Time converted using TO_TIMESTAMP_LTZ Key: FLINK-24448 URL: https://issues.apache.org/jira/browse/FLINK-24448 Project:

[jira] [Updated] (FLINK-23049) UnalignedCheckpointCompatibilityITCase hangs on azure

2021-10-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23049: --- Labels: pull-request-available test-stability (was: test-stability) >

[jira] [Commented] (FLINK-24443) IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs fail with output mismatch

2021-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423994#comment-17423994 ] Timo Walther commented on FLINK-24443: -- Test disabled in 9ab85e1d10f0848ce43c01bfdb6788d7288dada7.

[GitHub] [flink] akalash opened a new pull request #17412: [FLINK-23049][tests] Checkpoint is triggered manually for UnalignedCh…

2021-10-04 Thread GitBox
akalash opened a new pull request #17412: URL: https://github.com/apache/flink/pull/17412 …eckpointCompatibilityITCase ## What is the purpose of the change *This PR fixes UnalignedCheckpointCompatibilityITCase* ## Brief change log - *The checkpoint

[GitHub] [flink] Aitozi commented on a change in pull request #17398: [FLINK-24357][tests] Harden ZooKeeperLeaderElectionConnectionHandlingTest

2021-10-04 Thread GitBox
Aitozi commented on a change in pull request #17398: URL: https://github.com/apache/flink/pull/17398#discussion_r721476412 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionConnectionHandlingTest.java ## @@ -131,7 +130,8

[GitHub] [flink] tillrohrmann commented on a change in pull request #17240: [FLINK-24255][tests] Test environments respect configuration when being instantiated

2021-10-04 Thread GitBox
tillrohrmann commented on a change in pull request #17240: URL: https://github.com/apache/flink/pull/17240#discussion_r721469849 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/MiniClusterPipelineExecutorServiceLoader.java ## @@

[jira] [Commented] (FLINK-9465) Specify a separate savepoint timeout option via CLI

2021-10-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423992#comment-17423992 ] Till Rohrmann commented on FLINK-9465: -- Do you want to add the parameter as a query parameter or

[GitHub] [flink] tillrohrmann commented on a change in pull request #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
tillrohrmann commented on a change in pull request #17409: URL: https://github.com/apache/flink/pull/17409#discussion_r721435775 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/InternalCuratorResource.java ## @@ -0,0 +1,51 @@ +/*

[jira] [Commented] (FLINK-24443) IntervalJoinITCase.testRowTimeInnerJoinWithEquiTimeAttrs fail with output mismatch

2021-10-04 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423985#comment-17423985 ] Timo Walther commented on FLINK-24443: -- [~slinkydeveloper] it seems the test is unstable. Can you

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * e144e131c041cc6cbd232ef4cfe6a00fe3710813 Azure:

[jira] [Assigned] (FLINK-24437) Remove unhandled exception handler from CuratorFramework before closing it

2021-10-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-24437: - Assignee: Aitozi > Remove unhandled exception handler from CuratorFramework before

[jira] [Commented] (FLINK-19903) Allow to read metadata in filesystem connector

2021-10-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423966#comment-17423966 ] Francesco Guardiani commented on FLINK-19903: - Hi, I'm taking over this issue. > Allow to

[jira] [Assigned] (FLINK-19903) Allow to read metadata in filesystem connector

2021-10-04 Thread Francesco Guardiani (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Francesco Guardiani reassigned FLINK-19903: --- Assignee: Francesco Guardiani > Allow to read metadata in filesystem

[GitHub] [flink] flinkbot edited a comment on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17390: URL: https://github.com/apache/flink/pull/17390#issuecomment-930352446 ## CI report: * 70c10afbaa5c0ec1d7ba181d5bceb48784bdc845 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #17105: [FLINK-23704][streaming] FLIP-27 sources are not generating LatencyMarkers

2021-10-04 Thread GitBox
pnowojski commented on a change in pull request #17105: URL: https://github.com/apache/flink/pull/17105#discussion_r721321681 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java ## @@ -478,4 +505,79 @@ public void

[jira] [Closed] (FLINK-24269) Rename methods around final checkpoints

2021-10-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-24269. Resolution: Implemented Implemented in: * master **

[GitHub] [flink] flinkbot edited a comment on pull request #17410: [FLINK-24445][build] Copy rpc-akka jar in package phase

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17410: URL: https://github.com/apache/flink/pull/17410#issuecomment-933317819 ## CI report: * 6f093536dfb23f1a6b1702d2325c41fb07b07884 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17405: [FLINK-21456][table] Copy DateTimeUtils from avatica-core and introduce StringUtils

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17405: URL: https://github.com/apache/flink/pull/17405#issuecomment-932088993 ## CI report: * fd9c5b4e3f26e20b7621dc1dbb4147e6ae5e8567 UNKNOWN * 173ae8a45161d09b10ed7af8c1dbb76ec2c325f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17390: URL: https://github.com/apache/flink/pull/17390#issuecomment-930352446 ## CI report: * 2beaec046fdd5490740a67b4a1a7b3f7730f62b3 Azure:

[jira] [Updated] (FLINK-24447) Bundle netty in flink-shaded-zookeeper 3.5+

2021-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24447: - Summary: Bundle netty in flink-shaded-zookeeper 3.5+ (was: Bundle netty in

[jira] [Created] (FLINK-24447) Bundle netty in flink-shade-zookeeper 3.5+

2021-10-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-24447: Summary: Bundle netty in flink-shade-zookeeper 3.5+ Key: FLINK-24447 URL: https://issues.apache.org/jira/browse/FLINK-24447 Project: Flink Issue

[GitHub] [flink] dawidwys closed pull request #17316: [FLINK-24269][Runtime / Checkpointing] Rename methods around final ch…

2021-10-04 Thread GitBox
dawidwys closed pull request #17316: URL: https://github.com/apache/flink/pull/17316 -- 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] matriv commented on a change in pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
matriv commented on a change in pull request #17396: URL: https://github.com/apache/flink/pull/17396#discussion_r721341645 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -18,176 +18,905 @@

[GitHub] [flink] matriv commented on a change in pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
matriv commented on a change in pull request #17396: URL: https://github.com/apache/flink/pull/17396#discussion_r721340864 ## File path: flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/CastFunctionITCase.java ## @@ -18,176 +18,905 @@

[GitHub] [flink] zentol commented on a change in pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
zentol commented on a change in pull request #17390: URL: https://github.com/apache/flink/pull/17390#discussion_r721336257 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java ## @@ -183,4 +118,90 @@ public R getRequestBody() {

[GitHub] [flink-web] NicoK closed pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-10-04 Thread GitBox
NicoK closed pull request #472: URL: https://github.com/apache/flink-web/pull/472 -- 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-web] NicoK merged pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-10-04 Thread GitBox
NicoK merged pull request #472: URL: https://github.com/apache/flink-web/pull/472 -- 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-web] NicoK commented on pull request #472: [hotfix] minor fixes and improvements in the 1.14 release post

2021-10-04 Thread GitBox
NicoK commented on pull request #472: URL: https://github.com/apache/flink-web/pull/472#issuecomment-933449901 Thanks @pnowojski and @infoverload for your reviews, I applied the changes and will merge -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #17405: [FLINK-21456][table] Copy DateTimeUtils from avatica-core and introduce StringUtils

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17405: URL: https://github.com/apache/flink/pull/17405#issuecomment-932088993 ## CI report: * fd9c5b4e3f26e20b7621dc1dbb4147e6ae5e8567 UNKNOWN * 173ae8a45161d09b10ed7af8c1dbb76ec2c325f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17411: [FLINK-17914][hs] Keep archives if listStatus fails

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17411: URL: https://github.com/apache/flink/pull/17411#issuecomment-933425378 ## CI report: * 98aa68599b684b3a96152407046ac052e3337af2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 0e54cbec07f6d8c188b660e3fadd68f70dafb445 Azure:

[GitHub] [flink] nicoweidner commented on a change in pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
nicoweidner commented on a change in pull request #17390: URL: https://github.com/apache/flink/pull/17390#discussion_r721315044 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java ## @@ -183,4 +118,90 @@ public R

[GitHub] [flink] nicoweidner commented on a change in pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
nicoweidner commented on a change in pull request #17390: URL: https://github.com/apache/flink/pull/17390#discussion_r721315044 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java ## @@ -183,4 +118,90 @@ public R

[GitHub] [flink] nicoweidner commented on a change in pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
nicoweidner commented on a change in pull request #17390: URL: https://github.com/apache/flink/pull/17390#discussion_r721309172 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlers.java ## @@ -120,8 +120,10 @@ public static

[GitHub] [flink] zentol commented on a change in pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
zentol commented on a change in pull request #17390: URL: https://github.com/apache/flink/pull/17390#discussion_r721324197 ## File path: flink-runtime-web/src/test/java/org/apache/flink/runtime/webmonitor/handlers/JarHandlers.java ## @@ -120,8 +120,10 @@ public static String

[GitHub] [flink] AHeise commented on a change in pull request #17406: [FLINK-24405][tests] Introduce util to reliably drain all messages from a kafka topic

2021-10-04 Thread GitBox
AHeise commented on a change in pull request #17406: URL: https://github.com/apache/flink/pull/17406#discussion_r721318188 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaUtil.java ## @@ -0,0 +1,116 @@ +/* + *

[GitHub] [flink-training] NicoK merged pull request #41: [hotfix] remove extraneous files for non-existing modules

2021-10-04 Thread GitBox
NicoK merged pull request #41: URL: https://github.com/apache/flink-training/pull/41 -- 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] nicoweidner commented on a change in pull request #17390: [FLINK-24275][rest] Idempotent job cancellation

2021-10-04 Thread GitBox
nicoweidner commented on a change in pull request #17390: URL: https://github.com/apache/flink/pull/17390#discussion_r721292429 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/HandlerRequest.java ## @@ -183,4 +118,90 @@ public R

[GitHub] [flink] AHeise commented on pull request #17363: [FLINK-24324][connectors/elasticsearch] Add Elasticsearch 7 sink based on FLIP-143

2021-10-04 Thread GitBox
AHeise commented on pull request #17363: URL: https://github.com/apache/flink/pull/17363#issuecomment-933429258 Could you adjust the title to something for user-friendly? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] AHeise commented on a change in pull request #17367: [FLINK-24382][metrics] Do not compute recordsOut metric in SinkOperat…

2021-10-04 Thread GitBox
AHeise commented on a change in pull request #17367: URL: https://github.com/apache/flink/pull/17367#discussion_r721306027 ## File path: flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/sink/writer/FileWriter.java ## @@ -85,17 +86,21 @@

[GitHub] [flink] flinkbot commented on pull request #17411: [FLINK-17914][hs] Keep archives if listStatus fails

2021-10-04 Thread GitBox
flinkbot commented on pull request #17411: URL: https://github.com/apache/flink/pull/17411#issuecomment-933425378 ## CI report: * 98aa68599b684b3a96152407046ac052e3337af2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #17405: [FLINK-21456][table] Copy DateTimeUtils from avatica-core and introduce StringUtils

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17405: URL: https://github.com/apache/flink/pull/17405#issuecomment-932088993 ## CI report: * fd9c5b4e3f26e20b7621dc1dbb4147e6ae5e8567 UNKNOWN * 173ae8a45161d09b10ed7af8c1dbb76ec2c325f5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 0e54cbec07f6d8c188b660e3fadd68f70dafb445 Azure:

[jira] [Commented] (FLINK-24339) Remove guard against CRLF split across chunks

2021-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17423906#comment-17423906 ] Chesnay Schepler commented on FLINK-24339: -- The fix will supposedly be included in 4.1.69. >

[GitHub] [flink] flinkbot commented on pull request #17411: [FLINK-17914][hs] Keep archives if listStatus fails

2021-10-04 Thread GitBox
flinkbot commented on pull request #17411: URL: https://github.com/apache/flink/pull/17411#issuecomment-933411559 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

[jira] [Updated] (FLINK-17914) HistoryServer deletes archives if archive listing fails

2021-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17914: - Fix Version/s: 1.14.1 1.15.0 1.13.3 >

[jira] [Updated] (FLINK-17914) HistoryServer deletes cached archives if archive listing fails

2021-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17914: - Summary: HistoryServer deletes cached archives if archive listing fails (was:

[jira] [Updated] (FLINK-17914) HistoryServer deletes archives if archive listing fails

2021-10-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-17914: - Summary: HistoryServer deletes archives if archive listing fails (was:

[jira] [Updated] (FLINK-17914) HistoryServerTest.testCleanExpiredJob:158->runArchiveExpirationTest:214 expected:<2> but was:<0>

2021-10-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17914: --- Labels: pull-request-available (was: ) >

[GitHub] [flink] zentol opened a new pull request #17411: [FLINK-17914][hs] Keep archives if listStatus fails

2021-10-04 Thread GitBox
zentol opened a new pull request #17411: URL: https://github.com/apache/flink/pull/17411 Fixes an issue where the HistoryServer was wiping archives if the listing of archives failed (e.g., due to a concurrent deletion of an archive). This could result in all locally cached archived

[GitHub] [flink] CrynetLogistics edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-04 Thread GitBox
CrynetLogistics edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-933406220 **Comment From Nuno** `KinesisDataStreamsSinkConfig` Should we change the variable `DEFAULT_MAX_TimeInBufferMS` to `DEFAULT_MAX_TIME_IN_BUFFER_MS`?

[GitHub] [flink] CrynetLogistics edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-04 Thread GitBox
CrynetLogistics edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-933406220 Comment From Nuno `KinesisDataStreamsSinkConfig` Should we change the variable `DEFAULT_MAX_TimeInBufferMS` to `DEFAULT_MAX_TIME_IN_BUFFER_MS`?

[GitHub] [flink] CrynetLogistics commented on pull request #17345: [FLINK-24227][connectors] FLIP-171: Added Kinesis Data Streams Sink i…

2021-10-04 Thread GitBox
CrynetLogistics commented on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-933406220 Comment From Nuno `KinesisDataStreamsSinkConfig` Should we change the variable `DEFAULT_MAX_TimeInBufferMS` to `DEFAULT_MAX_TIME_IN_BUFFER_MS`?

[GitHub] [flink] flinkbot edited a comment on pull request #17405: [FLINK-21456][table] Copy DateTimeUtils from avatica-core and introduce StringUtils

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17405: URL: https://github.com/apache/flink/pull/17405#issuecomment-932088993 ## CI report: * cce71e81000ea574af40d262c3489cb3b8e5b473 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * 446362585c664a26aeedf7864f1639134eb90fa9 Azure:

[GitHub] [flink-training] NicoK opened a new pull request #41: [hotfix] remove extraneous files for non-existing modules

2021-10-04 Thread GitBox
NicoK opened a new pull request #41: URL: https://github.com/apache/flink-training/pull/41 Unfortunately, I merged these extra files with #24 which do not belong to any submodule here. This PR removes them again, leaving a cleaner source checkout. -- This is an automated message from

[jira] [Closed] (FLINK-23653) improve training exercises and tests so they are better examples

2021-10-04 Thread Nico Kruber (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-23653. --- Fix Version/s: 1.13.3 Resolution: Fixed Fixed on master via

[GitHub] [flink-benchmarks] dawidwys merged pull request #32: [FLINK-24230] Buffer debloating microbenchmark for single gate

2021-10-04 Thread GitBox
dawidwys merged pull request #32: URL: https://github.com/apache/flink-benchmarks/pull/32 -- 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 #17409: [FLINK-24437][HA]Remove unhandled exception handler from CuratorFrame…

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17409: URL: https://github.com/apache/flink/pull/17409#issuecomment-933172900 ## CI report: * 3c23c4f883d9bc64ecc6f6a83cc0b6c41e84052f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17405: [FLINK-21456][table] Copy DateTimeUtils from avatica-core and introduce StringUtils

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17405: URL: https://github.com/apache/flink/pull/17405#issuecomment-932088993 ## CI report: * 04dfe21ba6a525858c670e75b3fbf2a9985f80e6 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17396: [FLINK-24393][test] Add CAST tests for type combinations

2021-10-04 Thread GitBox
flinkbot edited a comment on pull request #17396: URL: https://github.com/apache/flink/pull/17396#issuecomment-931316432 ## CI report: * 446362585c664a26aeedf7864f1639134eb90fa9 Azure:

  1   2   >