[jira] [Reopened] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren reopened FLINK-26037: --- > TaskManagerRunnerTest JVM crash with exit code 239 >

[jira] [Updated] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-26037: -- Affects Version/s: 1.17.0 > TaskManagerRunnerTest JVM crash with exit code 239 >

[jira] [Commented] (FLINK-26037) TaskManagerRunnerTest JVM crash with exit code 239

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629260#comment-17629260 ] Qingsheng Ren commented on FLINK-26037: ---

[jira] [Commented] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629257#comment-17629257 ] Qingsheng Ren commented on FLINK-29898: --- [~wangyang0918] Any thought on his one? >

[jira] [Created] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI

2022-11-04 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-29898: - Summary: ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI Key: FLINK-29898 URL: https://issues.apache.org/jira/browse/FLINK-29898

[jira] [Commented] (FLINK-27916) HybridSourceReaderTest.testReader failed with AssertionError

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629256#comment-17629256 ] Qingsheng Ren commented on FLINK-27916: ---

[jira] [Updated] (FLINK-29897) PyFlinkStreamUserDefinedFunctionTests.test_table_function fails on CI

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-29897: -- Description: Link: 

[jira] [Commented] (FLINK-29405) InputFormatCacheLoaderTest is unstable

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629255#comment-17629255 ] Qingsheng Ren commented on FLINK-29405: ---

[jira] [Commented] (FLINK-29897) PyFlinkStreamUserDefinedFunctionTests.test_table_function fails on CI

2022-11-04 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629254#comment-17629254 ] Qingsheng Ren commented on FLINK-29897: --- [~hxbks2ks] Any thought on this one? >

[jira] [Created] (FLINK-29897) PyFlinkStreamUserDefinedFunctionTests.test_table_function fails on CI

2022-11-04 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-29897: - Summary: PyFlinkStreamUserDefinedFunctionTests.test_table_function fails on CI Key: FLINK-29897 URL: https://issues.apache.org/jira/browse/FLINK-29897 Project:

[GitHub] [flink] Samrat002 commented on pull request #21242: [FLINK-29878][hive] Fix flink-sql-connector hive error

2022-11-04 Thread GitBox
Samrat002 commented on PR #21242: URL: https://github.com/apache/flink/pull/21242#issuecomment-1304406023 @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

[GitHub] [flink] leonardBang commented on a diff in pull request #21241: [hotfix][doc] add `INTERVAL` subtraction into the example and update the related description

2022-11-04 Thread GitBox
leonardBang commented on code in PR #21241: URL: https://github.com/apache/flink/pull/21241#discussion_r1014556699 ## docs/content/docs/dev/table/sql/queries/joins.md: ## @@ -154,7 +154,7 @@ CREATE TABLE currency_rates ( currency STRING, conversion_rate DECIMAL(32,

[jira] [Resolved] (FLINK-24229) DynamoDB implementation of Async Sink

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-24229. --- Resolution: Fixed > DynamoDB implementation of Async Sink >

[jira] [Commented] (FLINK-24229) DynamoDB implementation of Async Sink

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629208#comment-17629208 ] Danny Cranmer commented on FLINK-24229: --- merged commit

[GitHub] [flink-connector-aws] dannycranmer merged pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-11-04 Thread GitBox
dannycranmer merged PR #1: URL: https://github.com/apache/flink-connector-aws/pull/1 -- 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:

[jira] [Commented] (FLINK-29896) DynamoDB CI Failing to run checks

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629206#comment-17629206 ] Danny Cranmer commented on FLINK-29896: --- merged commit

[jira] [Resolved] (FLINK-29896) DynamoDB CI Failing to run checks

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-29896. --- Resolution: Fixed > DynamoDB CI Failing to run checks > - >

[GitHub] [flink-connector-aws] dannycranmer merged pull request #11: [FLINK-29896] hotfix for build failure due to yaml literal typo

2022-11-04 Thread GitBox
dannycranmer merged PR #11: URL: https://github.com/apache/flink-connector-aws/pull/11 -- 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:

