[jira] [Closed] (FLINK-32095) HiveDialectITCase crashed with exit code 239

[ https://issues.apache.org/jira/browse/FLINK-32095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-32095. - Resolution: Duplicate The exit code 239 indicates that a fatal error occurred that was handled

[jira] [Comment Edited] (FLINK-31669) DynamicFilteringITCase failed fataly because of NoClassDefFoundError of akka/actor/SuppressedDeadLetter

[ https://issues.apache.org/jira/browse/FLINK-31669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17706775#comment-17706775 ] Matthias Pohl edited comment on FLINK-31669 at 5/15/23 8:25 AM: Based on

[jira] [Commented] (FLINK-32094) startScheduling.BATCH performance regression since May 11th

[ https://issues.apache.org/jira/browse/FLINK-32094?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722696#comment-17722696 ] Yuxin Tan commented on FLINK-32094: --- Thanks [~martijnvisser] and [~Thesharing]. I reproduced the

[GitHub] [flink] flinkbot commented on pull request #22578: [FLINK-32094][network] Avoid creating tiered internal shuffle master before enabling the tiered storage

flinkbot commented on PR #22578: URL: https://github.com/apache/flink/pull/22578#issuecomment-1547401496 ## CI report: * 7e32deb4cf8f71ed86c10ef1bfa65bf79a2a30c9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] TanYuxin-tyx opened a new pull request, #22578: [FLINK-32094][network] Avoid creating tiered internal shuffle master before enabling the tiered storage

TanYuxin-tyx opened a new pull request, #22578: URL: https://github.com/apache/flink/pull/22578 ## What is the purpose of the change *Avoid creating tiered internal shuffle master before enabling the tiered storage* ## Brief change log - *Avoid

[jira] [Assigned] (FLINK-31967) SQL with LAG function NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-31967: - Assignee: Haojin Wang > SQL with LAG function NullPointerException >

[jira] [Assigned] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-31780: - Assignee: Oleksandr Nitavskyi > Allow users to disable "Ensemble tracking" for

[jira] [Resolved] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-31780. --- Fix Version/s: 1.18.0 Resolution: Fixed master:

[jira] [Updated] (FLINK-31780) Allow users to disable "Ensemble tracking" for ZooKeeper

[ https://issues.apache.org/jira/browse/FLINK-31780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-31780: -- Component/s: Runtime / Coordination > Allow users to disable "Ensemble tracking" for

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193477540 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java: ## @@ -0,0 +1,167 @@ +/* + *

[GitHub] [flink] XComp merged pull request #22394: [FLINK-31780][component=Runtime/Coordination] Allow users to disable 'Ensemble tracking' feature for ZooKeeper Curator framework

XComp merged PR #22394: URL: https://github.com/apache/flink/pull/22394 -- 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 #22394: [FLINK-31780][component=Runtime/Coordination] Allow users to disable 'Ensemble tracking' feature for ZooKeeper Curator framework

XComp commented on PR #22394: URL: https://github.com/apache/flink/pull/22394#issuecomment-1547381717 I was planning to merge the PR but was blocked by FLINK-32066. The issue is resolved and CI is green for this change. I will go ahead and merge it. -- This is an automated message from

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193475956 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[jira] [Resolved] (FLINK-32099) create flink_data volume for operations playground

[ https://issues.apache.org/jira/browse/FLINK-32099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson resolved FLINK-32099. Fix Version/s: 1.17.1 Resolution: Implemented > create flink_data volume for

[jira] [Commented] (FLINK-32069) jobClient.getJobStatus() can return status RUNNING for finished insert operation

[ https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722692#comment-17722692 ] Matthias Pohl commented on FLINK-32069: --- I already mentioned it in Slack and will add the comment

[jira] [Commented] (FLINK-32069) jobClient.getJobStatus() can return status RUNNING for finished insert operation

[ https://issues.apache.org/jira/browse/FLINK-32069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722691#comment-17722691 ] Matthias Pohl commented on FLINK-32069: --- Thanks for documenting this issue in Jira, [~izeren].

[jira] [Commented] (FLINK-32099) create flink_data volume for operations playground

[ https://issues.apache.org/jira/browse/FLINK-32099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722688#comment-17722688 ] David Anderson commented on FLINK-32099: fixed in playground master with

[GitHub] [flink-training] San-ctuary closed pull request #58: [hotfix] fix link bug

San-ctuary closed pull request #58: [hotfix] fix link bug URL: https://github.com/apache/flink-training/pull/58 -- 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,

[GitHub] [flink-playgrounds] alpinegizmo merged pull request #42: Create flink_data volume for operations playground.

alpinegizmo merged PR #42: URL: https://github.com/apache/flink-playgrounds/pull/42 -- 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-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193460464 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/proxy/StreamProxy.java: ## @@ -0,0 +1,56 @@ +/* + * Licensed

[jira] [Created] (FLINK-32099) create flink_data volume for operations playground

David Anderson created FLINK-32099: -- Summary: create flink_data volume for operations playground Key: FLINK-32099 URL: https://issues.apache.org/jira/browse/FLINK-32099 Project: Flink Issue

[jira] [Commented] (FLINK-32098) Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO

[ https://issues.apache.org/jira/browse/FLINK-32098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722684#comment-17722684 ] Matthias Pohl commented on FLINK-32098: --- I'm linking FLINK-27204 which covers moving all the

[jira] [Created] (FLINK-32098) Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO

Matthias Pohl created FLINK-32098: - Summary: Dispatcher#submitJob calls Dispatcher#isInGloballyTerminalState up to three times which might be expensive due to IO Key: FLINK-32098 URL:

[GitHub] [flink] alpinegizmo merged pull request #22576: Remove savepoint and checkpoint mount instructions from flink playground.

alpinegizmo merged PR #22576: URL: https://github.com/apache/flink/pull/22576 -- 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-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193446492 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/assigner/UniformShardAssigner.java: ## @@ -0,0

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r119308 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigUtil.java: ## @@ -0,0 +1,61 @@ +/* + *

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193441538 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/StartingPosition.java: ## @@ -0,0 +1,94 @@ +/* + *

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193439564 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitState.java: ## @@ -0,0 +1,72 @@ +/* + *

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193436235 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitState.java: ## @@ -0,0 +1,72 @@ +/* + *

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193436235 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/split/KinesisShardSplitState.java: ## @@ -0,0 +1,72 @@ +/* + *

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193435598 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/reader/PollingKinesisShardSplitReader.java: ## @@ -0,0 +1,152

[jira] [Created] (FLINK-32097) Implement support for Kinesis aggregation

Hong Liang Teoh created FLINK-32097: --- Summary: Implement support for Kinesis aggregation Key: FLINK-32097 URL: https://issues.apache.org/jira/browse/FLINK-32097 Project: Flink Issue Type:

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193433223 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/enumerator/KinesisStreamsSourceEnumerator.java: ## @@ -0,0

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193430853 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java: ## @@ -0,0 +1,167 @@ +/* + *

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193430008 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java: ## @@ -0,0 +1,167 @@ +/* + *

[jira] [Commented] (FLINK-32096) Flink 1.17 doc points to non-existant branch in flink-training repo

[ https://issues.apache.org/jira/browse/FLINK-32096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722680#comment-17722680 ] Samrat Deb commented on FLINK-32096: [~yunta] :+1 > Flink 1.17 doc points to non-existant branch in

[jira] [Updated] (FLINK-31413) Remove provided dependency of flink-table-planner from Hive connector

[ https://issues.apache.org/jira/browse/FLINK-31413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia updated FLINK-31413: - Description: Can move on after finish FLINK-31409. We still need some follow-up tasks before removing

[GitHub] [flink-connector-aws] hlteoh37 commented on a diff in pull request #49: [FLINK-24438] Add Kinesis connector using FLIP-27

hlteoh37 commented on code in PR #49: URL: https://github.com/apache/flink-connector-aws/pull/49#discussion_r1193423666 ## flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/config/SourceConfigConstants.java: ## @@ -0,0 +1,369 @@ +/* +

[jira] [Commented] (FLINK-32096) Flink 1.17 doc points to non-existant branch in flink-training repo

[ https://issues.apache.org/jira/browse/FLINK-32096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722676#comment-17722676 ] Yun Tang commented on FLINK-32096: -- [~samrat007] Thanks for the reporting, I will fix this problem. >

[jira] [Assigned] (FLINK-32096) Flink 1.17 doc points to non-existant branch in flink-training repo

[ https://issues.apache.org/jira/browse/FLINK-32096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-32096: Assignee: Yun Tang > Flink 1.17 doc points to non-existant branch in flink-training repo >

[jira] [Created] (FLINK-32096) Flink 1.17 doc points to non-existant branch in flink-training repo

Samrat Deb created FLINK-32096: -- Summary: Flink 1.17 doc points to non-existant branch in flink-training repo Key: FLINK-32096 URL: https://issues.apache.org/jira/browse/FLINK-32096 Project: Flink

[jira] [Comment Edited] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722670#comment-17722670 ] David Artiga edited comment on FLINK-31810 at 5/15/23 6:46 AM: --- RocksDB

[jira] [Comment Edited] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722670#comment-17722670 ] David Artiga edited comment on FLINK-31810 at 5/15/23 6:46 AM: --- RocksDB

[jira] [Commented] (FLINK-31810) RocksDBException: Bad table magic number on checkpoint rescale

[ https://issues.apache.org/jira/browse/FLINK-31810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722670#comment-17722670 ] David Artiga commented on FLINK-31810: -- RocksDB files are stored in local filesystem on DataProc

[jira] [Comment Edited] (FLINK-31967) SQL with LAG function NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722665#comment-17722665 ] Haojin Wang edited comment on FLINK-31967 at 5/15/23 6:26 AM: -- [~padavan] 

[GitHub] [flink] clownxc closed pull request #22555: [FLINK-31706] [runtime] The default source parallelism should be the same as ex…

clownxc closed pull request #22555: [FLINK-31706] [runtime] The default source parallelism should be the same as ex… URL: https://github.com/apache/flink/pull/22555 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (FLINK-31967) SQL with LAG function NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-31967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722665#comment-17722665 ] Haojin Wang commented on FLINK-31967: - This problem is caused by the basic data type of Java, and I

[GitHub] [flink] luoyuxia merged pull request #22577: [FLINK-31882][sql-client] Fix sql client can't show result for DELETE…

luoyuxia merged PR #22577: URL: https://github.com/apache/flink/pull/22577 -- 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:

<    1   2   3