[jira] [Commented] (FLINK-30221) Fix the bug of sum(try_cast(string as bigint)) return null when partial elements can't convert to bigint

2022-11-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640448#comment-17640448 ] Martijn Visser commented on FLINK-30221: Why is this a bug? Because the entire purpose of

[jira] [Commented] (FLINK-30232) shading of netty epoll shared library does not account for ARM64 platform

2022-11-28 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640445#comment-17640445 ] Martijn Visser commented on FLINK-30232: [~cthomson] Thanks for the report! Do you want to open

[GitHub] [flink] XComp commented on pull request #20755: [FLINK-29092][tests] Use base path bucket assigner

2022-11-28 Thread GitBox
XComp commented on PR #20755: URL: https://github.com/apache/flink/pull/20755#issuecomment-1330198111 @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.

[GitHub] [flink] XComp commented on pull request #20755: [FLINK-29092][tests] Use base path bucket assigner

2022-11-28 Thread GitBox
XComp commented on PR #20755: URL: https://github.com/apache/flink/pull/20755#issuecomment-1330197844 The test failure is not related to the change: I created FLINK-30236 to cover the timeout issue in the Kafka-related test -- This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-30236) UpsertKafkaTableITCase failed due to timeout when creating a topic

2022-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640434#comment-17640434 ] Matthias Pohl commented on FLINK-30236: --- There's [another stacktrace

[jira] [Created] (FLINK-30236) UpsertKafkaTableITCase failed due to timeout when creating a topic

2022-11-28 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30236: - Summary: UpsertKafkaTableITCase failed due to timeout when creating a topic Key: FLINK-30236 URL: https://issues.apache.org/jira/browse/FLINK-30236 Project: Flink

[GitHub] [flink] alpinegizmo commented on a diff in pull request #21349: Support Maven 3.3+

2022-11-28 Thread GitBox
alpinegizmo commented on code in PR #21349: URL: https://github.com/apache/flink/pull/21349#discussion_r1034376565 ## tools/ci/flink-ci-tools/src/main/java/org/apache/flink/tools/ci/optional/ShadeOptionalChecker.java: ## @@ -65,9 +65,23 @@ public static void main(String[] args)

[jira] [Updated] (FLINK-30037) Improve the efficiency of Flink ML Python CI

2022-11-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30037: - Fix Version/s: ml-2.2.0 > Improve the efficiency of Flink ML Python CI >

[jira] [Resolved] (FLINK-30037) Improve the efficiency of Flink ML Python CI

2022-11-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved FLINK-30037. -- Resolution: Fixed > Improve the efficiency of Flink ML Python CI >

[jira] [Assigned] (FLINK-30037) Improve the efficiency of Flink ML Python CI

2022-11-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-30037: Assignee: Yunfeng Zhou > Improve the efficiency of Flink ML Python CI >

[jira] [Created] (FLINK-30235) Comprehensive benchmarks on changelog checkpointing

2022-11-28 Thread Rui Xia (Jira)
Rui Xia created FLINK-30235: --- Summary: Comprehensive benchmarks on changelog checkpointing Key: FLINK-30235 URL: https://issues.apache.org/jira/browse/FLINK-30235 Project: Flink Issue Type:

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #182: [FLINK-30160] Add Transformer for FValueTest

2022-11-28 Thread GitBox
yunfengzhou-hub commented on code in PR #182: URL: https://github.com/apache/flink-ml/pull/182#discussion_r1031974363 ## flink-ml-lib/src/main/java/org/apache/flink/ml/stats/fvaluetest/FValueTest.java: ## @@ -0,0 +1,370 @@ +/* Review Comment: Let's add this class to the

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #181: [FLINK-30124] Support collecting model data with arrays and maps

2022-11-28 Thread GitBox
lindong28 commented on code in PR #181: URL: https://github.com/apache/flink-ml/pull/181#discussion_r1034363906 ## flink-ml-python/pyflink/ml/tests/test_utils.py: ## @@ -51,15 +51,17 @@ def setUp(self): self.t_env = StreamTableEnvironment.create(self.env)

[jira] [Created] (FLINK-30234) SourceReaderBase should provide an option to disable numRecordsIn metric registration

2022-11-28 Thread Qingsheng Ren (Jira)
Qingsheng Ren created FLINK-30234: - Summary: SourceReaderBase should provide an option to disable numRecordsIn metric registration Key: FLINK-30234 URL: https://issues.apache.org/jira/browse/FLINK-30234

