[jira] [Commented] (FLINK-29277) Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented'

2022-09-12 Thread Jiankun Feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603391#comment-17603391 ] Jiankun Feng commented on FLINK-29277: -- Flink Submits the task to YARN,YarnClientY

[jira] [Assigned] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-29271: -- Assignee: jiangjiguang0719 > Change to byte array from bytebuffer to improve performa

[jira] [Created] (FLINK-29277) Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented'

2022-09-12 Thread Jiankun Feng (Jira)
Jiankun Feng created FLINK-29277: Summary: Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented' Key: FLINK-29277 URL: https://

[GitHub] [flink] wuchong commented on a diff in pull request #20176: [FLINK-27660][table] add table api for registering function with resource

2022-09-12 Thread GitBox
wuchong commented on code in PR #20176: URL: https://github.com/apache/flink/pull/20176#discussion_r964657510 ## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java: ## @@ -516,13 +518,51 @@ void createFunction( boolean ig

[GitHub] [flink] zzzzzzzs commented on a diff in pull request #20342: [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API

2022-09-12 Thread GitBox
zzzs commented on code in PR #20342: URL: https://github.com/apache/flink/pull/20342#discussion_r969203533 ## flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java: ## @@ -371,6 +371,11 @@ public static String repeat(Str

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #362: [FLINK-28574] Bump the JOSDK version to 3.2.0

2022-09-12 Thread GitBox
morhidi commented on PR #362: URL: https://github.com/apache/flink-kubernetes-operator/pull/362#issuecomment-1244959843 Hi @SteNicholas It'd be great if you could try to fix the CI errors, i.e.` NoSuchMethod`. There is also the `KubernetesClientMetrics` class which introduces an in

[GitHub] [flink] zzzzzzzs commented on a diff in pull request #20342: [FLINK-26939][Table SQL/API] Add TRANSLATE supported in SQL & Table API

2022-09-12 Thread GitBox
zzzs commented on code in PR #20342: URL: https://github.com/apache/flink/pull/20342#discussion_r969201461 ## flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/expressions/ScalarFunctionsTest.scala: ## @@ -282,6 +282,13 @@ class ScalarFunctionsTes

[jira] [Reopened] (FLINK-19869) Flink SQL JDBC connector for Postgres can't handle UUID datatype

2022-09-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-19869: Assignee: (was: Bobby Richard) After discussion with [~twalthr] this has been revert

[GitHub] [flink] MartijnVisser commented on a diff in pull request #20048: [FLINK-19869][connectors/jdbc] Add support for postgres UUID type

2022-09-12 Thread GitBox
MartijnVisser commented on code in PR #20048: URL: https://github.com/apache/flink/pull/20048#discussion_r969193850 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverter.java: ## @@ -59,6 +63,25 @@ public J

[jira] [Updated] (FLINK-19869) Flink SQL JDBC connector for Postgres can't handle UUID datatype

2022-09-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-19869: --- Fix Version/s: (was: 1.16.0) > Flink SQL JDBC connector for Postgres can't handle UUID d

[jira] [Updated] (FLINK-29134) fetch metrics may cause oom(ThreadPool task pile up)

2022-09-12 Thread Sitan Pang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sitan Pang updated FLINK-29134: --- Affects Version/s: 1.15.2 > fetch metrics may cause oom(ThreadPool task pile up) > -

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #360: [FLINK-29165][docs] update docs to create and delete deployment via code

2022-09-12 Thread GitBox
morhidi commented on PR #360: URL: https://github.com/apache/flink-kubernetes-operator/pull/360#issuecomment-1244949027 Please create another module, e.g. `kubernetes-client-examples` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #366: [FLINK-29251] Send CREATED status and Cancel event via FlinkResourceListener

2022-09-12 Thread GitBox
morhidi commented on code in PR #366: URL: https://github.com/apache/flink-kubernetes-operator/pull/366#discussion_r969187782 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java: ## @@ -58,36 +58,40 @@ public v

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #366: [FLINK-29251] Send CREATED status and Cancel event via FlinkResourceListener

