[GitHub] [flink-kubernetes-operator] haoxins commented on a diff in pull request #292: [FLINK-28385] Change the validator to return an error if the Jar URI is an empty string

2022-07-05 Thread GitBox
haoxins commented on code in PR #292: URL: https://github.com/apache/flink-kubernetes-operator/pull/292#discussion_r913449561 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/validation/DefaultValidator.java: ## @@ -178,7 +178,7 @@ private Optiona

[GitHub] [flink] deadwind4 opened a new pull request, #20161: [FLINK-28015][table][python] Support FROM_UNIXTIME in Table API

2022-07-05 Thread GitBox
deadwind4 opened a new pull request, #20161: URL: https://github.com/apache/flink/pull/20161 ## What is the purpose of the change Support instr and locate built-in functions in Table API. ## Brief change log - *Support FROM_UNIXTIME built-in functions in Table API.*

[jira] [Updated] (FLINK-28015) FROM_UNIXTIME could not be used in Table API

2022-07-05 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28015: --- Labels: pull-request-available (was: ) > FROM_UNIXTIME could not be used in Table API > ---

[GitHub] [flink] zentol commented on pull request #20155: [FLINK-28379][security] Run all UGI mocking tests in separate JVM

2022-07-05 Thread GitBox
zentol commented on PR #20155: URL: https://github.com/apache/flink/pull/20155#issuecomment-1174696001 @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. T

[jira] [Commented] (FLINK-28010) Use deleteRange to optimize the clear operation of RocksDBMapState.

2022-07-05 Thread ming li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562403#comment-17562403 ] ming li commented on FLINK-28010: - hi, [~yunta], do you think this optimization is feasi

[GitHub] [flink] flinkbot commented on pull request #20161: [FLINK-28015][table][python] Support FROM_UNIXTIME in Table API

2022-07-05 Thread GitBox
flinkbot commented on PR #20161: URL: https://github.com/apache/flink/pull/20161#issuecomment-1174698601 ## CI report: * 146dadc066d67d4c30b52866b2b6d0a26b32cedd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] gaoyunhaii commented on pull request #20108: [FLINK-28240][network] Fix the bug that NetworkBufferPool#getRequestedSegmentsUsage may throw ArithmeticException.

2022-07-05 Thread GitBox
gaoyunhaii commented on PR #20108: URL: https://github.com/apache/flink/pull/20108#issuecomment-1174698823 Merged -- 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 unsubsc

[GitHub] [flink] gaoyunhaii closed pull request #20108: [FLINK-28240][network] Fix the bug that NetworkBufferPool#getRequestedSegmentsUsage may throw ArithmeticException.

2022-07-05 Thread GitBox
gaoyunhaii closed pull request #20108: [FLINK-28240][network] Fix the bug that NetworkBufferPool#getRequestedSegmentsUsage may throw ArithmeticException. URL: https://github.com/apache/flink/pull/20108 -- This is an automated message from the Apache Git Service. To respond to the message, ple

[jira] [Commented] (FLINK-28357) Watermark issue when recovering Finished sources

