[jira] [Commented] (FLINK-30507) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMinMaxParallelism could not be initialized

2022-12-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652754#comment-17652754 ] Wencong Liu commented on FLINK-30507: -     Hello [~renqs]. For this failed IT case,

[jira] [Updated] (FLINK-30507) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMinMaxParallelism could not be initialized

2022-12-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-30507: Attachment: image-2022-12-29-15-52-17-508.png > EventTimeWindowCheckpointingITCase.testTumblingTim

[jira] [Updated] (FLINK-30507) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMinMaxParallelism could not be initialized

2022-12-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-30507: Attachment: image-2022-12-29-15-51-12-230.png > EventTimeWindowCheckpointingITCase.testTumblingTim

[GitHub] [flink] swuferhong commented on a diff in pull request #21489: [FLINK-30365][table-planner] New dynamic partition pruning strategy to support more dpp patterns

2022-12-28 Thread GitBox
swuferhong commented on code in PR #21489: URL: https://github.com/apache/flink/pull/21489#discussion_r1058791517 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/optimize/program/FlinkDynamicPartitionPruningConverterProgram.java: ## @@ -0,0 +

[GitHub] [flink] beyond1920 commented on pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
beyond1920 commented on PR #21257: URL: https://github.com/apache/flink/pull/21257#issuecomment-1367133367 If you plan to keep the changes of BufferWriters and Compact operators for speculative execution in this pr, there is no need to create a JIRA to issue this. -- This is an automated

[jira] [Updated] (FLINK-30507) EventTimeWindowCheckpointingITCase.testTumblingTimeWindowWithKVStateMinMaxParallelism could not be initialized

2022-12-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wencong Liu updated FLINK-30507: Attachment: image-2022-12-29-15-48-55-564.png > EventTimeWindowCheckpointingITCase.testTumblingTim

[GitHub] [flink] saLeox commented on pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

2022-12-28 Thread GitBox
saLeox commented on PR #21149: URL: https://github.com/apache/flink/pull/21149#issuecomment-1367123546 Hi @Tartarus0zm , thanks for your comments! For the rule constraints, when reading each parquet split, there is an existing rule in Flink, to check whether a column from requested schem

[GitHub] [flink] saLeox opened a new pull request, #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

2022-12-28 Thread GitBox
saLeox opened a new pull request, #21149: URL: https://github.com/apache/flink/pull/21149 ## What is the purpose of the change From the improvement [FLINK-23715](https://issues.apache.org/jira/browse/FLINK-23715), Flink use a collection named `unknownFieldsIndices` to track the n

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21162: [FLINK-29665][runtime] Support flexible subpartion range division

2022-12-28 Thread GitBox
wanglijie95 commented on code in PR #21162: URL: https://github.com/apache/flink/pull/21162#discussion_r1058781862 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/VertexInputInfoComputationUtils.java: ## @@ -255,12 +259,11 @@ public int getNumPartitions()

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21162: [FLINK-29665][runtime] Support flexible subpartion range division

2022-12-28 Thread GitBox
zhuzhurk commented on code in PR #21162: URL: https://github.com/apache/flink/pull/21162#discussion_r1058779302 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/VertexInputInfoComputationUtils.java: ## @@ -255,12 +259,11 @@ public int getNumPartitions() {

[jira] [Commented] (FLINK-27571) Recognize "less is better" benchmarks in regression detection script

2022-12-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652744#comment-17652744 ] Yanfei Lei commented on FLINK-27571: Hi [~roman] , could you please help take a look

[jira] [Commented] (FLINK-30530) Flink configuration from user-provided ConfigMap

2022-12-28 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652743#comment-17652743 ] Wencong Liu commented on FLINK-30530: - Hi [~tashoyan] , I'm quite interested in this

[GitHub] [flink] wanglijie95 commented on a diff in pull request #21162: [FLINK-29665][runtime] Support flexible subpartion range division

2022-12-28 Thread GitBox
wanglijie95 commented on code in PR #21162: URL: https://github.com/apache/flink/pull/21162#discussion_r1058767679 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/VertexInputInfoComputationUtils.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Sof