2022-09-12 Thread GitBox
morhidi commented on code in PR #366: URL: https://github.com/apache/flink-kubernetes-operator/pull/366#discussion_r969186749 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java: ## @@ -58,36 +58,40 @@ public v

[GitHub] [flink-kubernetes-operator] morhidi commented on a diff in pull request #366: [FLINK-29251] Send CREATED status and Cancel event via FlinkResourceListener

2022-09-12 Thread GitBox
morhidi commented on code in PR #366: URL: https://github.com/apache/flink-kubernetes-operator/pull/366#discussion_r969186749 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java: ## @@ -58,36 +58,40 @@ public v

[GitHub] [flink] xintongsong commented on a diff in pull request #20796: [FLINK-29238][runtime] Wrong index information will be obtained after the downstream failover in hybrid full mode

2022-09-12 Thread GitBox
xintongsong commented on code in PR #20796: URL: https://github.com/apache/flink/pull/20796#discussion_r969162160 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexImplTest.java: ## @@ -54,23 +54,32 @@ void before() { @Test

[GitHub] [flink-kubernetes-operator] pvary commented on a diff in pull request #366: [FLINK-29251] Send CREATED status and Cancel event via FlinkResourceListener

2022-09-12 Thread GitBox
pvary commented on code in PR #366: URL: https://github.com/apache/flink-kubernetes-operator/pull/366#discussion_r969157975 ## flink-kubernetes-operator/src/test/java/org/apache/flink/kubernetes/operator/listener/FlinkResourceListenerTest.java: ## @@ -58,36 +58,40 @@ public voi

[jira] [Closed] (FLINK-29275) Temporal Table function: Cannot add expression of different type to set