[GitHub] [flink-ml] lindong28 merged pull request #185: [FLINK-30037] Use shared mini-cluster in python tests

2022-11-28 Thread GitBox
lindong28 merged PR #185: URL: https://github.com/apache/flink-ml/pull/185 -- 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-ml] lindong28 commented on pull request #185: [FLINK-30037] Use shared mini-cluster in python tests

2022-11-28 Thread GitBox
lindong28 commented on PR #185: URL: https://github.com/apache/flink-ml/pull/185#issuecomment-1330164677 Thanks for the PR. It is great to see that the PR considerably reduced the overall python test time from more than 60 minutes to 10 minutes! LGTM. -- This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #21415: [FLINK-30189] HsSubpartitionFileReader may load data that has been consumed from memory

2022-11-28 Thread GitBox
flinkbot commented on PR #21415: URL: https://github.com/apache/flink/pull/21415#issuecomment-1330160641 ## CI report: * 9df038f609e7b90d030a7d6009ed1ffcec8528df UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] XComp commented on pull request #21412: [BP-1.15][FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase. (#21252)

2022-11-28 Thread GitBox
XComp commented on PR #21412: URL: https://github.com/apache/flink/pull/21412#issuecomment-1330159554 @syhily can you have a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] XComp commented on pull request #21411: [BP-1.16][FLINK-29830][Connector/Pulsar] Create the topic with schema before consuming messages in PulsarSinkITCase. (#21252)

2022-11-28 Thread GitBox
XComp commented on PR #21411: URL: https://github.com/apache/flink/pull/21411#issuecomment-1330159487 @syhily can you have a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-30189) HsSubpartitionFileReader may load data that has been consumed from memory

2022-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30189: --- Labels: pull-request-available (was: ) > HsSubpartitionFileReader may load data that has

[GitHub] [flink] reswqa opened a new pull request, #21415: [FLINK-30189] HsSubpartitionFileReader may load data that has been consumed from memory

2022-11-28 Thread GitBox
reswqa opened a new pull request, #21415: URL: https://github.com/apache/flink/pull/21415 ## What is the purpose of the change *In order to solve the problem that data cannot be read from the disk correctly after failover, we changed the calculation logical of the buffer's readable

[jira] [Commented] (FLINK-30225) Convergence test failed once after reference version upgrade to 1.15.3

2022-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640418#comment-17640418 ] Matthias Pohl commented on FLINK-30225: --- > But the guide already says to wait 24h after finalizing

[jira] [Comment Edited] (FLINK-30225) Convergence test failed once after reference version upgrade to 1.15.3

2022-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640418#comment-17640418 ] Matthias Pohl edited comment on FLINK-30225 at 11/29/22 6:39 AM: -

[GitHub] [flink-ml] zhipeng93 merged pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
zhipeng93 merged PR #184: URL: https://github.com/apache/flink-ml/pull/184 -- 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-ml] zhipeng93 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
zhipeng93 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1330152353 Thanks for the PR. LGTM. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Resolved] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

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

[jira] [Comment Edited] (FLINK-27846) Schema evolution for data file reading

2022-11-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640003#comment-17640003 ] Jingsong Lee edited comment on FLINK-27846 at 11/29/22 6:12 AM: master:

[GitHub] [flink-table-store] JingsongLi merged pull request #407: [FLINK-27846] Remove AlwaysTrue and AlwaysFalse

2022-11-28 Thread GitBox
JingsongLi merged PR #407: URL: https://github.com/apache/flink-table-store/pull/407 -- 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 merged pull request #21387: [FLINK-30183][metrics] Adds more descriptive error in case no default constructor is present.

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

[jira] [Closed] (FLINK-30225) Convergence test failed once after reference version upgrade to 1.15.3

2022-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl closed FLINK-30225. - Resolution: Cannot Reproduce Closing issue. Even the nightly build didn't run into issues

[jira] [Comment Edited] (FLINK-30225) Convergence test failed once after reference version upgrade to 1.15.3

2022-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640413#comment-17640413 ] Matthias Pohl edited comment on FLINK-30225 at 11/29/22 6:11 AM: -

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

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

[GitHub] [flink-table-store] zjureel commented on pull request #407: [FLINK-27846] Remove AlwaysTrue and AlwaysFalse

2022-11-28 Thread GitBox
zjureel commented on PR #407: URL: https://github.com/apache/flink-table-store/pull/407#issuecomment-1330132085 Thanks @JingsongLi LGTM -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

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

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

[jira] [Comment Edited] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