[jira] [Updated] (FLINK-27571) Recognize "less is better" benchmarks in regression detection script

2022-12-28 Thread Yanfei Lei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yanfei Lei updated FLINK-27571: --- Attachment: image-2022-12-29-14-39-59-976.png > Recognize "less is better" benchmarks in regression

[jira] [Commented] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652720#comment-17652720 ] Yongming Zhang commented on FLINK-30524: [~yunta] Please help me review this pr,

[GitHub] [flink] saLeox closed pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

2022-12-28 Thread GitBox
saLeox closed pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader URL: https://github.com/apache/flink/pull/21149 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink] saLeox commented on pull request #21149: [FLINK-29527][formats/parquet] Make unknownFieldsIndices work for single ParquetReader

2022-12-28 Thread GitBox
saLeox commented on PR #21149: URL: https://github.com/apache/flink/pull/21149#issuecomment-1367098878 > @saLeox Thanks for contribution. In our company, there are strict usage rules, so there is no such thing as multiple schema files in the same partition directory. The changes is fine, bu

[GitHub] [flink] lsyldliu commented on pull request #21401: [FLINK-29718][table] Supports hive sum function by native implementation

2022-12-28 Thread GitBox
lsyldliu commented on PR #21401: URL: https://github.com/apache/flink/pull/21401#issuecomment-1367091028 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Closed] (FLINK-17372) SlotManager should expose total required resources

2022-12-28 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-17372. Resolution: Done > SlotManager should expose total required resources > --

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058733349 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java: ## @@ -0,0 +1,158 @@ +/* + * Licensed to the Apach

[GitHub] [flink] luoyuxia commented on pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on PR #21257: URL: https://github.com/apache/flink/pull/21257#issuecomment-1367081179 > After discussion with @luoyuxia offline, we would not support speculative execution in the this version. And we would continue on this work after [FLIP-281+Sink+Supports+Speculative+Ex

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058733643 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchPartitionCommitOutputFormat.java: ## @@ -0,0 +1,148 @@

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058733349 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java: ## @@ -0,0 +1,158 @@ +/* + * Licensed to the Apach

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058733349 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java: ## @@ -0,0 +1,158 @@ +/* + * Licensed to the Apach

[GitHub] [flink] luoyuxia commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
luoyuxia commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058733349 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/CompactFileUtils.java: ## @@ -0,0 +1,158 @@ +/* + * Licensed to the Apach

[GitHub] [flink] beyond1920 commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
beyond1920 commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058725159 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchPartitionCommitOutputFormat.java: ## @@ -0,0 +1,148

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

2022-12-28 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652700#comment-17652700 ] Benchao Li commented on FLINK-30093: [~maosuhan] If this is the suggested way to han

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