2022-09-12 Thread Tally (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tally closed FLINK-29275. - Resolution: Later > Temporal Table function: Cannot add expression of different type to set > --

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #291: [FLINK-29273] Page not enough Exception in SortBufferMemTable

2022-09-12 Thread GitBox
JingsongLi commented on code in PR #291: URL: https://github.com/apache/flink-table-store/pull/291#discussion_r969135349 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/memory/MemoryPoolFactory.java: ## @@ -78,20 +85,27 @@ public int pageSize() {

[jira] [Updated] (FLINK-29276) Flush all memory in SortBufferMemTable.clear

2022-09-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29276: - Component/s: Table Store > Flush all memory in SortBufferMemTable.clear > --

[jira] [Updated] (FLINK-29276) Flush all memory in SortBufferMemTable.clear

2022-09-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29276: - Fix Version/s: table-store-0.3.0 > Flush all memory in SortBufferMemTable.clear > --

[jira] [Created] (FLINK-29276) Flush all memory in SortBufferMemTable.clear

2022-09-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29276: Summary: Flush all memory in SortBufferMemTable.clear Key: FLINK-29276 URL: https://issues.apache.org/jira/browse/FLINK-29276 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-29275) Temporal Table function: Cannot add expression of different type to set

2022-09-12 Thread Tally (Jira)
Tally created FLINK-29275: - Summary: Temporal Table function: Cannot add expression of different type to set Key: FLINK-29275 URL: https://issues.apache.org/jira/browse/FLINK-29275 Project: Flink Is

[GitHub] [flink] fsk119 commented on a diff in pull request #20719: [FLINK-29148][docs][sql-gateway][hive] Add SQL Gateway docs

2022-09-12 Thread GitBox
fsk119 commented on code in PR #20719: URL: https://github.com/apache/flink/pull/20719#discussion_r969132854 ## docs/content.zh/docs/dev/table/sql-gateway/overview.md: ## @@ -0,0 +1,226 @@ +--- +title: Overview +weight: 1 +type: docs +aliases: +- /dev/table/sql-gateway.html +---

[GitHub] [flink] reswqa commented on pull request #20796: [FLINK-29238][runtime] Wrong index information will be obtained after the downstream failover in hybrid full mode

2022-09-12 Thread GitBox
reswqa commented on PR #20796: URL: https://github.com/apache/flink/pull/20796#issuecomment-1244874893 @xintongsong Thanks for the review, comments of the first commit has been resolved. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] reswqa commented on a diff in pull request #20796: [FLINK-29238][runtime] Wrong index information will be obtained after the downstream failover in hybrid full mode

2022-09-12 Thread GitBox
reswqa commented on code in PR #20796: URL: https://github.com/apache/flink/pull/20796#discussion_r969131791 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManagerTest.java: ## @@ -340,6 +341,57 @@ void testRegisterSubpartitionReade

[jira] [Updated] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29273: --- Labels: pull-request-available (was: ) > Page not enough Exception in SortBufferMemTable >

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #291: [FLINK-29273] Page not enough Exception in SortBufferMemTable

2022-09-12 Thread GitBox
JingsongLi opened a new pull request, #291: URL: https://github.com/apache/flink-table-store/pull/291 When there are many partitions, the partition writer will seize memory and may have the memory not enough exceptions. We need to make sure that the writer has enough memory before it can

[jira] [Assigned] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-29273: Assignee: Jingsong Lee > Page not enough Exception in SortBufferMemTable > --

[GitHub] [flink] reswqa commented on pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-12 Thread GitBox
reswqa commented on PR #20739: URL: https://github.com/apache/flink/pull/20739#issuecomment-1244858068 @zhuzhurk Thank you for reviewing this pr, I have addressed your comments in a fix-up commit, PTAL~ -- This is an automated message from the Apache Git Service. To respond to the message

[GitHub] [flink] flinkbot commented on pull request #20819: [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs are

2022-09-12 Thread GitBox
flinkbot commented on PR #20819: URL: https://github.com/apache/flink/pull/20819#issuecomment-1244857059 ## CI report: * d0888cfc13f74f8a2d932127529dda2e6592e995 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] reswqa commented on a diff in pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-12 Thread GitBox
reswqa commented on code in PR #20739: URL: https://github.com/apache/flink/pull/20739#discussion_r969117632 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java: ## @@ -301,10 +335,12 @@ private boolean isDownstreamC

[GitHub] [flink] yuzelin commented on a diff in pull request #20719: [FLINK-29148][docs][sql-gateway][hive] Add SQL Gateway docs

2022-09-12 Thread GitBox
yuzelin commented on code in PR #20719: URL: https://github.com/apache/flink/pull/20719#discussion_r966793400 ## docs/content/docs/dev/table/sql-gateway/overview.md: ## @@ -0,0 +1,226 @@ +--- +title: Overview +weight: 1 +type: docs +aliases: +- /dev/table/sql-gateway.html +--- +

[GitHub] [flink] PatrickRen opened a new pull request, #20819: [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both outputs

2022-09-12 Thread GitBox
PatrickRen opened a new pull request, #20819: URL: https://github.com/apache/flink/pull/20819 Unchanged backport of #20760 on release-1.16 -- 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 spec

[GitHub] [flink] reswqa commented on a diff in pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-12 Thread GitBox
reswqa commented on code in PR #20739: URL: https://github.com/apache/flink/pull/20739#discussion_r969116344 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java: ## @@ -281,10 +313,12 @@ private boolean areRegionInput

[GitHub] [flink] reswqa commented on a diff in pull request #20739: [FLINK-29101] PipelinedRegionSchedulingStrategy benchmark shows performance degradation

2022-09-12 Thread GitBox
reswqa commented on code in PR #20739: URL: https://github.com/apache/flink/pull/20739#discussion_r969115835 ## flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/PipelinedRegionSchedulingStrategy.java: ## @@ -61,7 +62,8 @@ public class PipelinedRegionSchedu

[jira] [Commented] (FLINK-29102) ChangelogLocalRecoveryITCase.testRestartTM failed with AssertionFailedError

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603317#comment-17603317 ] Xingbo Huang commented on FLINK-29102: -- Hi [~Yanfei Lei] any updates on this issue?

[jira] [Updated] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28398: - Priority: Major (was: Critical) > CheckpointCoordinatorTriggeringTest.discardingTriggeringCheck

[jira] [Commented] (FLINK-28398) CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest( gets stuck

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603316#comment-17603316 ] Xingbo Huang commented on FLINK-28398: -- Given that it hasn't appeared for two month

[jira] [Closed] (FLINK-28627) KafkaITCase.testBrokerFailure failed with TestTimedOutException: test timed out after 60000 milliseconds

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-28627. Resolution: Cannot Reproduce Given that it hasn't appeared for two months, I will close this issue

[jira] [Updated] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28898: - Priority: Major (was: Critical) > ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnabl

[jira] [Commented] (FLINK-28975) withIdleness marks all streams from FLIP-27 sources as idle

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28975?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603314#comment-17603314 ] Qingsheng Ren commented on FLINK-28975: --- Fixed on master: d62df6899a1d7bd92ae998d3

[jira] [Commented] (FLINK-28898) ChangelogRecoverySwitchStateBackendITCase.testSwitchFromEnablingToDisablingWithRescalingOut failed

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603313#comment-17603313 ] Xingbo Huang commented on FLINK-28898: -- Given that it hasn't appeared for a month,

[jira] [Updated] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-28901: - Priority: Major (was: Critical) > CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed wit

[jira] [Commented] (FLINK-28901) CassandraSinkBaseTest.testTimeoutExceptionOnInvoke failed with TestTimedOutException

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603312#comment-17603312 ] Xingbo Huang commented on FLINK-28901: -- Given that it hasn't appeared for a month,

[jira] [Updated] (FLINK-29031) FlinkKinesisConsumerTest.testSourceSynchronization failed with AssertionFailedError

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29031: - Priority: Major (was: Critical) > FlinkKinesisConsumerTest.testSourceSynchronization failed wit

[jira] [Updated] (FLINK-29008) SortMergeResultPartitionTest.testRelease failed with TestTimedOutException

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29008: - Priority: Major (was: Critical) > SortMergeResultPartitionTest.testRelease failed with TestTime

[jira] [Commented] (FLINK-29008) SortMergeResultPartitionTest.testRelease failed with TestTimedOutException

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603311#comment-17603311 ] Xingbo Huang commented on FLINK-29008: -- Given that it hasn't appeared for a month,

[jira] [Commented] (FLINK-29031) FlinkKinesisConsumerTest.testSourceSynchronization failed with AssertionFailedError

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603310#comment-17603310 ] Xingbo Huang commented on FLINK-29031: -- Given that it hasn't appeared for a month,

[GitHub] [flink] PatrickRen merged pull request #20760: [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both output are idle

2022-09-12 Thread GitBox
PatrickRen merged PR #20760: URL: https://github.com/apache/flink/pull/20760 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.ap

[jira] [Updated] (FLINK-29092) HadoopPathBasedPartFileWriterTest.testWriteFile failed with AssertionError

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang updated FLINK-29092: - Priority: Major (was: Critical) > HadoopPathBasedPartFileWriterTest.testWriteFile failed with A

[jira] [Closed] (FLINK-29147) ChangelogLocalRecoveryITCase.testRestartTM failed with CheckpointException

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-29147. Resolution: Duplicate > ChangelogLocalRecoveryITCase.testRestartTM failed with CheckpointException

[jira] [Closed] (FLINK-27691) RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result mismatch

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingbo Huang closed FLINK-27691. Resolution: Cannot Reproduce Given that it hasn't appeared for a month, I will close this issue. P

[jira] [Commented] (FLINK-29274) HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed

2022-09-12 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603306#comment-17603306 ] Xingbo Huang commented on FLINK-29274: -- [~yzl] Could you help take a look? Thx. >

[jira] [Created] (FLINK-29274) HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed

2022-09-12 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-29274: Summary: HiveServer2EndpointITCase.testGetFunctionWithPattern failed with Persistence Manager has been closed Key: FLINK-29274 URL: https://issues.apache.org/jira/browse/FLINK-292

[jira] [Updated] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29273: - Description: When there are many partitions, the partition writer will seize memory and may hav

[jira] [Updated] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29273: - Attachment: screenshot-1.png > Page not enough Exception in SortBufferMemTable > ---

[jira] [Updated] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-29273: - Description: !screenshot-1.png! (was: !image-2022-09-13-11-03-07-855.png! ) > Page not enou

[jira] [Created] (FLINK-29273) Page not enough Exception in SortBufferMemTable

2022-09-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29273: Summary: Page not enough Exception in SortBufferMemTable Key: FLINK-29273 URL: https://issues.apache.org/jira/browse/FLINK-29273 Project: Flink Issue Type: B

[jira] [Created] (FLINK-29272) Document DataStream API (DataStream to Table) for table store

2022-09-12 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29272: Summary: Document DataStream API (DataStream to Table) for table store Key: FLINK-29272 URL: https://issues.apache.org/jira/browse/FLINK-29272 Project: Flink

[jira] [Updated] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jiangjiguang0719 updated FLINK-29271: - Description: I have done a test to compare byte array and bytebuffer,  40% performance i

[jira] [Commented] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603303#comment-17603303 ] jiangjiguang0719 commented on FLINK-29271: -- please assign me the issue, I will

[jira] [Created] (FLINK-29271) Change to byte array from bytebuffer to improve performance when reading parquet file

2022-09-12 Thread jiangjiguang0719 (Jira)
jiangjiguang0719 created FLINK-29271: Summary: Change to byte array from bytebuffer to improve performance when reading parquet file Key: FLINK-29271 URL: https://issues.apache.org/jira/browse/FLINK-29271

[GitHub] [flink] HuangXingBo closed pull request #20788: [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema

2022-09-12 Thread GitBox
HuangXingBo closed pull request #20788: [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema URL: https://github.com/apache/flink/pull/20788 -- 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] [Updated] (FLINK-29270) Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE

2022-09-12 Thread Muhammad Hilmi Al Fatih (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muhammad Hilmi Al Fatih updated FLINK-29270: Description: I did a very simple kafka-to-kafka pipeline with flink 1.14.4

[jira] [Updated] (FLINK-29270) Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE

2022-09-12 Thread Muhammad Hilmi Al Fatih (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Muhammad Hilmi Al Fatih updated FLINK-29270: Description: I did a very simple kafka-to-kafka pipeline with flink 1.14.4

[jira] [Created] (FLINK-29270) Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE

2022-09-12 Thread Muhammad Hilmi Al Fatih (Jira)
Muhammad Hilmi Al Fatih created FLINK-29270: --- Summary: Wrong metrics kafka producer (FlinkKafkaProducer, KafkaSink) in EXACTLY_ONCE Key: FLINK-29270 URL: https://issues.apache.org/jira/browse/FLINK-29270

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

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603301#comment-17603301 ] Qingsheng Ren commented on FLINK-24119: --- Should be fixed by FLINK-29153. Please re

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

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-24119. - Fix Version/s: 1.16.0 Assignee: Qingsheng Ren Resolution: Fixed > KafkaITCase.te

[GitHub] [flink] PatrickRen commented on pull request #20760: [FLINK-28975][connector/base] Add IdlenessManager for main and per-split output in source operator to mark idleness only if both output ar

2022-09-12 Thread GitBox
PatrickRen commented on PR #20760: URL: https://github.com/apache/flink/pull/20760#issuecomment-1244815251 @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 comment

[jira] [Closed] (FLINK-29018) KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-29018. - Resolution: Fixed > KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

[jira] [Commented] (FLINK-29018) KafkaITCase.testMultipleSourcesOnePartition failed with TopicExistsException

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603300#comment-17603300 ] Qingsheng Ren commented on FLINK-29018: --- Should be fixed by FLINK-29153. Please re

[jira] [Closed] (FLINK-29153) KafkaConsumerThread should catch WakeupException when committing offsets

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-29153. - Resolution: Fixed > KafkaConsumerThread should catch WakeupException when committing offsets > -

[jira] [Comment Edited] (FLINK-29153) KafkaConsumerThread should catch WakeupException when committing offsets

2022-09-12 Thread Qingsheng Ren (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17602076#comment-17602076 ] Qingsheng Ren edited comment on FLINK-29153 at 9/13/22 2:20 AM: --

[GitHub] [flink] reswqa commented on a diff in pull request #20796: [FLINK-29238][runtime] Wrong index information will be obtained after the downstream failover in hybrid full mode

2022-09-12 Thread GitBox
reswqa commented on code in PR #20796: URL: https://github.com/apache/flink/pull/20796#discussion_r969078333 ## flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManagerTest.java: ## @@ -340,6 +341,57 @@ void testRegisterSubpartitionReade

[GitHub] [flink] PatrickRen merged pull request #20794: [BP-1.16][FLINK-29153][connector/kafka] Retry KafkaConsumer#commitAsync on WakeupException in KafkaConsumerThread

2022-09-12 Thread GitBox
PatrickRen merged PR #20794: URL: https://github.com/apache/flink/pull/20794 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.ap

[GitHub] [flink] reswqa commented on a diff in pull request #20796: [FLINK-29238][runtime] Wrong index information will be obtained after the downstream failover in hybrid full mode

2022-09-12 Thread GitBox
reswqa commented on code in PR #20796: URL: https://github.com/apache/flink/pull/20796#discussion_r969078015 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManager.java: ## @@ -192,19 +192,22 @@ public void releaseSubpartitionReade

[GitHub] [flink] reswqa commented on a diff in pull request #20796: [FLINK-29238][runtime] Wrong index information will be obtained after the downstream failover in hybrid full mode

2022-09-12 Thread GitBox
reswqa commented on code in PR #20796: URL: https://github.com/apache/flink/pull/20796#discussion_r969077225 ## flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionView.java: ## @@ -85,10 +86,12 @@ public BufferAndBacklog getNextBuffer(

[GitHub] [flink] bobby-richard commented on a diff in pull request #20048: [FLINK-19869][connectors/jdbc] Add support for postgres UUID type

2022-09-12 Thread GitBox
bobby-richard commented on code in PR #20048: URL: https://github.com/apache/flink/pull/20048#discussion_r969023378 ## flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/PostgresRowConverter.java: ## @@ -59,6 +63,25 @@ public J

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-12 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r968928532 ## flink-core/src/main/java/org/apache/flink/api/connector/source/SourceReaderContext.java: ## @@ -63,4 +63,11 @@ public interface SourceReaderContext { * @see Us

[GitHub] [flink] afedulov commented on a diff in pull request #20757: [FLINK-27919] Add FLIP-27-based source for data generation (FLIP-238)

2022-09-12 Thread GitBox
afedulov commented on code in PR #20757: URL: https://github.com/apache/flink/pull/20757#discussion_r968925284 ## flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/GuavaRateLimiter.java: ## @@ -0,0 +1,38 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Updated] (FLINK-29268) Sync 1.16.0 code to ES repo

2022-09-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-29268: --- Labels: pull-request-available (was: ) > Sync 1.16.0 code to ES repo >

[GitHub] [flink-connector-elasticsearch] zentol commented on pull request #30: [FLINK-29268] Sync with 1.16.0 codebase

2022-09-12 Thread GitBox
zentol commented on PR #30: URL: https://github.com/apache/flink-connector-elasticsearch/pull/30#issuecomment-1244273840 Should be everything now. -- 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

[jira] [Updated] (FLINK-29269) Setup CI logging

2022-09-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-29269: - Description: Logging isn't setup on CI, which breaks some tests that rely on certain mes

[jira] [Created] (FLINK-29269) Setup CI logging

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29269: Summary: Setup CI logging Key: FLINK-29269 URL: https://issues.apache.org/jira/browse/FLINK-29269 Project: Flink Issue Type: Sub-task Compo

[GitHub] [flink] flinkbot commented on pull request #20818: [FLINK-25868][build] Enable japicmp for all modules

2022-09-12 Thread GitBox
flinkbot commented on PR #20818: URL: https://github.com/apache/flink/pull/20818#issuecomment-1244205057 ## CI report: * 5a761b83274189f59204c52e11d2a14aa71fb343 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-29268) Sync 1.16.0 code to ES repo

2022-09-12 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-29268: Summary: Sync 1.16.0 code to ES repo Key: FLINK-29268 URL: https://issues.apache.org/jira/browse/FLINK-29268 Project: Flink Issue Type: Sub-task

[GitHub] [flink] zentol opened a new pull request, #20818: [FLINK-25868][build] Enable japicmp for all modules

2022-09-12 Thread GitBox
zentol opened a new pull request, #20818: URL: https://github.com/apache/flink/pull/20818 1.16 backport of #20814. -- 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 unsubs

[jira] [Commented] (FLINK-25868) Enable japicmp for all modules

2022-09-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603228#comment-17603228 ] Chesnay Schepler commented on FLINK-25868: -- master: ddd034b1528c22fae1802238db

[GitHub] [flink] zentol merged pull request #20817: [FLINK-25868][build] Enable japicmp for all modules

2022-09-12 Thread GitBox
zentol merged PR #20817: URL: https://github.com/apache/flink/pull/20817 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[GitHub] [flink] zentol merged pull request #20814: [FLINK-25868][build] Enable japicmp for all modules

2022-09-12 Thread GitBox
zentol merged PR #20814: URL: https://github.com/apache/flink/pull/20814 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

[jira] [Resolved] (FLINK-29224) flink-mirror does not pick up the new release branch 1.16

2022-09-12 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-29224. - Fix Version/s: 1.17.0 (was: 1.16.0) Resolution: Fixed > flink-mirror does

[jira] [Commented] (FLINK-29224) flink-mirror does not pick up the new release branch 1.16

2022-09-12 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17603225#comment-17603225 ] Jing Ge commented on FLINK-29224: - fixed > flink-mirror does not pick up the new releas

[jira] [Closed] (FLINK-26876) flink-statebackend-rocksdb EmbeddedRocksDBStateBackend crashing on mac m1

2022-09-12 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26876. -- Resolution: Duplicate > flink-statebackend-rocksdb EmbeddedRocksDBStateBackend crashing on mac

[jira] [Updated] (FLINK-25756) Dedicated Opensearch connectors

2022-09-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25756: - Component/s: (was: Connectors / Common) > Dedicated Opensearch connectors >

[jira] [Updated] (FLINK-25756) Dedicated Opensearch connectors

2022-09-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25756: - Fix Version/s: opensearch-1.0.0 > Dedicated Opensearch connectors >

[jira] [Updated] (FLINK-25756) Dedicated Opensearch connectors

2022-09-12 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-25756: - Component/s: Connectors / Opensearch > Dedicated Opensearch connectors > ---

[jira] [Updated] (FLINK-29267) Support external type systems in DDL

2022-09-12 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-29267: - Description: Many connectors and formats require supporting external data types. Postgres users

[GitHub] [flink-web] dannycranmer commented on a diff in pull request #569: Release Flink 1.14.6

2022-09-12 Thread GitBox
dannycranmer commented on code in PR #569: URL: https://github.com/apache/flink-web/pull/569#discussion_r968631259 ## _posts/2022-09-08-release-1.14.6.md: ## @@ -0,0 +1,111 @@ +--- +layout: post +title: "Apache Flink 1.14.6 Release Announcement" +date: 2022-09-08T00:00:00.000Z

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

2022-09-12 Thread GitBox
dannycranmer commented on PR #1: URL: https://github.com/apache/flink-connector-dynamodb/pull/1#issuecomment-1243981647 Please rebase on `main` after this is merged https://github.com/apache/flink-connector-dynamodb/pull/2 -- This is an automated message from the Apache Git Service. To r

  1   2   3   >