2022-07-05 Thread James (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562404#comment-17562404 ] James commented on FLINK-28357: --- Great - thanks for the feedback. Understood about the sou

[jira] [Created] (FLINK-28388) Python doc build breaking nightly docs

2022-07-05 Thread Jira
Márton Balassi created FLINK-28388: -- Summary: Python doc build breaking nightly docs Key: FLINK-28388 URL: https://issues.apache.org/jira/browse/FLINK-28388 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28357) Watermark issue when recovering Finished sources

2022-07-05 Thread James (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562405#comment-17562405 ] James commented on FLINK-28357: --- Also - you say "non-chained map" but {+}I believe this pr

[jira] [Commented] (FLINK-28240) NettyShuffleMetricFactory#RequestedMemoryUsageMetric#getValue may throw ArithmeticException when the total segments of NetworkBufferPool is 0

2022-07-05 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562407#comment-17562407 ] Yun Gao commented on FLINK-28240: - Merged on master via c6b3a8aa25607fb62d51b92f11f72778

[jira] [Closed] (FLINK-28240) NettyShuffleMetricFactory#RequestedMemoryUsageMetric#getValue may throw ArithmeticException when the total segments of NetworkBufferPool is 0

2022-07-05 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-28240. --- Fix Version/s: 1.16.0 1.15.2 Assignee: Gen Luo Resolution: Fixed > NettyS

[jira] [Commented] (FLINK-28388) Python doc build breaking nightly docs

2022-07-05 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562408#comment-17562408 ] Márton Balassi commented on FLINK-28388: cc [~dianfu] [~ana4] > Python doc buil

[jira] [Updated] (FLINK-28388) Python doc build breaking nightly docs

2022-07-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-28388: - Component/s: API / Python > Python doc build breaking nightly docs > ---

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #193: [FLINK-28017] Introduce bucket-key to table store

2022-07-05 Thread GitBox
JingsongLi commented on code in PR #193: URL: https://github.com/apache/flink-table-store/pull/193#discussion_r913460665 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/TableSchema.java: ## @@ -129,6 +134,33 @@ public Map options() { ret

[jira] [Created] (FLINK-28389) Correct spec and status updates in FlinkDeploymentControllerTest

2022-07-05 Thread Matyas Orhidi (Jira)
Matyas Orhidi created FLINK-28389: - Summary: Correct spec and status updates in FlinkDeploymentControllerTest Key: FLINK-28389 URL: https://issues.apache.org/jira/browse/FLINK-28389 Project: Flink

[jira] [Assigned] (FLINK-28389) Correct spec and status updates in FlinkDeploymentControllerTest

2022-07-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-28389: -- Assignee: Matyas Orhidi > Correct spec and status updates in FlinkDeploymentControllerTest >

[GitHub] [flink-table-store] JingsongLi merged pull request #194: [FLINK-28381] Add Spark Reader documentation

2022-07-05 Thread GitBox
JingsongLi merged PR #194: URL: https://github.com/apache/flink-table-store/pull/194 -- 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...@

[jira] [Closed] (FLINK-28381) Add Spark Reader documentation

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28381. Resolution: Fixed master: e2612c0cfb8e14e5d1c33df280e827f3f67c0426 > Add Spark Reader documentati

[jira] [Assigned] (FLINK-28352) [Umbrella] Make Pulsar connector stable

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28352: -- Assignee: Yufan Sheng (was: Yufei Zhang) > [Umbrella] Make Pulsar connector stable >

[jira] [Assigned] (FLINK-28352) [Umbrella] Make Pulsar connector stable

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-28352: -- Assignee: Yufei Zhang > [Umbrella] Make Pulsar connector stable > ---

[jira] [Assigned] (FLINK-26721) PulsarSourceITCase.testSavepoint failed on azure pipeline

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-26721: -- Assignee: Yufan Sheng (was: Martijn Visser) > PulsarSourceITCase.testSavepoint faile

[jira] [Updated] (FLINK-26402) MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste failed due to Container startup failed

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26402: --- Priority: Major (was: Critical) > MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBe

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #195: [FLINK-26901] Introduce config options document for table store

2022-07-05 Thread GitBox
JingsongLi commented on code in PR #195: URL: https://github.com/apache/flink-table-store/pull/195#discussion_r913466400 ## docs/content/docs/development/configuration.md: ## @@ -0,0 +1,53 @@ +--- +title: "Configuration" +weight: 6 +type: docs +aliases: +- /development/configura

[jira] [Updated] (FLINK-26402) MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBeforeInitializingFileSyste failed due to Container startup failed

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26402: --- Priority: Critical (was: Major) > MinioTestContainerTest.testS3EndpointNeedsToBeSpecifiedBe

[jira] [Assigned] (FLINK-26600) PerJobMiniClusterFactoryTest.testJobClientSavepoint failed on azure

2022-07-05 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-26600: Assignee: Chesnay Schepler > PerJobMiniClusterFactoryTest.testJobClientSavepoint

[GitHub] [flink] MartijnVisser commented on a diff in pull request #20014: [FLINK-26979][table-planner] Correct the race condition on transformation node id

2022-07-05 Thread GitBox
MartijnVisser commented on code in PR #20014: URL: https://github.com/apache/flink/pull/20014#discussion_r913466628 ## flink-core/src/main/java/org/apache/flink/api/dag/Transformation.java: ## @@ -108,11 +109,10 @@ public static final int UPPER_BOUND_MAX_PARALLELISM = 1 <<

[GitHub] [flink] echauchot commented on pull request #19935: [FLINK-27884] Move OutputFormatBase to flink-core to offer flush mechanism to all output formats

2022-07-05 Thread GitBox
echauchot commented on PR #19935: URL: https://github.com/apache/flink/pull/19935#issuecomment-1174709407 @zentol friendly ping -- 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 commen

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562414#comment-17562414 ] Martijn Visser commented on FLINK-24960: [~mapohl] What's the current status of

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

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562415#comment-17562415 ] Martijn Visser commented on FLINK-27691: Downgrading to Major due to lack of occ

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

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27691: --- Priority: Major (was: Critical) > RankHarnessTest. testUpdateRankWithRowNumberSortKeyDropsT

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #195: [FLINK-26901] Introduce config options document for table store

2022-07-05 Thread GitBox
JingsongLi commented on code in PR #195: URL: https://github.com/apache/flink-table-store/pull/195#discussion_r913468538 ## docs/layouts/shortcodes/generated/core_configuration.html: ## @@ -0,0 +1,204 @@ + + + +Key +Default +Type +

[jira] [Commented] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562416#comment-17562416 ] Martijn Visser commented on FLINK-25233: Downgrading to Major due to lack of occ

[jira] [Updated] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25233: --- Priority: Major (was: Critical) > UpsertKafkaTableITCase.testAggregate fails on AZP > -

[GitHub] [flink] echauchot commented on pull request #19944: [FLINK-26793][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format

2022-07-05 Thread GitBox
echauchot commented on PR #19944: URL: https://github.com/apache/flink/pull/19944#issuecomment-1174710605 @MartijnVisser @zentol friendly ping -- 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

[jira] [Updated] (FLINK-25233) UpsertKafkaTableITCase.testAggregate fails on AZP

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25233: --- Fix Version/s: (was: 1.16.0) > UpsertKafkaTableITCase.testAggregate fails on AZP > -

[GitHub] [flink] MartijnVisser commented on pull request #19944: [FLINK-26793][documentation] Add recommendations about the write timeout to the javadoc of Cassandra sink and output format

2022-07-05 Thread GitBox
MartijnVisser commented on PR #19944: URL: https://github.com/apache/flink/pull/19944#issuecomment-1174712127 @echauchot Sorry, I'll have a look today :) -- 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] [Created] (FLINK-28390) Allows RocksDB to configure FIFO Compaction to reduce CPU overhead.

2022-07-05 Thread ming li (Jira)
ming li created FLINK-28390: --- Summary: Allows RocksDB to configure FIFO Compaction to reduce CPU overhead. Key: FLINK-28390 URL: https://issues.apache.org/jira/browse/FLINK-28390 Project: Flink Is

[GitHub] [flink] HeChuanXUPT commented on pull request #18310: [FLINK-16627] Flink-SQL json format add non-null optinon

2022-07-05 Thread GitBox
HeChuanXUPT commented on PR #18310: URL: https://github.com/apache/flink/pull/18310#issuecomment-1174717088 Does anyone have any suggestions ? or some one has another progress ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

2022-07-05 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562417#comment-17562417 ] Matthias Pohl commented on FLINK-24960: --- [~nsemmler] provided a workaround where w

[jira] [Commented] (FLINK-28274) ContinuousFileMonitoringFunction doesn't work with reactive mode

2022-07-05 Thread zl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562419#comment-17562419 ] zl commented on FLINK-28274: -- Does this problem only occur for \{ContinuousFileMonitoringF

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562424#comment-17562424 ] Martijn Visser commented on FLINK-24960: Are we OK with downgrading this to a Ma

[jira] [Commented] (FLINK-28274) ContinuousFileMonitoringFunction doesn't work with reactive mode

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562423#comment-17562423 ] Martijn Visser commented on FLINK-28274: -- The legacy source are still widely u

[GitHub] [flink-kubernetes-operator] morhidi commented on pull request #293: [FLINK-28348] Add configurable flag to disable last-state fallback for savepoint upgrade

2022-07-05 Thread GitBox
morhidi commented on PR #293: URL: https://github.com/apache/flink-kubernetes-operator/pull/293#issuecomment-1174725973 @gyfora addressed your comments, PTAL -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

[jira] [Updated] (FLINK-26621) flink-tests failed on azure due to Error occurred in starting fork

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26621: --- Priority: Critical (was: Blocker) > flink-tests failed on azure due to Error occurred in st

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

2022-07-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562425#comment-17562425 ] Gyula Fora commented on FLINK-27009: In the meantime I will work on adding an exampl

[jira] [Updated] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23391: --- Fix Version/s: (was: 1.16.0) > KafkaSourceReaderTest.testKafkaSourceMetrics fails on azu

[jira] [Updated] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23391: --- Priority: Major (was: Critical) > KafkaSourceReaderTest.testKafkaSourceMetrics fails on azu

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562426#comment-17562426 ] Martijn Visser commented on FLINK-23391: Downgrading to major due to lack of occ

[jira] [Updated] (FLINK-23740) SQL Full Outer Join bug

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23740: --- Affects Version/s: 1.14.5 1.13.6 1.15.0

[jira] [Updated] (FLINK-23740) SQL Full Outer Join bug

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23740: --- Fix Version/s: (was: 1.16.0) > SQL Full Outer Join bug > --- > >

[jira] [Updated] (FLINK-23740) SQL Full Outer Join bug

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-23740: --- Priority: Major (was: Critical) > SQL Full Outer Join bug > --- > >

[jira] [Created] (FLINK-28391) DefaultBlocklistHandlerTest unstable

2022-07-05 Thread Paul Lin (Jira)
Paul Lin created FLINK-28391: Summary: DefaultBlocklistHandlerTest unstable Key: FLINK-28391 URL: https://issues.apache.org/jira/browse/FLINK-28391 Project: Flink Issue Type: Bug Compon

[GitHub] [flink-table-store] JingsongLi merged pull request #191: [FLINK-26439] Introduce sequence.field to custom the order of the records

2022-07-05 Thread GitBox
JingsongLi merged PR #191: URL: https://github.com/apache/flink-table-store/pull/191 -- 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...@

[jira] [Commented] (FLINK-23740) SQL Full Outer Join bug

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562427#comment-17562427 ] Martijn Visser commented on FLINK-23740: Downgraded to major due to lack of acti

[GitHub] [flink-table-store] JingsongLi merged pull request #193: [FLINK-28017] Introduce bucket-key to table store

2022-07-05 Thread GitBox
JingsongLi merged PR #193: URL: https://github.com/apache/flink-table-store/pull/193 -- 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...@

[jira] [Commented] (FLINK-28159) Table Store: Bucket pruning based on primary key filter

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562428#comment-17562428 ] Jingsong Lee commented on FLINK-28159: -- [~liliwei] Thanks for your attention. This

[jira] [Closed] (FLINK-26439) Introduce sequence.field to custom the order of the records

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-26439. Resolution: Fixed master: 9f243ed8e6b8dc361b73f1dcafb4f8c13cb11263 > Introduce sequence.field to

[jira] [Closed] (FLINK-28017) Introduce bucket-key to table store

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28017. Resolution: Fixed master: 907747d3e37b7edb5c1bec5209e47bd4ff9f737b > Introduce bucket-key to tabl

[jira] [Commented] (FLINK-28274) ContinuousFileMonitoringFunction doesn't work with reactive mode

2022-07-05 Thread zl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562433#comment-17562433 ] zl commented on FLINK-28274: `Without an incentive for users to migrate, they will never do

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #293: [FLINK-28348] Add configurable flag to disable last-state fallback for savepoint upgrade

2022-07-05 Thread GitBox
gyfora merged PR #293: URL: https://github.com/apache/flink-kubernetes-operator/pull/293 -- 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

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

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24119: --- Fix Version/s: (was: 1.16.0) > KafkaITCase.testTimestamps fails due to "Topic xxx alread

[jira] [Updated] (FLINK-24241) test_table_environment_api.py fail with NPE

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24241: --- Priority: Major (was: Critical) > test_table_environment_api.py fail with NPE > ---

[jira] [Updated] (FLINK-24241) test_table_environment_api.py fail with NPE

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24241: --- Fix Version/s: (was: 1.16.0) > test_table_environment_api.py fail with NPE > ---

[jira] [Closed] (FLINK-28348) Add configurable flag to disable last-state fallback for savepoint upgrade

2022-07-05 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-28348. -- Resolution: Fixed merged to main 17723ffc09b6813006044f50165bb6cf15427df7 > Add configurable flag to

[jira] [Commented] (FLINK-24241) test_table_environment_api.py fail with NPE

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562435#comment-17562435 ] Martijn Visser commented on FLINK-24241: Downgraded to major due to lack of acti

[jira] [Updated] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24744: --- Fix Version/s: (was: 1.16.0) > FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExac

[jira] [Updated] (FLINK-24743) New File Sink end-to-end test fails on Azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24743: --- Fix Version/s: (was: 1.16.0) > New File Sink end-to-end test fails on Azure > --

[jira] [Updated] (FLINK-24743) New File Sink end-to-end test fails on Azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24743: --- Priority: Major (was: Critical) > New File Sink end-to-end test fails on Azure > --

[jira] [Updated] (FLINK-24744) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on Azure because org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24744: --- Priority: Major (was: Critical) > FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExac

[jira] [Closed] (FLINK-24795) FlinkKafkaProducerITCase.testRunOutOfProducersInThePool times out on AZP

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24795?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-24795. -- Fix Version/s: (was: 1.16.0) Resolution: Cannot Reproduce > FlinkKafkaProducerITCas

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24960: --- Priority: Major (was: Critical) > YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrec

[jira] [Updated] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots hang

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24960: --- Fix Version/s: (was: 1.16.0) (was: 1.15.1) > YARNSessionCapacityS

[jira] [Closed] (FLINK-25214) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce fails on AZP with incorrect result

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-25214. -- Fix Version/s: (was: 1.16.0) Resolution: Cannot Reproduce > FlinkKafkaProducerITCas

[jira] [Assigned] (FLINK-28221) Savepoint may corrupt file metas by repeat commit

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28221: Assignee: Caizhi Weng > Savepoint may corrupt file metas by repeat commit > -

[jira] [Assigned] (FLINK-28108) Support compaction for append-only table

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28108: Assignee: Jane Chan > Support compaction for append-only table >

[GitHub] [flink] MartijnVisser commented on pull request #20158: [FLINK-28357][datastream] Disallow null elements in StreamNode#typeSerializersIn

2022-07-05 Thread GitBox
MartijnVisser commented on PR #20158: URL: https://github.com/apache/flink/pull/20158#issuecomment-1174738789 @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 comm

[jira] [Assigned] (FLINK-28159) Table Store: Bucket pruning based on primary key filter

2022-07-05 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-28159: Assignee: Jingsong Lee > Table Store: Bucket pruning based on primary key filter > --

[jira] [Comment Edited] (FLINK-26764) Support RESPECT NULLS for FIRST_VALUE/LAST_VALUE

2022-07-05 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562047#comment-17562047 ] Jark Wu edited comment on FLINK-26764 at 7/5/22 7:57 AM: - I chec

[jira] [Commented] (FLINK-28159) Table Store: Bucket pruning based on primary key filter

2022-07-05 Thread liwei li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562397#comment-17562397 ] liwei li commented on FLINK-28159: -- Not sure I can handle it, but I'd like to try, may

[GitHub] [flink] fsk119 commented on a diff in pull request #19846: [FLINK-27768][sql-gateway] Allow executing sql for the SqlGatewayService

2022-07-05 Thread GitBox
fsk119 commented on code in PR #19846: URL: https://github.com/apache/flink/pull/19846#discussion_r913501319 ## flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/utils/SqlGatewayServiceExtension.java: ## @@ -43,6 +47,15 @@ public class SqlGateway

[jira] [Updated] (FLINK-26548) the source parallelism is not set correctly with AdaptiveBatchScheduler

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26548: --- Fix Version/s: (was: 1.16.0) > the source parallelism is not set correctly with Adaptive

[GitHub] [flink] chucheng92 commented on pull request #19827: [FLINK-27806][table] Support binary & varbinary types in datagen connector

2022-07-05 Thread GitBox
chucheng92 commented on PR #19827: URL: https://github.com/apache/flink/pull/19827#issuecomment-1174745279 @PatrickRen hi, qingsheng, can u help me to review this pr? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Updated] (FLINK-26912) EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26912: --- Fix Version/s: (was: 1.16.0) > EventTimeWindowCheckpointingITCase.testTumblingTimeWindow

[jira] [Updated] (FLINK-26912) EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26912: --- Fix Version/s: 1.16.0 > EventTimeWindowCheckpointingITCase.testTumblingTimeWindow failed on

[jira] [Commented] (FLINK-27074) python_job.py should write to TEST_DATA_DIR

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562443#comment-17562443 ] Martijn Visser commented on FLINK-27074: [~hxbks2ks] Can you have a look at this

[jira] [Assigned] (FLINK-27074) python_job.py should write to TEST_DATA_DIR

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-27074: -- Assignee: Thomas Thornton > python_job.py should write to TEST_DATA_DIR > ---

[GitHub] [flink] MartijnVisser commented on pull request #19734: [FLINK-27492][table] Introduce flink-table-api-scala-uber for convenience

2022-07-05 Thread GitBox
MartijnVisser commented on PR #19734: URL: https://github.com/apache/flink/pull/19734#issuecomment-1174747313 @twalthr Do you have time to finalize this one? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Updated] (FLINK-27944) IO metrics collision happens if a task has union inputs

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27944: --- Priority: Major (was: Critical) > IO metrics collision happens if a task has union inputs >

[jira] [Assigned] (FLINK-27944) IO metrics collision happens if a task has union inputs

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-27944: -- Assignee: xiaogang zhou > IO metrics collision happens if a task has union inputs > -

[jira] [Updated] (FLINK-27944) IO metrics collision happens if a task has union inputs

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27944: --- Fix Version/s: (was: 1.16.0) (was: 1.15.2) > IO metrics collision

[jira] [Updated] (FLINK-24872) PulsarSourceITCase.testMultipleSplits failed on AZP

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-24872: --- Fix Version/s: (was: 1.16.0) > PulsarSourceITCase.testMultipleSplits failed on AZP > ---

[jira] [Commented] (FLINK-28183) flink-python is lacking several test dependencies

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562444#comment-17562444 ] Martijn Visser commented on FLINK-28183: [~hxbks2ks] Is this something that you

[jira] [Commented] (FLINK-28391) DefaultBlocklistHandlerTest unstable

2022-07-05 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17562446#comment-17562446 ] Lijie Wang commented on FLINK-28391: I will take a look. > DefaultBlocklistHandlerT

[jira] [Updated] (FLINK-26979) JsonFunctionsITCase.test failed on azure

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26979: --- Fix Version/s: 1.16.0 > JsonFunctionsITCase.test failed on azure > -

[jira] [Updated] (FLINK-28198) CassandraConnectorITCase fails with timeout

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28198: --- Fix Version/s: 1.16.0 > CassandraConnectorITCase fails with timeout > --

[jira] [Updated] (FLINK-28176) test_es_sink_dynamic failed in jdk11

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28176: --- Fix Version/s: 1.16.0 > test_es_sink_dynamic failed in jdk11 > -

[jira] [Updated] (FLINK-27745) ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoundError

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-27745: --- Fix Version/s: 1.16.0 > ClientUtilsTest.uploadAndSetUserArtifacts failed with NoClassDefFoun

[jira] [Updated] (FLINK-28379) KerberosLoginProviderTest static UGI mock leaks into other tests

2022-07-05 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-28379: --- Fix Version/s: 1.16.0 > KerberosLoginProviderTest static UGI mock leaks into other tests > -

  1   2   3   4   5   6   7   >