2022-11-28 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640409#comment-17640409 ] Matthias Pohl edited comment on FLINK-29461 at 11/29/22 6:04 AM: - Same

[jira] [Commented] (FLINK-29461) ProcessDataStreamStreamingTests.test_process_function unstable

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

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

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

[jira] [Commented] (FLINK-29835) NoClassDefFoundError in PulsarSourceUnorderedE2ECase

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

[GitHub] [flink-ml] lindong28 commented on a diff in pull request #185: [FLINK-30037] Use shared mini-cluster in python tests

2022-11-28 Thread GitBox
lindong28 commented on code in PR #185: URL: https://github.com/apache/flink-ml/pull/185#discussion_r1034328331 ## flink-ml-python/pyflink/ml/tests/test_utils.py: ## @@ -37,10 +39,35 @@ def update_existing_params(target: JavaWithParams, source: JavaWithParams): class

[jira] [Commented] (FLINK-29856) Triggering savepoint does not trigger operator notifyCheckpointComplete

2022-11-28 Thread Mason Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640385#comment-17640385 ] Mason Chen commented on FLINK-29856: [~dwysakowicz] [~yunta] [~pnowojski] (contributors involved w/

[jira] [Commented] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

2022-11-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640380#comment-17640380 ] Weijie Guo commented on FLINK-30198: IMO, it seems too strange to identify the hash input and then

[GitHub] [flink-table-store] JingsongLi opened a new pull request, #407: [FLINK-27846] Remove AlwaysTrue and AlwaysFalse

2022-11-28 Thread GitBox
JingsongLi opened a new pull request, #407: URL: https://github.com/apache/flink-table-store/pull/407 Other engines can not support `AlwaysTrue`, `AlwaysFalse`, we can just remove the predicate if field not found. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-30233) Hybrid full result partition should also work with speculative execution

2022-11-28 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-30233: -- Summary: Hybrid full result partition should also work with speculative execution Key: FLINK-30233 URL: https://issues.apache.org/jira/browse/FLINK-30233 Project: Flink

[jira] [Comment Edited] (FLINK-27787) New tasks think they've been restored from savepoint (even when they weren't present in that savepoint)

2022-11-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640369#comment-17640369 ] Yanfei Lei edited comment on FLINK-27787 at 11/29/22 4:03 AM: -- [~arvid]

[jira] [Commented] (FLINK-27787) New tasks think they've been restored from savepoint (even when they weren't present in that savepoint)

2022-11-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27787?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640369#comment-17640369 ] Yanfei Lei commented on FLINK-27787: [~arvid] could you please take a look?  I found that

[jira] [Updated] (FLINK-30037) Improve the efficiency of Flink ML Python CI

2022-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30037: --- Labels: pull-request-available (was: ) > Improve the efficiency of Flink ML Python CI >

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request, #185: [FLINK-30037] Use shared mini-cluster in python tests

2022-11-28 Thread GitBox
yunfengzhou-hub opened a new pull request, #185: URL: https://github.com/apache/flink-ml/pull/185 ## What is the purpose of the change This pull request optimizes the efficiency of Flink ML python tests by enabling the use of shared mini cluster in python tests. ## Brief

[GitHub] [flink-table-store] zjureel commented on pull request #344: [FLINK-29823] Support to get schema of table snapshot

2022-11-28 Thread GitBox
zjureel commented on PR #344: URL: https://github.com/apache/flink-table-store/pull/344#issuecomment-1330040895 Hi @JingsongLi Sorry for replying late. I think `MyTable$schemas` is so good that we cannot to check the schema change history from Table Store currently. I think we can create

[GitHub] [flink-ml] lindong28 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
lindong28 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1330036570 @HuangXingBo can you help 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 URL above to go to

[GitHub] [flink-ml] lindong28 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
lindong28 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1330034703 @zhipeng93 @yunfengzhou-hub @jiangxin369 can you 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

[GitHub] [flink-ml] lindong28 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
lindong28 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1330034476 The sixth round of tests succeeded. https://github.com/apache/flink-ml/actions/runs/3570261026 -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-table-store] JingsongLi commented on pull request #347: [FLINK-27847] Support rename/drop column in SchemaManager

2022-11-28 Thread GitBox
JingsongLi commented on PR #347: URL: https://github.com/apache/flink-table-store/pull/347#issuecomment-1330032927 Hi @zjureel , we can continue the work of 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] [Closed] (FLINK-29964) Support Spark/Hive with OSS