2022-12-28 Thread hubert dulay (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652699#comment-17652699 ] hubert dulay commented on FLINK-30093: -- I think that would be best. Thanks > [F

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yongming Zhang updated FLINK-30524: --- Priority: Major (was: Minor) > Support full screen viewing on the Logs/Stdout/Thread Dump p

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

2022-12-28 Thread Suhan Mao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652696#comment-17652696 ] Suhan Mao commented on FLINK-30093: --- [~rmetzger]  Since this issue can be solved by th

[GitHub] [flink] flinkbot commented on pull request #21574: Release 1.16 pyflink read from kafka failed.

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

[GitHub] [flink] flinkbot commented on pull request #21573: [FLINK-30524] Support full screen viewing on the Logs/Stdout/Thread D…

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

[GitHub] [flink] ColdWater2019 opened a new pull request, #21574: Release 1.16 pyflink read from kafka failed.

2022-12-28 Thread GitBox
ColdWater2019 opened a new pull request, #21574: URL: https://github.com/apache/flink/pull/21574 java.lang.NoSuchMethodError: org.apache.flink.connector.base.source.reader.fetcher.SingleThreadFetcherManager.(Lorg/apache/flink/connector/base/source/reader/synchronization/FutureCompletingBloc

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30524: --- Labels: pull-request-available (was: ) > Support full screen viewing on the Logs/Stdout/Thr

[GitHub] [flink] damumu0625 opened a new pull request, #21573: [FLINK-30524] Support full screen viewing on the Logs/Stdout/Thread D…

2022-12-28 Thread GitBox
damumu0625 opened a new pull request, #21573: URL: https://github.com/apache/flink/pull/21573 …ump page ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-

[GitHub] [flink-ml] zhipeng93 merged pull request #194: [FLINK-30523] Fix the data generator for VectorAssembler benchmark

2022-12-28 Thread GitBox
zhipeng93 merged PR #194: URL: https://github.com/apache/flink-ml/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...@flink.apac

[GitHub] [flink-ml] zhipeng93 commented on pull request #194: [FLINK-30523] Fix the data generator for VectorAssembler benchmark

2022-12-28 Thread GitBox
zhipeng93 commented on PR #194: URL: https://github.com/apache/flink-ml/pull/194#issuecomment-1367050617 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 comm

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yongming Zhang updated FLINK-30524: --- Description: !https://intranetproxy.alipay.com/skylark/lark/0/2022/png/336411/1672227240081-

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yongming Zhang updated FLINK-30524: --- Description: !https://intranetproxy.alipay.com/skylark/lark/0/2022/png/336411/1672227240081-

[jira] [Updated] (FLINK-30524) Support full screen viewing on the Logs/Stdout/Thread Dump page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yongming Zhang updated FLINK-30524: --- Summary: Support full screen viewing on the Logs/Stdout/Thread Dump page (was: Unify the st

[jira] [Updated] (FLINK-30524) Unify the style of the logs page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yongming Zhang updated FLINK-30524: --- Attachment: image-2022-12-29-11-16-20-204.png > Unify the style of the logs page > -

[jira] [Updated] (FLINK-30524) Unify the style of the logs page

2022-12-28 Thread Yongming Zhang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yongming Zhang updated FLINK-30524: --- Description: There are certain differences in the layout of the "Logs/Stdout" and "Log List"

[jira] [Closed] (FLINK-28850) Support table alias in LOOKUP hint

2022-12-28 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He closed FLINK-28850. -- Resolution: Fixed Fixed in master: be6b1c94ef3f552c753746863cb0a4e7dd86d2fc f32ba645246a8180a0218265

[jira] [Updated] (FLINK-28850) Support table alias in LOOKUP hint

2022-12-28 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He updated FLINK-28850: --- Fix Version/s: 1.17.0 > Support table alias in LOOKUP hint > -- > >

[jira] [Assigned] (FLINK-28850) Support table alias in LOOKUP hint

2022-12-28 Thread Godfrey He (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Godfrey He reassigned FLINK-28850: -- Assignee: lincoln lee > Support table alias in LOOKUP hint >

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #195: [FLINK-30532] Add benchmark for DCT, SQLTransformer and StopWordsRemover

2022-12-28 Thread GitBox
jiangxin369 commented on code in PR #195: URL: https://github.com/apache/flink-ml/pull/195#discussion_r1058706248 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/clustering/KMeansModelDataGenerator.java: ## @@ -55,20 +61,36 @@ public Table[] getDa

[GitHub] [flink] godfreyhe closed pull request #20800: [FLINK-28850][table-planner] Support table alias in LOOKUP hint

2022-12-28 Thread GitBox
godfreyhe closed pull request #20800: [FLINK-28850][table-planner] Support table alias in LOOKUP hint URL: https://github.com/apache/flink/pull/20800 -- 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] Tartarus0zm commented on a diff in pull request #21257: [FLINK-29879][filesystem] introduce operators for merging files in batch mode.

2022-12-28 Thread GitBox
Tartarus0zm commented on code in PR #21257: URL: https://github.com/apache/flink/pull/21257#discussion_r1058705980 ## flink-connectors/flink-connector-files/src/main/java/org/apache/flink/connector/file/table/batch/compact/BatchFileWriter.java: ## @@ -0,0 +1,115 @@ +/* + * Licen

[jira] [Closed] (FLINK-30521) Improve `Altering Tables` of Doc

2022-12-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30521. --- Resolution: Fixed master: 659a5ce4b1b7a45c506391476b3b67396346403f release-0.3: cfd132362b14ba66b41d

[jira] [Updated] (FLINK-30521) Improve `Altering Tables` of Doc

2022-12-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30521: Fix Version/s: table-store-0.3.0 table-store-0.4.0 > Improve `Altering Tables`

[jira] [Assigned] (FLINK-30521) Improve `Altering Tables` of Doc

2022-12-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng reassigned FLINK-30521: --- Assignee: yuzelin > Improve `Altering Tables` of Doc > > >

[jira] [Updated] (FLINK-30521) Improve `Altering Tables` of Doc

2022-12-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-30521: Affects Version/s: table-store-0.3.0 > Improve `Altering Tables` of Doc >

[jira] [Updated] (FLINK-30521) Improve `Altering Tables` of Doc

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30521: --- Labels: pull-request-available (was: ) > Improve `Altering Tables` of Doc > ---

[GitHub] [flink-table-store] tsreaper merged pull request #446: [FLINK-30521] Improve `Altering Tables` of Doc

2022-12-28 Thread GitBox
tsreaper merged PR #446: URL: https://github.com/apache/flink-table-store/pull/446 -- 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...@fl

[jira] [Closed] (FLINK-30506) Add documentation for writing Table Store with Spark3

2022-12-28 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-30506. --- Resolution: Fixed master: 33c30f2e79e85ee15130320d6e712601c1b44d6c release-0.3: d02276de2fdcf90b50b3

[GitHub] [flink-ml] jiangxin369 commented on a diff in pull request #193: [FLINK-30515] Add benchmark for CountVectorizer, Imputer, RobustScale…

2022-12-28 Thread GitBox
jiangxin369 commented on code in PR #193: URL: https://github.com/apache/flink-ml/pull/193#discussion_r1058691003 ## flink-ml-benchmark/src/main/java/org/apache/flink/ml/benchmark/datagenerator/param/HasNumDistinctValues.java: ## @@ -0,0 +1,42 @@ +/* + * Licensed to the Apache S

[GitHub] [flink-ml] yunfengzhou-hub commented on pull request #195: [FLINK-30532] Add benchmark for DCT, SQLTransformer and StopWordsRemover

2022-12-28 Thread GitBox
yunfengzhou-hub commented on PR #195: URL: https://github.com/apache/flink-ml/pull/195#issuecomment-1367027863 Hi @jiangxin369, Could you please take a look at this PR? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

[jira] [Closed] (FLINK-22318) Support RENAME column name for ALTER TABLE statement

2022-12-28 Thread Shengkai Fang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shengkai Fang closed FLINK-22318. - Fix Version/s: 1.17.0 Resolution: Implemented Merged into master: 291fee0e1e1007af3e261e

[jira] [Updated] (FLINK-30532) Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm

2022-12-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30532: --- Labels: pull-request-available (was: ) > Add benchmark for DCT, SQLTransformer and StopWord

[GitHub] [flink-ml] yunfengzhou-hub opened a new pull request, #195: [FLINK-30532] Add benchmark for DCT, SQLTransformer and StopWordsRemover

2022-12-28 Thread GitBox
yunfengzhou-hub opened a new pull request, #195: URL: https://github.com/apache/flink-ml/pull/195 ## What is the purpose of the change This pull request mainly adds the benchmark configuration files for DCT, SQLTransformer and StopWordsRemover algorithm. ## Brief change log

[GitHub] [flink] fsk119 closed pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement

2022-12-28 Thread GitBox
fsk119 closed pull request #19329: [FLINK-22318][table] Support RENAME column name for ALTER TABLE statement URL: https://github.com/apache/flink/pull/19329 -- 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] lsyldliu commented on a diff in pull request #21401: [FLINK-29718][table] Supports hive sum function by native implementation

2022-12-28 Thread GitBox
lsyldliu commented on code in PR #21401: URL: https://github.com/apache/flink/pull/21401#discussion_r1058688565 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSumAggFunction.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apac

[GitHub] [flink] lsyldliu commented on a diff in pull request #21401: [FLINK-29718][table] Supports hive sum function by native implementation

2022-12-28 Thread GitBox
lsyldliu commented on code in PR #21401: URL: https://github.com/apache/flink/pull/21401#discussion_r1058688565 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSumAggFunction.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apac

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

2022-12-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652450#comment-17652450 ] Leonard Xu edited comment on FLINK-27691 at 12/29/22 2:01 AM:

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

2022-12-28 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu closed FLINK-27691. -- Fix Version/s: 1.17.0 1.16.1 Resolution: Fixed > RankHarnessTest. testUpdate

[GitHub] [flink] lsyldliu commented on a diff in pull request #21401: [FLINK-29718][table] Supports hive sum function by native implementation

2022-12-28 Thread GitBox
lsyldliu commented on code in PR #21401: URL: https://github.com/apache/flink/pull/21401#discussion_r1058687922 ## flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/HiveSumAggFunction.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apac

[GitHub] [flink] leonardBang merged pull request #21568: [bp-1.16][FLINK-27691][table-planner] Remove unnecessary state ttl to avoid unstable results of RankHarnessTest

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

[jira] [Updated] (FLINK-30531) Reduce operator chain call stack depth

2022-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30531: - Description: Benchmark results show that Flink time to execute simple programs is more than 3X slower t

[jira] [Updated] (FLINK-30531) Reduce operator chain call stack depth

2022-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30531: - Description: Benchmark results show that Flink time to execute simple programs is more than 3X slower t

[jira] [Updated] (FLINK-30531) Reduce operator chain call stack depth

2022-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30531: - Description: Benchmark results show that Flink time to execute simple programs is more than 3X slower t

[jira] [Updated] (FLINK-30515) Add benchmark for CountVectorizer, Imputer, RobustScaler, UnivariateFeatureSelector and VarianceThresholdSelector

2022-12-28 Thread Jiang Xin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiang Xin updated FLINK-30515: -- Component/s: Library / Machine Learning Fix Version/s: ml-2.2.0 Issue Type: Improvement (

[jira] [Created] (FLINK-30532) Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm

2022-12-28 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30532: Summary: Add benchmark for DCT, SQLTransformer and StopWordsRemover algorithm Key: FLINK-30532 URL: https://issues.apache.org/jira/browse/FLINK-30532 Project: Flink

[jira] [Updated] (FLINK-30531) Reduce operator chain call stack depth

2022-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated FLINK-30531: - Description: Benchmark results show that Flink time to execute simple programs is more than 3X slower t

[jira] [Assigned] (FLINK-30531) Reduce operator chain call stack depth

2022-12-28 Thread Dong Lin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin reassigned FLINK-30531: Assignee: Dong Lin > Reduce operator chain call stack depth > ---

[jira] [Created] (FLINK-30531) Reduce operator chain call stack depth

2022-12-28 Thread Dong Lin (Jira)
Dong Lin created FLINK-30531: Summary: Reduce operator chain call stack depth Key: FLINK-30531 URL: https://issues.apache.org/jira/browse/FLINK-30531 Project: Flink Issue Type: Improvement

[GitHub] [flink] zhuzhurk commented on a diff in pull request #21162: [FLINK-29665][runtime] Support flexible subpartion range division

2022-12-28 Thread GitBox
zhuzhurk commented on code in PR #21162: URL: https://github.com/apache/flink/pull/21162#discussion_r1058681107 ## flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/VertexInputInfoComputationUtils.java: ## @@ -0,0 +1,261 @@ +/* + * Licensed to the Apache Softwa

[GitHub] [flink-table-store] Gerrrr commented on pull request #447: Speed up FTS build

2022-12-28 Thread GitBox
Ge commented on PR #447: URL: https://github.com/apache/flink-table-store/pull/447#issuecomment-1366985547 In addition, I would like to add a recommendation on the [Build from source page](https://nightlies.apache.org/flink/flink-table-store-docs-master/docs/engines/build/) to use the

[GitHub] [flink-table-store] Gerrrr opened a new pull request, #447: Speed up FTS build

2022-12-28 Thread GitBox
Ge opened a new pull request, #447: URL: https://github.com/apache/flink-table-store/pull/447 With this patch the maven build takes around 1 minute instead of 20 on my laptop. There are 2 changes - pinning a dependency in 1b6f8012328522b945dc5e36eda7ee946159c6c9 and updating 2 p

[jira] [Updated] (FLINK-30530) Flink configuration from user-provided ConfigMap

2022-12-28 Thread Arseniy Tashoyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arseniy Tashoyan updated FLINK-30530: - Description: Currently the Flink configuration can be specified in the YAML descriptor o

[jira] [Updated] (FLINK-30530) Flink configuration from user-provided ConfigMap

2022-12-28 Thread Arseniy Tashoyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arseniy Tashoyan updated FLINK-30530: - Description: Currently the Flink configuration can be specified in the YAML descriptor o

[jira] [Updated] (FLINK-30530) Flink configuration from user-provided ConfigMap

2022-12-28 Thread Arseniy Tashoyan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arseniy Tashoyan updated FLINK-30530: - Description: Currently the Flink configuration can be specified in the YAML descriptor o

[jira] [Created] (FLINK-30530) Flink configuration from user-provided ConfigMap

2022-12-28 Thread Arseniy Tashoyan (Jira)
Arseniy Tashoyan created FLINK-30530: Summary: Flink configuration from user-provided ConfigMap Key: FLINK-30530 URL: https://issues.apache.org/jira/browse/FLINK-30530 Project: Flink Issu

[GitHub] [flink-connector-opensearch] ypark2103 commented on pull request #1: [FLINK-25756] [connectors/opensearch] Dedicated Opensearch connectors

2022-12-28 Thread GitBox
ypark2103 commented on PR #1: URL: https://github.com/apache/flink-connector-opensearch/pull/1#issuecomment-1366853846 @reta I heard java 8 was deprecated starting Flink 1.15. Does it mean I need to upgrade to java 11 to use this connector? Or can I still use java 8 for Flink 1.16? -- T

[GitHub] [flink] gyfora commented on pull request #21515: [FLINK-30429][client] Fix IllegalArgumentException when no argument in flink executable

2022-12-28 Thread GitBox
gyfora commented on PR #21515: URL: https://github.com/apache/flink/pull/21515#issuecomment-1366773913 @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-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652535#comment-17652535 ] Gyula Fora commented on FLINK-30518: Please test this with replicas 1 and 2 and see

[jira] [Closed] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-30406. -- Fix Version/s: kubernetes-operator-1.3.1 Resolution: Fixed merged to main 6ff02908b254c0f8e732

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652533#comment-17652533 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:20 PM: --

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652533#comment-17652533 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:12 PM: --

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652533#comment-17652533 ] Binh-Nguyen Tran commented on FLINK-30518: -- [~gyfora] I did not test with jobs

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #495: [backport][FLINK-30406] Detect when jobmanager never started

2022-12-28 Thread GitBox
gyfora merged PR #495: URL: https://github.com/apache/flink-kubernetes-operator/pull/495 -- 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-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652532#comment-17652532 ] Gyula Fora commented on FLINK-30518: But can you clarify what doesn't work with mult

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652530#comment-17652530 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:03 PM: --

[jira] [Comment Edited] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652530#comment-17652530 ] Binh-Nguyen Tran edited comment on FLINK-30518 at 12/28/22 4:03 PM: --

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Binh-Nguyen Tran (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652530#comment-17652530 ] Binh-Nguyen Tran commented on FLINK-30518: -- [~gyfora] I think my assumption is

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: 1.15.3 1.16.0 > Arguments contains with '#' will error spl

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Component/s: API / Core (was: Kubernetes Operator) > Arguments contains with '#

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: (was: kubernetes-operator-1.3.0) > Arguments contains with '#' will error spl

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Component/s: Kubernetes Operator (was: API / Core) > Arguments contains with '#

[jira] [Updated] (FLINK-30520) Arguments contains with '#' will error split in loadYAMLResource

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora updated FLINK-30520: --- Affects Version/s: kubernetes-operator-1.3.0 (was: 1.16.0)

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

2022-12-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652529#comment-17652529 ] Gyula Fora commented on FLINK-30518: Strange, the standalone and native integration

  1   2   >