[jira] [Commented] (FLINK-30391) show jars command doesn't list client wrapper classloader loaded jars

[ https://issues.apache.org/jira/browse/FLINK-30391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684488#comment-17684488 ] Samrat Deb commented on FLINK-30391: i would like to work on this issue  > show jars command

[jira] [Created] (FLINK-30910) ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion

Matthias Pohl created FLINK-30910: - Summary: ApplicationDispatcherBootstrapTest.testApplicationIsStoppedWhenStoppingBootstrap fails with assertion Key: FLINK-30910 URL:

[jira] [Created] (FLINK-30909) Running HA (hashmap, sync) end-to-end test

Matthias Pohl created FLINK-30909: - Summary: Running HA (hashmap, sync) end-to-end test Key: FLINK-30909 URL: https://issues.apache.org/jira/browse/FLINK-30909 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-30865) Make pyflink-ml modules consistent with Flink ML Java library packages

[ https://issues.apache.org/jira/browse/FLINK-30865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30865: --- Labels: pull-request-available (was: ) > Make pyflink-ml modules consistent with Flink ML

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #204: [FLINK-30865] Make pyflink-ml modules consistent with Flink ML Java library packages

jiangxin369 opened a new pull request, #204: URL: https://github.com/apache/flink-ml/pull/204 ## What is the purpose of the change Make pyflink-ml modules consistent with Flink ML Java library packages. ## Brief change log - Move packages and classes in

[jira] [Commented] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684478#comment-17684478 ] Zhu Zhu commented on FLINK-30904: - I have assigned you the ticket :) [~xiasun] > Update the

[jira] [Assigned] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-30904: --- Assignee: xingbe > Update the documentation and configuration description of slow task detector >

[jira] [Commented] (FLINK-27285) CassandraConnectorITCase failed on azure due to NoHostAvailableException

[ https://issues.apache.org/jira/browse/FLINK-27285?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684477#comment-17684477 ] Matthias Pohl commented on FLINK-27285: ---

[jira] [Created] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

Matthias Pohl created FLINK-30908: - Summary: Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail Key: FLINK-30908 URL: https://issues.apache.org/jira/browse/FLINK-30908

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684474#comment-17684474 ] Matthias Pohl commented on FLINK-18356: ---

[jira] [Commented] (FLINK-26974) Python EmbeddedThreadDependencyTests.test_add_python_file failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684472#comment-17684472 ] Matthias Pohl commented on FLINK-26974: ---

[jira] [Created] (FLINK-30907) HiveSinkCompactionITCase.testSingleParallelism fails with test timeout

Matthias Pohl created FLINK-30907: - Summary: HiveSinkCompactionITCase.testSingleParallelism fails with test timeout Key: FLINK-30907 URL: https://issues.apache.org/jira/browse/FLINK-30907 Project:

[jira] [Updated] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-30906: Component/s: Runtime / Task > TwoInputStreamTask passes wrong configuration object when creating input >

[jira] [Created] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

Yun Gao created FLINK-30906: --- Summary: TwoInputStreamTask passes wrong configuration object when creating input processor Key: FLINK-30906 URL: https://issues.apache.org/jira/browse/FLINK-30906 Project:

[jira] [Commented] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684470#comment-17684470 ] xingbe commented on FLINK-30904: I'd like to continue this work, please assign this ticket to me,

[jira] [Commented] (FLINK-30843) Add Notifier For Autoscaler

[ https://issues.apache.org/jira/browse/FLINK-30843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684468#comment-17684468 ] Gaurav Miglani commented on FLINK-30843: [~gyfora]  waiting for your comment > Add Notifier For

[jira] [Commented] (FLINK-30846) SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails

[ https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684466#comment-17684466 ] Matthias Pohl commented on FLINK-30846: --- The following failed build didn't include the above

[jira] [Commented] (FLINK-30508) CliClientITCase.testSqlStatements failed with output not matched with expected

[ https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684463#comment-17684463 ] Matthias Pohl commented on FLINK-30508: ---

[jira] [Commented] (FLINK-30508) CliClientITCase.testSqlStatements failed with output not matched with expected

[ https://issues.apache.org/jira/browse/FLINK-30508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684464#comment-17684464 ] Matthias Pohl commented on FLINK-30508: --- Any updates on that one [~fsk119]? >

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684460#comment-17684460 ] Matthias Pohl commented on FLINK-18356: ---

[jira] [Closed] (FLINK-30868) Revert to use LongSerializer for seralization in the TimeIndicatorTypeInfo

[ https://issues.apache.org/jira/browse/FLINK-30868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30868. - Fix Version/s: 1.17.0 Resolution: Fixed Merged into master:

[jira] [Created] (FLINK-30905) doc generation fails with "concurrent map read and map write"

Matthias Pohl created FLINK-30905: - Summary: doc generation fails with "concurrent map read and map write" Key: FLINK-30905 URL: https://issues.apache.org/jira/browse/FLINK-30905 Project: Flink

[GitHub] [flink] fsk119 merged pull request #21827: [FLINK-30868][table-api] Fix to use origin LongSerializer for seriali…

fsk119 merged PR #21827: URL: https://github.com/apache/flink/pull/21827 -- 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-30840) Fix resource leak when creating Executor

[ https://issues.apache.org/jira/browse/FLINK-30840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-30840. - Resolution: Fixed Merged into master: 152edf6a5e6f67a67a3d09815557b304bcd7b1a0 > Fix resource

[jira] [Assigned] (FLINK-30840) Fix resource leak when creating Executor

[ https://issues.apache.org/jira/browse/FLINK-30840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang reassigned FLINK-30840: - Assignee: Shengkai Fang > Fix resource leak when creating Executor >

[GitHub] [flink] fsk119 merged pull request #21800: [FLINK-30840][sql-client] Fix resource leak when creating Executor

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

[jira] [Updated] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30904: Description: FLINK-30707 improved the slow task detecting. The previous documentation and configuration

[GitHub] [flink] 1996fanrui commented on a diff in pull request #21855: [bp-1.15][FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoin

1996fanrui commented on code in PR #21855: URL: https://github.com/apache/flink/pull/21855#discussion_r1097010183 ## flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBStateUploaderTest.java: ## @@ -96,13 +100,92 @@

[jira] [Commented] (FLINK-30899) FileSystemTableSource with CSV format incorrectly selects fields if filtering for partition

[ https://issues.apache.org/jira/browse/FLINK-30899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684455#comment-17684455 ] luoyuxia commented on FLINK-30899: -- [~mateczagany] Thanks for reporting. I think it's the right

[jira] [Updated] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30904: Description: FLINK-30707 improved the slow task detecting. The previous documentation and configuration

[jira] [Updated] (FLINK-30904) Update the documentation and configuration description of slow task detector

[ https://issues.apache.org/jira/browse/FLINK-30904?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-30904: Environment: (was: FLINK-30707 improved the slow task detecting. The previous documentation and

[jira] [Created] (FLINK-30904) Update the documentation and configuration description of slow task detector

Zhu Zhu created FLINK-30904: --- Summary: Update the documentation and configuration description of slow task detector Key: FLINK-30904 URL: https://issues.apache.org/jira/browse/FLINK-30904 Project: Flink

[GitHub] [flink] lincoln-lil commented on a diff in pull request #21507: [FLINK-30386] Fix the issue that column constraint lacks primary key not enforced check

lincoln-lil commented on code in PR #21507: URL: https://github.com/apache/flink/pull/21507#discussion_r1096998249 ## flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/SqlConstraintValidator.java: ## @@ -80,4 +83,20 @@ public static void

[GitHub] [flink] jiexray commented on pull request #21822: [FLINK-30863][state] Do not delete the local changelog file of aborted checkpoint

jiexray commented on PR #21822: URL: https://github.com/apache/flink/pull/21822#issuecomment-1418605498 Hello @fredia, thank you for creating this PR. I have some concern about the removal of `LocalChangelogRegistryImpl#prune()`, please have a look. In my opinion, the main purpose of

[GitHub] [flink] lindong28 commented on a diff in pull request #21589: [FLINK-25509][connector-base] Add RecordEvaluator to dynamically stop source based on de-serialized records

lindong28 commented on code in PR #21589: URL: https://github.com/apache/flink/pull/21589#discussion_r1096967718 ## flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaSourceReaderTest.java: ## @@ -479,6 +486,125 @@ public

[jira] [Resolved] (FLINK-30727) JoinReorderITCase.testBushyTreeJoinReorder failed due to IOException

[ https://issues.apache.org/jira/browse/FLINK-30727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-30727. --- Fix Version/s: 1.17.0 Resolution: Fixed Thanks for letting me know. You're free to

[GitHub] [flink] flinkbot commented on pull request #21858: [FLINK-30729][state/changelog] Refactor checkState() to WARN of StateChangelogWriter to avoid confusing IllegalException

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

[jira] [Updated] (FLINK-30903) The max parallelism used in adaptive batch scheduler doesn't fallbacks to default parallelism

[ https://issues.apache.org/jira/browse/FLINK-30903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-30903: -- Summary: The max parallelism used in adaptive batch scheduler doesn't fallbacks to default

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1096990499 ## flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java: ## @@ -0,0 +1,424 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-30729) AggregateITCase generates stacktraces of IllegalStateExceptions in Maven output but doesn't fail

[ https://issues.apache.org/jira/browse/FLINK-30729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684439#comment-17684439 ] Yanfei Lei commented on FLINK-30729: I open a PR to replace {{checkState()}} with {{LOG.warn()}}

[jira] [Updated] (FLINK-30901) The jobVertex's parallelismConfigured is incorrect when chaining with source operators

[ https://issues.apache.org/jira/browse/FLINK-30901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-30901: -- Summary: The jobVertex's parallelismConfigured is incorrect when chaining with source operators

[jira] [Updated] (FLINK-30729) AggregateITCase generates stacktraces of IllegalStateExceptions in Maven output but doesn't fail

[ https://issues.apache.org/jira/browse/FLINK-30729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30729: --- Labels: pull-request-available (was: ) > AggregateITCase generates stacktraces of

[GitHub] [flink] fredia opened a new pull request, #21858: [FLINK-30729][state/changelog] Refactor checkState() to WARN of StateChangelogWriter to avoid confusing IllegalException

fredia opened a new pull request, #21858: URL: https://github.com/apache/flink/pull/21858 ## What is the purpose of the change Refactor checkState() to WARN of StateChangelogWriter to avoid confusing IllegalException. ## Brief change log - Replace `checkState()`

[jira] [Updated] (FLINK-30903) The max parallelism of adaptive batch scheduler doesn't fallback to default parallelism

[ https://issues.apache.org/jira/browse/FLINK-30903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-30903: -- Summary: The max parallelism of adaptive batch scheduler doesn't fallback to default parallelism

[GitHub] [flink] flinkbot commented on pull request #21857: [FLINK-30903][runtime] Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism

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

[jira] [Updated] (FLINK-30903) Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism

[ https://issues.apache.org/jira/browse/FLINK-30903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30903: --- Labels: pull-request-available (was: ) > Fix the maxParallelism of

[GitHub] [flink] JunRuiLee opened a new pull request, #21857: [FLINK-30903][runtime] Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism

JunRuiLee opened a new pull request, #21857: URL: https://github.com/apache/flink/pull/21857 ## What is the purpose of the change In [FLINK-30684](https://issues.apache.org/jira/browse/FLINK-30684) we mark the vertices which use the default parallelism, and in

[jira] [Assigned] (FLINK-30903) Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism

[ https://issues.apache.org/jira/browse/FLINK-30903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-30903: -- Assignee: Junrui Li > Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider

[jira] [Updated] (FLINK-30903) Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism

[ https://issues.apache.org/jira/browse/FLINK-30903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Li updated FLINK-30903: -- Priority: Critical (was: Major) > Fix the maxParallelism of

[jira] [Created] (FLINK-30903) Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism

Junrui Li created FLINK-30903: - Summary: Fix the maxParallelism of DefaultVertexParallelismAndInputInfosDecider fallback to default parallelism Key: FLINK-30903 URL: https://issues.apache.org/jira/browse/FLINK-30903

[GitHub] [flink] SmirAlex commented on pull request #20919: [FLINK-29405] Fix unstable test InputFormatCacheLoaderTest

SmirAlex commented on PR #20919: URL: https://github.com/apache/flink/pull/20919#issuecomment-1418554554 @XComp Big thanks for the review, your comments were very helpful! @PatrickRen Thanks for merging a MR! And sorry for not responding, I was on a vacation without laptop last week, so,

[GitHub] [flink] flinkbot commented on pull request #21856: [FLINK-30902][runtime] Partition reuse does not take effect on edges of hybrid selective type

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

[jira] [Comment Edited] (FLINK-19230) Support Python UDAF on blink batch planner

[ https://issues.apache.org/jira/browse/FLINK-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684431#comment-17684431 ] Dian Fu edited comment on FLINK-19230 at 2/6/23 5:41 AM: - I believe this should

[jira] [Closed] (FLINK-19230) Support Python UDAF on blink batch planner

[ https://issues.apache.org/jira/browse/FLINK-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-19230. --- Fix Version/s: (was: 1.17.0) Resolution: Not A Problem I believe this should have already been

[jira] [Updated] (FLINK-30902) Partition reuse does not take effect on edges of hybrid selective type

[ https://issues.apache.org/jira/browse/FLINK-30902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30902: --- Labels: pull-request-available (was: ) > Partition reuse does not take effect on edges of

[GitHub] [flink] reswqa opened a new pull request, #21856: [FLINK-30902][runtime] Partition reuse does not take effect on edges of hybrid selective type

reswqa opened a new pull request, #21856: URL: https://github.com/apache/flink/pull/21856 ## What is the purpose of the change *Partition reuse only take effect for re-consumable edge, but hybrid selective result partition is not re-consumable. This optimization is very important to

[jira] [Commented] (FLINK-25402) FLIP-198: Working directory for Flink processes

[ https://issues.apache.org/jira/browse/FLINK-25402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684429#comment-17684429 ] melin commented on FLINK-25402: --- When a job is submitted, can add files to the Working directory? spark

[GitHub] [flink] lincoln-lil commented on a diff in pull request #21641: [FLINK-30006][table-planner] Make all pure dynamic functions non-deterministic in streaming mode to avoid wrong plans

lincoln-lil commented on code in PR #21641: URL: https://github.com/apache/flink/pull/21641#discussion_r1096956862 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/FlinkTimestampDynamicFunction.java: ## @@ -0,0 +1,77 @@ +/* + *

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1095888644 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java: ## @@ -0,0 +1,317 @@ +/* + *

[jira] [Closed] (FLINK-27929) Drop support for python 3.6

[ https://issues.apache.org/jira/browse/FLINK-27929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27929. --- Fix Version/s: (was: 1.17.0) Resolution: Duplicate > Drop support for python 3.6 >

[jira] [Commented] (FLINK-27929) Drop support for python 3.6

[ https://issues.apache.org/jira/browse/FLINK-27929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684428#comment-17684428 ] Dian Fu commented on FLINK-27929: - Closing this ticket as Python 3.6 should have been dropped during

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1096955404 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java: ## @@ -0,0 +1,317 @@ +/* + *

[jira] [Closed] (FLINK-27713) Bump Apache Beam to 2.40.0

[ https://issues.apache.org/jira/browse/FLINK-27713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-27713. --- Fix Version/s: (was: 1.17.0) Resolution: Duplicate Closing this ticket as Apache Beam has been

[GitHub] [flink] ifndef-SleePy commented on a diff in pull request #21807: [FLINK-30842][docs] Add document for sink supports speculative execution

ifndef-SleePy commented on code in PR #21807: URL: https://github.com/apache/flink/pull/21807#discussion_r1096945717 ## docs/content/docs/deployment/speculative_execution.md: ## @@ -92,6 +88,31 @@ No extra change is required for other sources to work with speculative execution

[GitHub] [flink-benchmarks] fredia commented on pull request #63: [FLINK-27571][benchmark] Recognize 'less is better' benchmarks in regression detection script

fredia commented on PR #63: URL: https://github.com/apache/flink-benchmarks/pull/63#issuecomment-1418515066 @pnowojski Thanks for your information, I overlooked this when updating `codespeed_benchmark` table. The colors are controlled by the[

[GitHub] [flink-connector-mongodb] Jiabao-Sun commented on a diff in pull request #1: [FLINK-6573][connectors/mongodb] Flink MongoDB Connector

Jiabao-Sun commented on code in PR #1: URL: https://github.com/apache/flink-connector-mongodb/pull/1#discussion_r1096941489 ## flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java: ## @@ -0,0 +1,426 @@ +/* + *

[jira] [Commented] (FLINK-30870) Performance regressions notifications in Slack are cut off

[ https://issues.apache.org/jira/browse/FLINK-30870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684417#comment-17684417 ] Yanfei Lei commented on FLINK-30870: The message after updating the Jenkins script became normal:

[jira] [Updated] (FLINK-30870) Performance regressions notifications in Slack are cut off

[ https://issues.apache.org/jira/browse/FLINK-30870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-30870: --- Attachment: image-2023-02-06-12-26-57-268.png > Performance regressions notifications in Slack are

[GitHub] [flink] godfreyhe commented on a diff in pull request #21641: [FLINK-30006][table-planner] Make all pure dynamic functions non-deterministic in streaming mode to avoid wrong plans

godfreyhe commented on code in PR #21641: URL: https://github.com/apache/flink/pull/21641#discussion_r1096928686 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/sql/FlinkTimestampDynamicFunction.java: ## @@ -0,0 +1,77 @@ +/* + *

[jira] [Updated] (FLINK-30870) Performance regressions notifications in Slack are cut off

[ https://issues.apache.org/jira/browse/FLINK-30870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30870: --- Labels: pull-request-available (was: ) > Performance regressions notifications in Slack

[jira] [Created] (FLINK-30902) Partition reuse does not take effect on edges of hybrid selective type

Weijie Guo created FLINK-30902: -- Summary: Partition reuse does not take effect on edges of hybrid selective type Key: FLINK-30902 URL: https://issues.apache.org/jira/browse/FLINK-30902 Project: Flink

[GitHub] [flink-benchmarks] fredia opened a new pull request, #65: [FLINK-30870][benchmark] Replace sending slack messages with attachments

fredia opened a new pull request, #65: URL: https://github.com/apache/flink-benchmarks/pull/65 Due to the[ limitation of the message length](https://github.com/jenkinsci/slack-plugin/issues/735#issuecomment-774131103) of slack plugin, the performance regressions notifications in Slack are

[jira] [Commented] (FLINK-30594) Update Java version because of JDK bug in the operator

[ https://issues.apache.org/jira/browse/FLINK-30594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684413#comment-17684413 ] Xin Li commented on FLINK-30594: [~gaborgsomogyi]  The OpenJDK images have announced deprecations.

[GitHub] [flink] flinkbot commented on pull request #21855: [FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exception

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

[GitHub] [flink] fsk119 commented on a diff in pull request #21802: [FLINK-30811][sql-gateway] Fix SqlGateway cannot stop job correctly

fsk119 commented on code in PR #21802: URL: https://github.com/apache/flink/pull/21802#discussion_r1096883501 ## flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/context/SessionContext.java: ## @@ -266,16 +266,20 @@ public static SessionContext

[jira] [Closed] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-29038. --- Resolution: Fixed fixed in 1.16: db524dfb46673bc98d4cf93b9e84ed9a4b76d837 >

[jira] [Updated] (FLINK-29038) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-29038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-29038: Fix Version/s: 1.16.2 (was: 1.16.0) >

[GitHub] [flink] 1996fanrui opened a new pull request, #21855: [FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exception

1996fanrui opened a new pull request, #21855: URL: https://github.com/apache/flink/pull/21855 Backport the [FLINK-30461](https://issues.apache.org/jira/browse/FLINK-30461) to release-1.15 -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] flinkbot commented on pull request #21854: [FLINK-30901][runtime] Fix set jobVertex parallelismConfigured don't contain chained sources.

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

[GitHub] [flink] lincoln-lil merged pull request #21848: [bp-1.16][FLINK-29038][datastream] Remove local timeout in AsyncWaitOperatorTest for testing guideline

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

[jira] [Assigned] (FLINK-30901) Fix set jobVertex parallelismConfigured don't contain chained sources.

[ https://issues.apache.org/jira/browse/FLINK-30901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-30901: -- Assignee: Junrui Li > Fix set jobVertex parallelismConfigured don't contain chained sources.

[jira] [Updated] (FLINK-30901) Fix set jobVertex parallelismConfigured don't contain chained sources.

[ https://issues.apache.org/jira/browse/FLINK-30901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30901: --- Labels: pull-request-available (was: ) > Fix set jobVertex parallelismConfigured don't

[GitHub] [flink] JunRuiLee opened a new pull request, #21854: [FLINK-30901][runtime] Fix set jobVertex parallelismConfigured don't contain chained sources.

JunRuiLee opened a new pull request, #21854: URL: https://github.com/apache/flink/pull/21854 ## What is the purpose of the change When create OperatorChainInfo in StreamingJobGenerator, the chained source don't include in the chainedNodes and they will not be added to

[jira] [Closed] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-30876. -- Resolution: Fixed > Fix ResetTransformationProcessor don't reset the transformation of ExecNode > in

[jira] [Comment Edited] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684394#comment-17684394 ] Godfrey He edited comment on FLINK-30876 at 2/6/23 3:23 AM: Fixed in master:

[jira] [Created] (FLINK-30901) Fix set jobVertex parallelismConfigured don't contain chained sources.

Junrui Li created FLINK-30901: - Summary: Fix set jobVertex parallelismConfigured don't contain chained sources. Key: FLINK-30901 URL: https://issues.apache.org/jira/browse/FLINK-30901 Project: Flink

[GitHub] [flink] godfreyhe commented on pull request #21622: [FLINK-30570] Fix error inferred partition condition

godfreyhe commented on PR #21622: URL: https://github.com/apache/flink/pull/21622#issuecomment-1418440245 cc @swuferhong -- 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] [Updated] (FLINK-30900) Introduce utils for table store

[ https://issues.apache.org/jira/browse/FLINK-30900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30900: --- Labels: pull-request-available (was: ) > Introduce utils for table store >

[GitHub] [flink-table-store] zjureel opened a new pull request, #504: [FLINK-30900] Introduce utils for table store

zjureel opened a new pull request, #504: URL: https://github.com/apache/flink-table-store/pull/504 Introduce utils classes in flink-core for table store -- 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

[GitHub] [flink] flinkbot commented on pull request #21853: [FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exception

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

[jira] [Closed] (FLINK-13284) Correct some builtin functions' return type inference in Blink planner

[ https://issues.apache.org/jira/browse/FLINK-13284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-13284. --- > Correct some builtin functions' return type inference in Blink planner >

[jira] [Assigned] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-30876: -- Assignee: Yunhong Zheng > Fix ResetTransformationProcessor don't reset the transformation of

[jira] [Commented] (FLINK-30876) Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

[ https://issues.apache.org/jira/browse/FLINK-30876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684394#comment-17684394 ] Godfrey He commented on FLINK-30876: Fixed in master: 111342f37bdc0d582d3f7af458d9869f0548299f >

[jira] [Created] (FLINK-30900) Introduce utils for table store

Shammon created FLINK-30900: --- Summary: Introduce utils for table store Key: FLINK-30900 URL: https://issues.apache.org/jira/browse/FLINK-30900 Project: Flink Issue Type: Sub-task

[GitHub] [flink] tsreaper commented on a diff in pull request #21759: [FLINK-29237][table] Remove RexSimplify from Flink code, SearchOperator code generation for RexUnknown.nullAs

tsreaper commented on code in PR #21759: URL: https://github.com/apache/flink/pull/21759#discussion_r1096901589 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/SearchOperatorGen.scala: ## @@ -96,7 +96,9 @@ object SearchOperatorGen

[jira] [Commented] (FLINK-29481) Show JobType on WebUI

[ https://issues.apache.org/jira/browse/FLINK-29481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17684393#comment-17684393 ] LI Mingkun commented on FLINK-29481: [~wanglijie] I have created a PR on this ticket > Show JobType

[GitHub] [flink-table-store] zhangjun0x01 commented on pull request #471: [FLINK-30608] support rename table

zhangjun0x01 commented on PR #471: URL: https://github.com/apache/flink-table-store/pull/471#issuecomment-1418429110 I run the spark UT in my computer,it is fine ， I don't know why it failed here -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] godfreyhe closed pull request #21828: [FLINK-30876][table-planner] Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode

godfreyhe closed pull request #21828: [FLINK-30876][table-planner] Fix ResetTransformationProcessor don't reset the transformation of ExecNode in BatchExecMultiInput.rootNode URL: https://github.com/apache/flink/pull/21828 -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] 1996fanrui opened a new pull request, #21853: [FLINK-30461][checkpoint] Fix the bug that the shared files will remain forever after the rocksdb incremental checkpoint exception

1996fanrui opened a new pull request, #21853: URL: https://github.com/apache/flink/pull/21853 Backport the FLINK-30461 to 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

[GitHub] [flink] tsreaper commented on pull request #21393: [FLINK-27246][TableSQL/Runtime][master] - Include WHILE blocks in split generated java methods

tsreaper commented on PR #21393: URL: https://github.com/apache/flink/pull/21393#issuecomment-1418428367 > After merging this PR I would like to create a back port PRs to 1.15 and 1.16. You're welcome to create back ports. As 1.16.0 has just released for one month or two I guess

  1   2   >