2022-11-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29964. Assignee: Jane Chan Resolution: Fixed master: 18cdaee7cf6eb3fadeeb958ecb3b3c4a7bd57440 >

[GitHub] [flink-table-store] JingsongLi merged pull request #369: [FLINK-29964] Support Spark/Hive with OSS

2022-11-28 Thread GitBox
JingsongLi merged PR #369: URL: https://github.com/apache/flink-table-store/pull/369 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-29983) Table Store with Hive3 profile lacks hive-standalone-metastore dependency

2022-11-28 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-29983. Assignee: Jane Chan Resolution: Fixed master: 6152dbc07a4e802d77f0e2140c345f497306c948 >

[GitHub] [flink-table-store] JingsongLi merged pull request #373: [FLINK-29983] Fix Table Store with Hive3 lacking hive-standalone-metastore dependency

2022-11-28 Thread GitBox
JingsongLi merged PR #373: URL: https://github.com/apache/flink-table-store/pull/373 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-29789) Fix flaky tests in CheckpointCoordinatorTest

2022-11-28 Thread Sopan Phaltankar (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640352#comment-17640352 ] Sopan Phaltankar commented on FLINK-29789: -- [~martijnvisser] any thoughts? > Fix flaky tests

[GitHub] [flink-ml] lindong28 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
lindong28 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1329986916 Fourth and Fifth rounds of tests succeeded. https://github.com/apache/flink-ml/actions/runs/3566599097 https://github.com/apache/flink-ml/actions/runs/3568456675 -- This

[GitHub] [flink-ml] lindong28 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
lindong28 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1329985845 Third round of tests failed due to NullPointerException from `RelMetadataQuery`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] liyubin117 commented on a diff in pull request #21182: [FLINK-29679][table] Migrate to new schema framework & show column comment

2022-11-28 Thread GitBox
liyubin117 commented on code in PR #21182: URL: https://github.com/apache/flink/pull/21182#discussion_r1031324721 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/typeutils/TimeIndicatorTypeInfo.java: ## @@ -62,13 +61,10 @@ protected

[jira] [Commented] (FLINK-29640) Enhance the function configured by execution.shutdown-on-attached-exit by heartbeat between client and dispatcher

2022-11-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640338#comment-17640338 ] Xintong Song commented on FLINK-29640: -- Sure, I'll take a look. > Enhance the function configured

[jira] [Commented] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

2022-11-28 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640337#comment-17640337 ] Lijie Wang commented on FLINK-30198: [~zhuzh] Would you like share your thoughs? > Support

[jira] [Comment Edited] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

2022-11-28 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640337#comment-17640337 ] Lijie Wang edited comment on FLINK-30198 at 11/29/22 1:54 AM: -- [~zhuzh]

[jira] [Commented] (FLINK-30198) Support AdaptiveBatchScheduler to set per-task size for reducer task

2022-11-28 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640333#comment-17640333 ] Lijie Wang commented on FLINK-30198: My main concern here is that Flink does not have the concept of

[GitHub] [flink-ml] lindong28 commented on pull request #184: [hotfix] Update python tests to set execution.attached=True

2022-11-28 Thread GitBox
lindong28 commented on PR #184: URL: https://github.com/apache/flink-ml/pull/184#issuecomment-1329970056 Second round of tests failed due to `Py4JNetworkError("Answer from Java side is empty")` https://github.com/apache/flink-ml/actions/runs/3565699798/jobs/5991195736 -- This is

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640323#comment-17640323 ] Benchao Li commented on FLINK-30158: [~jamesmcguirepro] The schema for 'second' seems not correct.

[jira] [Commented] (FLINK-29801) OperatorCoordinator need open the way to operate metricGroup interface

2022-11-28 Thread Steven Zhen Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640306#comment-17640306 ] Steven Zhen Wu commented on FLINK-29801: This is an important missing part of coordinator. I am

[jira] [Commented] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-11-28 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640298#comment-17640298 ] Thomas Weise commented on FLINK-29099: -- [~sethsaperstein] thanks for the thorough investigation and

[jira] [Resolved] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-11-28 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-29099. -- Fix Version/s: 1.17.0 Resolution: Fixed > Deadlock for Single Subtask in Kinesis

[jira] [Assigned] (FLINK-29099) Deadlock for Single Subtask in Kinesis Consumer

2022-11-28 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise reassigned FLINK-29099: Assignee: seth saperstein > Deadlock for Single Subtask in Kinesis Consumer >