[jira] [Assigned] (FLINK-29896) DynamoDB CI Failing to run checks

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-29896: - Assignee: Daren Wong > DynamoDB CI Failing to run checks >

[jira] [Updated] (FLINK-29896) DynamoDB CI Failing to run checks

2022-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29896: --- Labels: pull-request-available (was: ) > DynamoDB CI Failing to run checks >

[GitHub] [flink-connector-aws] darenwkt opened a new pull request, #11: [FLINK-29896] hotfix for build failure due to yaml literal typo

2022-11-04 Thread GitBox
darenwkt opened a new pull request, #11: URL: https://github.com/apache/flink-connector-aws/pull/11 This is a hotfix for build failure caused by typo in yaml multiline literal. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink-connector-aws] hlteoh37 commented on pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-11-04 Thread GitBox
hlteoh37 commented on PR #1: URL: https://github.com/apache/flink-connector-aws/pull/1#issuecomment-1304196612 LGTM -- 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

[GitHub] [flink-connector-aws] dannycranmer commented on pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-11-04 Thread GitBox
dannycranmer commented on PR #1: URL: https://github.com/apache/flink-connector-aws/pull/1#issuecomment-1304179568 Seems like the checks are broken, raised a Jira to fix: - https://issues.apache.org/jira/browse/FLINK-29896 LGTM, running tests locally before merging -- This is

[jira] [Updated] (FLINK-29896) DynamoDB CI Failing to run checks

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29896: -- Description: The checks are failing to actually run the build and test step: -

[jira] [Created] (FLINK-29896) DynamoDB CI Failing to run checks

2022-11-04 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-29896: - Summary: DynamoDB CI Failing to run checks Key: FLINK-29896 URL: https://issues.apache.org/jira/browse/FLINK-29896 Project: Flink Issue Type: Bug

[GitHub] [flink-connector-aws] dannycranmer commented on pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-11-04 Thread GitBox
dannycranmer commented on PR #1: URL: https://github.com/apache/flink-connector-aws/pull/1#issuecomment-1304151007 As discussed offline. The build takes ~9 minutes to run due to excessive use of integration tests. We will follow up to migrate these tests to unit tests, and generally

[jira] [Updated] (FLINK-29895) Improve code coverage and integration tests for DynamoDB implementation of Async Sink

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29895: -- Labels: (was: pull-request-available stale-assigned) > Improve code coverage and