[GitHub] [flink] tweise merged pull request #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-11-28 Thread GitBox
tweise merged PR #20844: URL: https://github.com/apache/flink/pull/20844 -- 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-opensearch] reta commented on a diff in pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-11-28 Thread GitBox
reta commented on code in PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#discussion_r1034107205 ## flink-connector-opensearch/src/main/java/org/apache/flink/streaming/connectors/opensearch/OpensearchSink.java: ## @@ -0,0 +1,807 @@ +/* + * Licensed to

[jira] [Created] (FLINK-30232) shading of netty epoll shared library does not account for ARM64 platform

2022-11-28 Thread Chris Thomson (Jira)
Chris Thomson created FLINK-30232: - Summary: shading of netty epoll shared library does not account for ARM64 platform Key: FLINK-30232 URL: https://issues.apache.org/jira/browse/FLINK-30232 Project:

[jira] [Updated] (FLINK-30054) Move existing Pulsar connector code from Flink repo to dedicated Pulsar repo

2022-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30054: --- Labels: pull-request-available (was: ) > Move existing Pulsar connector code from Flink

[GitHub] [flink-connector-pulsar] boring-cyborg[bot] commented on pull request #1: [FLINK-30054][Connector/Pulsar] Move existing Pulsar connector code

2022-11-28 Thread GitBox
boring-cyborg[bot] commented on PR #1: URL: https://github.com/apache/flink-connector-pulsar/pull/1#issuecomment-1329804803 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This is

[jira] [Created] (FLINK-30231) Update to Fabric8 Kubernetes Client to a version that has automatic renewal of service account tokens

2022-11-28 Thread Chris Thomson (Jira)
Chris Thomson created FLINK-30231: - Summary: Update to Fabric8 Kubernetes Client to a version that has automatic renewal of service account tokens Key: FLINK-30231 URL:

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21264: [FLINK-29928][runtime, state] Share RocksDB memory across TM slots

2022-11-28 Thread GitBox
rkhachatryan commented on code in PR #21264: URL: https://github.com/apache/flink/pull/21264#discussion_r1034085757 ## flink-tests/src/test/java/org/apache/flink/test/state/TaskManagerWideRocksDbMemorySharingITCase.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache

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

2022-11-28 Thread Xinyi Yan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29855?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xinyi Yan updated FLINK-29855: -- Affects Version/s: 1.16.0 > UDF randomly processed input data twice >

[GitHub] [flink] rkhachatryan commented on a diff in pull request #21362: [FLINK-29430] Add sanity check when setCurrentKeyGroupIndex

2022-11-28 Thread GitBox
rkhachatryan commented on code in PR #21362: URL: https://github.com/apache/flink/pull/21362#discussion_r1034045588 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/InternalKeyContextImpl.java: ## @@ -72,6 +73,10 @@ public void setCurrentKey(@Nonnull K

[GitHub] [flink] MartijnVisser commented on pull request #20097: [FLINK-28284][Connectors/Jdbc] Add JdbcSink with new format

2022-11-28 Thread GitBox
MartijnVisser commented on PR #20097: URL: https://github.com/apache/flink/pull/20097#issuecomment-1329712397 FYI: we're currently in the process of moving the JDBC code from the Flink repository to the dedicated Flink JDBC repository, see

[GitHub] [flink] MartijnVisser closed pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect

2022-11-28 Thread GitBox
MartijnVisser closed pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect URL: https://github.com/apache/flink/pull/12038 -- 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

[GitHub] [flink] MartijnVisser commented on pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect

2022-11-28 Thread GitBox
MartijnVisser commented on PR #12038: URL: https://github.com/apache/flink/pull/12038#issuecomment-1329710865 Closed since this has been resolved via https://github.com/apache/flink/pull/20235 -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] AlanConfluent commented on a diff in pull request #21264: [FLINK-29928][runtime, state] Share RocksDB memory across TM slots

2022-11-28 Thread GitBox
AlanConfluent commented on code in PR #21264: URL: https://github.com/apache/flink/pull/21264#discussion_r1033923674 ## flink-tests/src/test/java/org/apache/flink/test/state/TaskManagerWideRocksDbMemorySharingITCase.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache

[jira] [Commented] (FLINK-30158) [Flink SQL][Protobuf] NullPointerException when querying Kafka topic using repeated or map attributes

2022-11-28 Thread James Mcguire (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640182#comment-17640182 ] James Mcguire commented on FLINK-30158: --- Sorry about that, I meant to provide the Flink schema!

[jira] [Updated] (FLINK-30119) Flink Kubernetes Operator should store last savepoint in the SavepointInfo.lastSavepoint field whether it is completed or pending

2022-11-28 Thread Clara Xiong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Clara Xiong updated FLINK-30119: Summary: Flink Kubernetes Operator should store last savepoint in the SavepointInfo.lastSavepoint

[GitHub] [flink] sethsaperstein-lyft commented on pull request #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-11-28 Thread GitBox
sethsaperstein-lyft commented on PR #20844: URL: https://github.com/apache/flink/pull/20844#issuecomment-1329517196 @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

[GitHub] [flink] tweise commented on pull request #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-11-28 Thread GitBox
tweise commented on PR #20844: URL: https://github.com/apache/flink/pull/20844#issuecomment-1329498171 @sethsaperstein-lyft please rebase to latest master -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] tweise commented on pull request #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-11-28 Thread GitBox
tweise commented on PR #20844: URL: https://github.com/apache/flink/pull/20844#issuecomment-1329493507 Unrelated error in `test_connect_2` (Kafka connector): ``` Nov 28 15:09:24 [WARNING] The requested profile "skip-webui-build" could not be activated because it does not exist. Nov

[GitHub] [flink] tweise commented on pull request #20844: [FLINK-29099][connectors/kinesis] Update global watermark for idle subtask

2022-11-28 Thread GitBox
tweise commented on PR #20844: URL: https://github.com/apache/flink/pull/20844#issuecomment-1329487365 Unrelated issue in `docs_404_check`: ``` 2022-11-28T14:46:48.1952435Z go: downloading github.com/apache/flink-connector-elasticsearch v3.0.0+incompatible

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

2022-11-28 Thread hubert dulay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17640143#comment-17640143 ] hubert dulay commented on FLINK-30093: -- I may have found the solution to this. Basically the

[jira] [Commented] (FLINK-30230) Drop CI Support for Flink 1.15

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

[jira] [Resolved] (FLINK-30230) Drop CI Support for Flink 1.15

2022-11-28 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-30230. --- Resolution: Done > Drop CI Support for Flink 1.15 > -- > >

[GitHub] [flink-connector-aws] dannycranmer merged pull request #31: [FLINK-30230][Connectors/AWS] Drop CI build for Flink 1.15

2022-11-28 Thread GitBox
dannycranmer merged PR #31: URL: https://github.com/apache/flink-connector-aws/pull/31 -- 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 #31: [FLINK-30230][Connectors/AWS] Drop CI build for Flink 1.15

2022-11-28 Thread GitBox
hlteoh37 commented on code in PR #31: URL: https://github.com/apache/flink-connector-aws/pull/31#discussion_r1033818276 ## .github/workflows/ci.yml: ## @@ -19,52 +19,16 @@ name: Build flink-connector-dynamodb on: [push, pull_request] jobs: -

[jira] [Updated] (FLINK-30222) Suspended a job in last-state mode bug

2022-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30222: --- Labels: pull-request-available (was: ) > Suspended a job in last-state mode bug >

[GitHub] [flink-kubernetes-operator] pvary opened a new pull request, #456: FLINK-30222: Operator should handle 'kubernetes' as a valid setting for the 'high-availability' config key

2022-11-28 Thread GitBox
pvary opened a new pull request, #456: URL: https://github.com/apache/flink-kubernetes-operator/pull/456 ## What is the purpose of the change Since 1.16 it is possible to set `kubernetes` as a value for `high-availability` Operator needs to accept this as a valid value ##

[jira] [Updated] (FLINK-30230) Drop CI Support for Flink 1.15

2022-11-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30230: --- Labels: pull-request-available (was: ) > Drop CI Support for Flink 1.15 >

[GitHub] [flink-connector-aws] dannycranmer opened a new pull request, #31: [FLINK-30230][Connectors/AWS] Drop CI build for Flink 1.15

2022-11-28 Thread GitBox
dannycranmer opened a new pull request, #31: URL: https://github.com/apache/flink-connector-aws/pull/31 Delete CI job for Flink 1.15 build -- 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-30230) Drop CI Support for Flink 1.15

2022-11-28 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30230: -- Summary: Drop CI Support for Flink 1.15 (was: Drop Support for Flink 1.15) > Drop CI Support

[jira] [Updated] (FLINK-30230) Drop CI Support for Flink 1.15

2022-11-28 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30230: -- Description: We are dropping support for Flink 1.15.x in AWS connectors version 4.x.  

  1   2   3   4   >