[jira] [Updated] (FLINK-24229) DynamoDB implementation of Async Sink

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24229: -- Summary: DynamoDB implementation of Async Sink (was: [FLIP-171] DynamoDB implementation of

[jira] [Updated] (FLINK-24229) DynamoDB implementation of Async Sink

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24229: -- Labels: pull-request-available (was: pull-request-available stale-assigned) > DynamoDB

[jira] [Updated] (FLINK-29895) Improve code coverage and integration tests for DynamoDB implementation of Async Sink

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29895: -- Issue Type: Improvement (was: New Feature) > Improve code coverage and integration tests for

[jira] [Updated] (FLINK-29895) Improve code coverage and integration tests for DynamoDB implementation of Async Sink

2022-11-04 Thread Yuri Gusev (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuri Gusev updated FLINK-29895: --- Description: *Scope:* * Reduce number of integration tests in favor of better unit test coverage *

[jira] [Created] (FLINK-29895) Improve code coverage and integration tests for DynamoDB implementation of Async Sink

2022-11-04 Thread Yuri Gusev (Jira)
Yuri Gusev created FLINK-29895: -- Summary: Improve code coverage and integration tests for DynamoDB implementation of Async Sink Key: FLINK-29895 URL: https://issues.apache.org/jira/browse/FLINK-29895

[jira] [Commented] (FLINK-29855) UDF randomly processed input data twice

2022-11-04 Thread Xinyi Yan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629175#comment-17629175 ] Xinyi Yan commented on FLINK-29855: --- Thank you to [~luoyuxia] for confirming the root cause of the

[jira] [Commented] (FLINK-23542) Upgrade Checkstyle to at least 8.29

2022-11-04 Thread Samrat Deb (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629151#comment-17629151 ] Samrat Deb commented on FLINK-23542: Hey [~martijnvisser] ! Can i pick this task and work on it ?

[GitHub] [flink] ashmeet-kandhari commented on pull request #20991: [FLINK-25538][flink-connector-kafka] JUnit5 Migration

2022-11-04 Thread GitBox
ashmeet-kandhari commented on PR #20991: URL: https://github.com/apache/flink/pull/20991#issuecomment-1303971800 Hi @snuyanzin I have made changes for the comments added. Let me know if anything else is there -- This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-29878) Fail to use flink-sql-connector-hive-3.1.3

2022-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29878: --- Labels: pull-request-available (was: ) > Fail to use flink-sql-connector-hive-3.1.3 >

[GitHub] [flink] flinkbot commented on pull request #21242: [FLINK-29878][hive] Fix flink-sql-connector hive error

2022-11-04 Thread GitBox
flinkbot commented on PR #21242: URL: https://github.com/apache/flink/pull/21242#issuecomment-1303970895 ## CI report: * 919ad5e14f6648461820f2485ef59680fa4db59e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] Samrat002 opened a new pull request, #21242: [Flink][hive] Fix flink-sql-connector hive error

2022-11-04 Thread GitBox
Samrat002 opened a new pull request, #21242: URL: https://github.com/apache/flink/pull/21242 ## What is the purpose of the change ## Brief change log Fix dependencies error ## Does this pull request potentially affect one of the following parts: -

[GitHub] [flink] reswqa commented on a diff in pull request #21209: [FLINK-29818] Fix the unstable test HsResultPartitionTest.testAvailability

2022-11-04 Thread GitBox
reswqa commented on code in PR #21209: URL: https://github.com/apache/flink/pull/21209#discussion_r1014315054 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFullSpillingStrategyTest.java: ## @@ -149,9 +147,9 @@ void

[jira] [Commented] (FLINK-29891) The RetryRule tests print some excessive stacktraces that might confuse people investigating actual issues

2022-11-04 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629132#comment-17629132 ] Ryan Skraba commented on FLINK-29891: - Sure, can you assign this to me? > The RetryRule tests print

[GitHub] [flink] reswqa commented on pull request #21209: [FLINK-29818] Fix the unstable test HsResultPartitionTest.testAvailability

2022-11-04 Thread GitBox
reswqa commented on PR #21209: URL: https://github.com/apache/flink/pull/21209#issuecomment-1303943003 @xintongsong Thanks for the review. > I tried the fix without the questioned hotfix commit. Unfortunately, it doesn't work. As you said, there's a bug that we are releasing

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2022-11-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629128#comment-17629128 ] Thomas Weise commented on FLINK-29871: -- +1 > Upgrade operator Flink version and examples to 1.16 >

[jira] [Commented] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629105#comment-17629105 ] Danny Cranmer commented on FLINK-29894: --- Created INFRA ticket

[GitHub] [flink] pnowojski commented on a diff in pull request #21056: [FLINK-29379][datastream] Migrate most of the ExecutionConfig fields to Configuration

2022-11-04 Thread GitBox
pnowojski commented on code in PR #21056: URL: https://github.com/apache/flink/pull/21056#discussion_r1014256187 ## flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java: ## @@ -461,14 +461,20 @@ public RestartStrategies.RestartStrategyConfiguration

[jira] [Closed] (FLINK-29807) Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

2022-11-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-29807. -- Resolution: Fixed Merged to master as 1e131d2a777..32cc0143753 > Drop

[jira] [Assigned] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-29894: - Assignee: Danny Cranmer > Rename flink-connector-dynamodb to flink-connector-aws >

[GitHub] [flink] pnowojski merged pull request #21201: [FLINK-29807] Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

2022-11-04 Thread GitBox
pnowojski merged PR #21201: URL: https://github.com/apache/flink/pull/21201 -- 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:

[jira] [Updated] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29894: -- Fix Version/s: aws-connector-2.0.0 > Rename flink-connector-dynamodb to flink-connector-aws >

[GitHub] [flink] pnowojski commented on pull request #21201: [FLINK-29807] Drop TypeSerializerConfigSnapshot and savepoint support from Flink versions < 1.8.0

2022-11-04 Thread GitBox
pnowojski commented on PR #21201: URL: https://github.com/apache/flink/pull/21201#issuecomment-1303861102 Thanks for the review, azure is green, 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

[jira] [Updated] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29894: -- Component/s: Connectors / AWS > Rename flink-connector-dynamodb to flink-connector-aws >

[jira] [Updated] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29894: -- Description: The existing

[jira] [Created] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

2022-11-04 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-29894: - Summary: Rename flink-connector-dynamodb to flink-connector-aws Key: FLINK-29894 URL: https://issues.apache.org/jira/browse/FLINK-29894 Project: Flink

[jira] [Updated] (FLINK-29438) Setup AWS Connectors Project Structure

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29438: -- Description: Umbrella task for AWS Connector repo setup. Please put all AWS connector setup

[jira] [Updated] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

2022-11-04 Thread ramkrishna.s.vasudevan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ramkrishna.s.vasudevan updated FLINK-18568: --- Labels: auto-deprioritized-major (was: auto-deprioritized-major

[jira] [Updated] (FLINK-29438) Setup AWS Connectors Project Structure

2022-11-04 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-29438: -- Summary: Setup AWS Connectors Project Structure (was: Setup DynamoDB Connector Project

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2022-11-04 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629088#comment-17629088 ] Gyula Fora commented on FLINK-29871: Thats a very good point [~thw] . Let's do this in 2 steps

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

2022-11-04 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629085#comment-17629085 ] Thomas Weise commented on FLINK-29871: -- X.Y.0 releases are not vetted and prone to surprises.

[jira] [Resolved] (FLINK-28449) [JUnit5 Migration] Module: flink-parquet

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-28449. --- Fix Version/s: 1.17.0 Resolution: Fixed master:

[GitHub] [flink] XComp merged pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-11-04 Thread GitBox
XComp merged PR #20230: URL: https://github.com/apache/flink/pull/20230 -- 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] XComp commented on pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-11-04 Thread GitBox
XComp commented on PR #20230: URL: https://github.com/apache/flink/pull/20230#issuecomment-1303838597 I'm gonna merge this PR without rerunning the e2e tests because the change suggested by this PR is independent of the e2e tests. -- This is an automated message from the Apache Git

[jira] [Updated] (FLINK-29893) k8s python e2e test failed due to permission error when pulling the Docker image

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29893: -- Issue Type: Bug (was: Improvement) > k8s python e2e test failed due to permission error when

[jira] [Updated] (FLINK-29893) k8s python e2e test failed due to permission error when pulling the Docker image

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29893: -- Labels: test-stability (was: ) > k8s python e2e test failed due to permission error when

[jira] [Created] (FLINK-29893) k8s python e2e test failed due to permission error when pulling the Docker image

2022-11-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29893: - Summary: k8s python e2e test failed due to permission error when pulling the Docker image Key: FLINK-29893 URL: https://issues.apache.org/jira/browse/FLINK-29893

[GitHub] [flink] XComp commented on pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-11-04 Thread GitBox
XComp commented on PR #20230: URL: https://github.com/apache/flink/pull/20230#issuecomment-1303836863 I created FLINK-29893 to cover the build failure. -- 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

[jira] [Commented] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629077#comment-17629077 ] Leonard Xu commented on FLINK-29836: [~mapohl] My mistake, udpated > PulsarUnorderedSourceITCase

[jira] [Updated] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-29836: --- Affects Version/s: (was: 1.16.0) (was: 1.17.0) >

[GitHub] [flink] XComp commented on a diff in pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-11-04 Thread GitBox
XComp commented on code in PR #20230: URL: https://github.com/apache/flink/pull/20230#discussion_r1014228413 ## flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetColumnarRowInputFormatTest.java: ## @@ -126,7 +126,7 @@ class

[GitHub] [flink] XComp commented on a diff in pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-11-04 Thread GitBox
XComp commented on code in PR #20230: URL: https://github.com/apache/flink/pull/20230#discussion_r1014228413 ## flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetColumnarRowInputFormatTest.java: ## @@ -126,7 +126,7 @@ class

[GitHub] [flink] XComp commented on a diff in pull request #20230: [FLINK-28449][tests][JUnit5 migration] flink-parquet

2022-11-04 Thread GitBox
XComp commented on code in PR #20230: URL: https://github.com/apache/flink/pull/20230#discussion_r1014227896 ## flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/avro/AvroParquetFileReadITCase.java: ## @@ -79,14 +92,14 @@ public static void setup()

[jira] [Commented] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629065#comment-17629065 ] Matthias Pohl commented on FLINK-29836: --- I'm linking FLINK-29755. They might be caused by the same

[jira] [Comment Edited] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629064#comment-17629064 ] Matthias Pohl edited comment on FLINK-29836 at 11/4/22 4:01 PM: {code}

[jira] [Commented] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629064#comment-17629064 ] Matthias Pohl commented on FLINK-29836: --- {quote} java.util.concurrent.ExecutionException:

[jira] [Updated] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-04 Thread Sergio Sainz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergio Sainz updated FLINK-29892: - Description: When adding a string with hash (#) character in env.java.opts in flink-conf.yaml

[jira] [Created] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

2022-11-04 Thread Sergio Sainz (Jira)
Sergio Sainz created FLINK-29892: Summary: flink-conf.yaml does not accept hash (#) in the env.java.opts property Key: FLINK-29892 URL: https://issues.apache.org/jira/browse/FLINK-29892 Project:

[jira] [Commented] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629062#comment-17629062 ] Matthias Pohl commented on FLINK-29836: --- [~leonard] is this a mistake or what's the reason you

[jira] [Updated] (FLINK-29836) PulsarUnorderedSourceITCase failed due to an expected job restart not happening

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29836: -- Affects Version/s: 1.15.2 > PulsarUnorderedSourceITCase failed due to an expected job restart

[jira] [Commented] (FLINK-29891) The RetryRule tests print some excessive stacktraces that might confuse people investigating actual issues

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629052#comment-17629052 ] Matthias Pohl commented on FLINK-29891: --- [~rskraba] could you have a look at this? > The

[GitHub] [flink-kubernetes-operator] tagarr commented on pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

2022-11-04 Thread GitBox
tagarr commented on PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#issuecomment-1303779571 If we don't use this method the only way I can see this working is by creating an init container that has the WATCH_NAMESPACE env var and then finding a way to modify the

[GitHub] [flink] xintongsong commented on a diff in pull request #21209: [FLINK-29818] Fix the unstable test HsResultPartitionTest.testAvailability

2022-11-04 Thread GitBox
xintongsong commented on code in PR #21209: URL: https://github.com/apache/flink/pull/21209#discussion_r1014058947 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFullSpillingStrategy.java: ## @@ -128,28 +128,32 @@ private void

[jira] [Created] (FLINK-29891) The RetryRule tests print some excessive stacktraces that might confuse people investigating actual issues

2022-11-04 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-29891: - Summary: The RetryRule tests print some excessive stacktraces that might confuse people investigating actual issues Key: FLINK-29891 URL:

[jira] [Commented] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

2022-11-04 Thread Srinivasulu Punuru (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629031#comment-17629031 ] Srinivasulu Punuru commented on FLINK-18568: [~ram_krish] I can't seem to edit these Jiras,

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

2022-11-04 Thread GitBox
morhidi commented on PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#issuecomment-1303689150 The main idea of having the watch namespaces in the configs is to be able to reload it dynamically without an operator restart. This would break that obviously and pin

[jira] [Commented] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629028#comment-17629028 ] Matthias Pohl commented on FLINK-29890: --- [~jark] may you have a look on that one? > UDFs

[jira] [Updated] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-29890: -- Priority: Critical (was: Major) > UDFs classloading from JARs in 1.16 is broken >

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

2022-11-04 Thread GitBox
morhidi commented on PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#issuecomment-1303685999 Hi @tagarr could you please update the PR description using the PR template? I'd like to understand also why the current CM based configuration is not sufficient? --

[jira] [Updated] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

2022-11-04 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-29890: -- Description: 1.16 introduced a lot of changes with respect to classloading in the

[GitHub] [flink-kubernetes-operator] gyfora commented on pull request #420: FLINK-29536 - Add WATCH_NAMESPACE env var to operator

2022-11-04 Thread GitBox
gyfora commented on PR #420: URL: https://github.com/apache/flink-kubernetes-operator/pull/420#issuecomment-1303681972 cc @morhidi -- 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-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-04 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17629022#comment-17629022 ] Matthias Pohl commented on FLINK-29461: ---

[jira] [Created] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

2022-11-04 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-29890: - Summary: UDFs classloading from JARs in 1.16 is broken Key: FLINK-29890 URL: https://issues.apache.org/jira/browse/FLINK-29890 Project: Flink

[jira] [Updated] (FLINK-29890) UDFs classloading from JARs in 1.16 is broken

2022-11-04 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-29890: -- Description: 1.16 introduced a lot of changes with respect to classloading in the

[jira] [Updated] (FLINK-29889) netty-tcnative-static does not bundle tcnative-classes

2022-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29889: --- Labels: pull-request-available (was: ) > netty-tcnative-static does not bundle

[GitHub] [flink-shaded] zentol opened a new pull request, #115: [FLINK-29889][netty] Bundle tcnative-classes

2022-11-04 Thread GitBox
zentol opened a new pull request, #115: URL: https://github.com/apache/flink-shaded/pull/115 ``` Nov 03 12:44:46 [INFO] --- maven-shade-plugin:3.1.1:shade (shade-flink) @ flink-shaded-netty-tcnative-static --- Nov 03 12:44:47 [INFO] Including

[jira] [Closed] (FLINK-29874) Streaming File Sink end-to-end test failed on azure due to ClassNotFoundException

2022-11-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29874. Resolution: Duplicate > Streaming File Sink end-to-end test failed on azure due to >

[jira] [Updated] (FLINK-29889) netty-tcnative-static does not bundle tcnative-classes

2022-11-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29889: - Description: The shade plugin configuration was not adjusted to also bundle the

[jira] [Assigned] (FLINK-29889) netty-tcnative-static does not bundle tcnative-classes

2022-11-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-29889: Assignee: Chesnay Schepler > netty-tcnative-static does not bundle

[jira] [Closed] (FLINK-29886) networkThroughput 1000,100ms,OpenSSL Benchmark is failing

2022-11-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-29886. Resolution: Duplicate > networkThroughput 1000,100ms,OpenSSL Benchmark is failing >

[jira] [Created] (FLINK-29889) netty-tcnative-static does not bundle tcnative-classes

2022-11-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29889: Summary: netty-tcnative-static does not bundle tcnative-classes Key: FLINK-29889 URL: https://issues.apache.org/jira/browse/FLINK-29889 Project: Flink

[GitHub] [flink-connector-opensearch] reta commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-11-04 Thread GitBox
reta commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1303657822 @MartijnVisser doing my deligance by pinging once per month :-) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-connector-dynamodb] hlteoh37 commented on a diff in pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-11-04 Thread GitBox
hlteoh37 commented on code in PR #1: URL: https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1014057263 ## flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java: ## @@ -0,0 +1,307 @@ +/* + *

[GitHub] [flink-connector-dynamodb] hlteoh37 commented on a diff in pull request #1: [FLINK-24229][Connectors][DynamoDB] - Add AWS DynamoDB connector

2022-11-04 Thread GitBox
hlteoh37 commented on code in PR #1: URL: https://github.com/apache/flink-connector-dynamodb/pull/1#discussion_r1014055821 ## flink-connector-dynamodb/src/main/java/org/apache/flink/streaming/connectors/dynamodb/sink/DynamoDbSinkWriter.java: ## @@ -0,0 +1,307 @@ +/* + *

  1   2   3   >