[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[GitHub] [flink] flinkbot edited a comment on pull request #18995: [FLINK-26498][TABLE][WINDOW]emit result when cleanupTime timer call onEventTime if allowlatency e…

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18995: URL: https://github.com/apache/flink/pull/18995#issuecomment-1060511804 ## CI report: * 0b607728d4aa0cfbd216575dbc449565de505713 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Created] (FLINK-26535) Introduce StoreTableSource and StoreTableSink

2022-03-08 Thread Jane Chan (Jira)
Jane Chan created FLINK-26535: - Summary: Introduce StoreTableSource and StoreTableSink Key: FLINK-26535 URL: https://issues.apache.org/jira/browse/FLINK-26535 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26527) ClassCastException in TemporaryClassLoaderContext

2022-03-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502784#comment-17502784 ] Martijn Visser commented on FLINK-26527: [~tinny] You're suffering from the prob

[jira] [Updated] (FLINK-26535) Introduce StoreTableSource and StoreTableSink

2022-03-08 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26535: -- Description: Introduce StoreTableSource and StoreTableSink, which creates StoreSource and StoreSink re

[jira] [Updated] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

2022-03-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-26524: --- Description: e2e test {{Elasticsearch (v5.3.3) sink end-to-end test}} failed in [this build

[jira] [Commented] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

2022-03-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502785#comment-17502785 ] Martijn Visser commented on FLINK-26524: Thanks for clarifying [~guoyangze] - Sh

[jira] [Updated] (FLINK-26535) Introduce StoreTableSource and StoreTableSink

2022-03-08 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26535: -- Description: Introduce StoreTableSource and StoreTableSink, which creates StoreSource and StoreSink re

[jira] [Updated] (FLINK-26535) Introduce StoreTableSource and StoreTableSink

2022-03-08 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jane Chan updated FLINK-26535: -- Description: Introduce StoreTableSource and StoreTableSink, which creates StoreSource and StoreSink re

[jira] [Assigned] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26534: Assignee: lincoln lee > shuffle by sink's primary key should cover the case that input ch

[GitHub] [flink] flinkbot edited a comment on pull request #18994: [FLINK-26505][hive] Support non equality condition for left semi join…

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18994: URL: https://github.com/apache/flink/pull/18994#issuecomment-1060435366 ## CI report: * 83c89641a59ebb45c7260e04b096f3d79d4e32e0 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-26535) Introduce StoreTableSource and StoreTableSink

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26535: Assignee: Jane Chan > Introduce StoreTableSource and StoreTableSink > ---

[jira] [Updated] (FLINK-26535) Introduce StoreTableSource and StoreTableSink

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-26535: - Fix Version/s: table-store-0.1.0 > Introduce StoreTableSource and StoreTableSink > -

[GitHub] [flink] smattheis commented on pull request #18984: [hotfix][docs] Fix HTML formatting in ops/metrics.md

2022-03-08 Thread GitBox
smattheis commented on pull request #18984: URL: https://github.com/apache/flink/pull/18984#issuecomment-1061513936 @pnowojski backport to any previous version not required as `watermarkAlignmentDrift` is new in 1.15 -- This is an automated message from the Apache Git Service. To respond

[jira] [Commented] (FLINK-26527) ClassCastException in TemporaryClassLoaderContext

2022-03-08 Thread shizhengchao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502790#comment-17502790 ] shizhengchao commented on FLINK-26527: -- [~martijnvisser] Thanks, I've got it, it's

[jira] [Commented] (FLINK-26524) Elasticsearch (v5.3.3) sink end-to-end test

2022-03-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26524?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502792#comment-17502792 ] Martijn Visser commented on FLINK-26524: This probably won't get picked up sooni

[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * a7efad2153427eeb07dcdede96c89f6db1ec5b7f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Updated] (FLINK-26137) Create webhook REST api test

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26137: --- Labels: pull-request-available (was: ) > Create webhook REST api test > ---

[GitHub] [flink] flinkbot edited a comment on pull request #19002: [FLINK-26501] extra log

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19002: URL: https://github.com/apache/flink/pull/19002#issuecomment-1060970183 ## CI report: * a7efad2153427eeb07dcdede96c89f6db1ec5b7f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Closed] (FLINK-26527) ClassCastException in TemporaryClassLoaderContext

2022-03-08 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-26527. -- Resolution: Not A Problem Thanks for getting back on this [~tinny] ! Good luck on your next st

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 8e46affb05226eeed6b8eb20df971445139654a8 Azure: [FAILURE](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #19004: [FLINK-26490][checkpoint] Adjust the MaxParallelism when operator state don't contain keyed state.

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19004: URL: https://github.com/apache/flink/pull/19004#issuecomment-1061472524 ## CI report: * b4fe404fd3eb4563d6e476c83c4d29c947752571 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resu

[jira] [Assigned] (FLINK-26137) Create webhook REST api test

2022-03-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26137: -- Assignee: Nicholas Jiang > Create webhook REST api test > > >

[jira] [Commented] (FLINK-26137) Create webhook REST api test

2022-03-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502798#comment-17502798 ] Gyula Fora commented on FLINK-26137: done :)  > Create webhook REST api test >

[jira] [Commented] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-08 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502799#comment-17502799 ] Matyas Orhidi commented on FLINK-26521: --- +1 Since we don't need to trigger savepoi

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 610f23f625a4559bef6f000916a2de37a5cb3b38 Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-08 Thread GitBox
JingsongLi commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r821432900 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/OrcFileStatsExtractor.java ## @@ -0,0 +1,183 @@ +/* +

[jira] [Commented] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-08 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502800#comment-17502800 ] Matyas Orhidi commented on FLINK-26521: --- We need to think of a clever way to resta

[jira] [Closed] (FLINK-26526) Record hasNull and allNull instead of nullCount in FieldStats

2022-03-08 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-26526. --- Resolution: Not A Problem > Record hasNull and allNull instead of nullCount in FieldStats >

[jira] [Comment Edited] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-08 Thread Matyas Orhidi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502800#comment-17502800 ] Matyas Orhidi edited comment on FLINK-26521 at 3/8/22, 8:34 AM: --

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-08 Thread GitBox
JingsongLi commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r821433871 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/OrcFileStatsExtractor.java ## @@ -0,0 +1,183 @@ +/* +

[GitHub] [flink] flinkbot edited a comment on pull request #18303: [FLINK-25085][runtime] Add a scheduled thread pool for periodic tasks in RpcEndpoint

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18303: URL: https://github.com/apache/flink/pull/18303#issuecomment-1008005239 ## CI report: * ecd80ec7a11dae690b258377aab2428872a0abdb Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 610f23f625a4559bef6f000916a2de37a5cb3b38 Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] lincoln-lil opened a new pull request #19006: [FLINK-26534][table-planner] shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-08 Thread GitBox
lincoln-lil opened a new pull request #19006: URL: https://github.com/apache/flink/pull/19006 ## What is the purpose of the change FLINK-20370 fix the wrong result when sink primary key is not the same with query and introduced a new auto-keyby sink's primary key strategy for append str

[jira] [Updated] (FLINK-26534) shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26534: --- Labels: pull-request-available (was: ) > shuffle by sink's primary key should cover the cas

[jira] [Updated] (FLINK-26496) [JUnit5 Migration] Module: flink-yarn-test

2022-03-08 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-26496: --- Parent: FLINK-25325 Issue Type: Sub-task (was: Improvement) > [JUnit5 Migration] Module: fl

[jira] [Assigned] (FLINK-26513) Document operator helm chart

2022-03-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-26513: -- Assignee: Márton Balassi > Document operator helm chart > > >

[jira] [Assigned] (FLINK-26468) Test default binding to localhost

2022-03-08 Thread Joe Moser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Moser reassigned FLINK-26468: - Assignee: Gabor Somogyi > Test default binding to localhost > -

[jira] [Commented] (FLINK-26424) RequestTimeoutException

2022-03-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26424?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502804#comment-17502804 ] Till Rohrmann commented on FLINK-26424: --- I think we will soon solve this problem.

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

2022-03-08 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502807#comment-17502807 ] Till Rohrmann commented on FLINK-23190: --- Sorry for not getting back to your PR [~l

[jira] [Closed] (FLINK-26377) Extract Reconciler interface

2022-03-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26377. -- Resolution: Fixed > Extract Reconciler interface > > > Ke

[jira] [Closed] (FLINK-26471) Deleting the operator while jobs are running causes the jobs to fail

2022-03-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26471. -- Resolution: Fixed merged: 8abb9f7af486e6e2cc729b24645d0ed36e8482fc > Deleting the operator while jobs

[GitHub] [flink] flinkbot edited a comment on pull request #17959: [hotfix][doc] Remove redundant document description

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #17959: URL: https://github.com/apache/flink/pull/17959#issuecomment-982471429 ## CI report: * e7dfb46f6688fdb610a54f1058b0d6069d0c93d3 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 610f23f625a4559bef6f000916a2de37a5cb3b38 Azure: [CANCELED](https://dev.azure.com/apache-

[jira] [Created] (FLINK-26536) PyFlink RemoteKeyedStateBackend#merge_namespaces bug

2022-03-08 Thread Juntao Hu (Jira)
Juntao Hu created FLINK-26536: - Summary: PyFlink RemoteKeyedStateBackend#merge_namespaces bug Key: FLINK-26536 URL: https://issues.apache.org/jira/browse/FLINK-26536 Project: Flink Issue Type: Bu

[GitHub] [flink] flinkbot commented on pull request #19006: [FLINK-26534][table-planner] shuffle by sink's primary key should cover the case that input changelog stream has a different parallelism

2022-03-08 Thread GitBox
flinkbot commented on pull request #19006: URL: https://github.com/apache/flink/pull/19006#issuecomment-1061561518 ## CI report: * a110bde8a2512a88f6f77b0d4b1d6952f599ac43 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-25684) Support enhanced show databases syntax

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502814#comment-17502814 ] Jingsong Lee commented on FLINK-25684: -- [~jark]  > Support enhanced show databases

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 610f23f625a4559bef6f000916a2de37a5cb3b38 Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #19006: [FLINK-26534][table-planner] shuffle by sink's primary key should cover the case that input changelog stream has a different parallel

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19006: URL: https://github.com/apache/flink/pull/19006#issuecomment-1061561518 ## CI report: * a110bde8a2512a88f6f77b0d4b1d6952f599ac43 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] LadyForest opened a new pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

2022-03-08 Thread GitBox
LadyForest opened a new pull request #19007: URL: https://github.com/apache/flink/pull/19007 ## What is the purpose of the change This PR aims to throw an explicit exception when querying a view with hints to improve user experience. Currently, the hints on view are swallowed quietly

[jira] [Updated] (FLINK-26495) Dynamic table options does not work for view

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26495: --- Labels: pull-request-available (was: ) > Dynamic table options does not work for view > ---

[jira] [Commented] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-08 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502816#comment-17502816 ] Yang Wang commented on FLINK-26521: --- Maybe we could introduce a new reconciler in the

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 610f23f625a4559bef6f000916a2de37a5cb3b38 Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot commented on pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

2022-03-08 Thread GitBox
flinkbot commented on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1061572668 ## CI report: * 7e6f04294c00b3ec399aef1b3d8f71dfe150c579 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-26521) Reconsider setting generationAwareEventProcessing = true

2022-03-08 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-26521. -- Resolution: Fixed closed: a2412c0f2434d8005be12318ec347cbe60502753 > Reconsider setting generationAwa

[GitHub] [flink] Vancior opened a new pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-08 Thread GitBox
Vancior opened a new pull request #19008: URL: https://github.com/apache/flink/pull/19008 ## What is the purpose of the change This pull request fix two bugs in PyFlink RemoteKeyedStateBackend#merge_namespaces, which lead to incorrect result of session window merging.

[jira] [Updated] (FLINK-26536) PyFlink RemoteKeyedStateBackend#merge_namespaces bug

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26536: --- Labels: pull-request-available (was: ) > PyFlink RemoteKeyedStateBackend#merge_namespaces b

[GitHub] [flink] SteNicholas commented on pull request #18892: [FLINK-25177][table] Support 'DESCRIBE TABLE EXTENDED' with managed table

2022-03-08 Thread GitBox
SteNicholas commented on pull request #18892: URL: https://github.com/apache/flink/pull/18892#issuecomment-1061576277 @JingsongLi, could you please help to review this pull request? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

[GitHub] [flink] flinkbot edited a comment on pull request #18892: [FLINK-25177][table] Support 'DESCRIBE TABLE EXTENDED' with managed table

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18892: URL: https://github.com/apache/flink/pull/18892#issuecomment-1048407140 ## CI report: * 82dfead6209ea99d6642abac1534bb2a89dc9591 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19003: URL: https://github.com/apache/flink/pull/19003#issuecomment-1061377385 ## CI report: * d412278f22b0f79c0af6481398cb697a82da0ad5 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19007: [FLINK-26495][table-planner] Prohibit hints(dynamic table options) on view

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19007: URL: https://github.com/apache/flink/pull/19007#issuecomment-1061572668 ## CI report: * 7e6f04294c00b3ec399aef1b3d8f71dfe150c579 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] tsreaper commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-08 Thread GitBox
tsreaper commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r821481242 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/OrcFileStatsExtractor.java ## @@ -0,0 +1,183 @@ +/* + *

[GitHub] [flink] flinkbot commented on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-08 Thread GitBox
flinkbot commented on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 290c71daa6e7502d0715349a784d43ee27c1c2dd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] gaoyunhaii commented on pull request #18805: [FLINK-26516][streaming] Recover GlobalCommittables with Sink V1 GlobalCommittable serializer

2022-03-08 Thread GitBox
gaoyunhaii commented on pull request #18805: URL: https://github.com/apache/flink/pull/18805#issuecomment-1061584175 I added a fix for the failed azure test: previously if there are no committables the combine and commit would be skipped, otherwise there might create an empty global commit

[jira] [Commented] (FLINK-26458) Rename Accumulator to MergeFunction

2022-03-08 Thread Jane Chan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502822#comment-17502822 ] Jane Chan commented on FLINK-26458: --- I can take this ticket. > Rename Accumulator to

[GitHub] [flink] honnix opened a new pull request #19009: [hotfix] [docs] Refer to Running in an IDE section early on

2022-03-08 Thread GitBox
honnix opened a new pull request #19009: URL: https://github.com/apache/flink/pull/19009 ## What is the purpose of the change When following this doc, I found myself searching on Google instead of reading the final section that is pretty further away. It might be useful to have an e

[GitHub] [flink] zhuzhurk commented on a change in pull request #19003: [FLINK-26517][runtime] Normalize the decided parallelism to power of 2 when using adaptive batch scheduler

2022-03-08 Thread GitBox
zhuzhurk commented on a change in pull request #19003: URL: https://github.com/apache/flink/pull/19003#discussion_r821468782 ## File path: flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java ## @@ -531,7 +531,9 @@ .withDescriptio

[GitHub] [flink] honnix commented on a change in pull request #19009: [hotfix] [docs] Refer to Running in an IDE section early on

2022-03-08 Thread GitBox
honnix commented on a change in pull request #19009: URL: https://github.com/apache/flink/pull/19009#discussion_r821491306 ## File path: docs/content/docs/try-flink/datastream.md ## @@ -902,4 +903,4 @@ You should see the following output in your task manager logs: Running t

[GitHub] [flink] flinkbot edited a comment on pull request #18863: [FLINK-26033][flink-connector-kafka]Fix the problem that robin does not take effect due to upgrading kafka client to 2.4.1 since Flin

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18863: URL: https://github.com/apache/flink/pull/18863#issuecomment-1046819200 ## CI report: * 8cda572f57f1ee4a969e84d51b05d1e1ba74887f Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18805: [FLINK-26516][streaming] Recover GlobalCommittables with Sink V1 GlobalCommittable serializer

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18805: URL: https://github.com/apache/flink/pull/18805#issuecomment-1041554745 ## CI report: * e0cc9d1d2036b964077a274f7425cab180404583 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18892: [FLINK-25177][table] Support 'DESCRIBE TABLE EXTENDED' with managed table

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18892: URL: https://github.com/apache/flink/pull/18892#issuecomment-1048407140 ## CI report: * 82dfead6209ea99d6642abac1534bb2a89dc9591 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 610f23f625a4559bef6f000916a2de37a5cb3b38 Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #19008: [FLINK-26536] [python] Fix PyFlink RemoteKeyedStateBackend#merge_namespaces bugs

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19008: URL: https://github.com/apache/flink/pull/19008#issuecomment-1061583264 ## CI report: * 290c71daa6e7502d0715349a784d43ee27c1c2dd Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] paul8263 opened a new pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

2022-03-08 Thread GitBox
paul8263 opened a new pull request #19010: URL: https://github.com/apache/flink/pull/19010 ## What is the purpose of the change Compared English with Chinese version, the orders of articles locates in TOC for docs learn Flink are different. ## Brief change log - docs/co

[jira] [Assigned] (FLINK-26458) Rename Accumulator to MergeFunction

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-26458: Assignee: Jane Chan > Rename Accumulator to MergeFunction > -

[jira] [Commented] (FLINK-26458) Rename Accumulator to MergeFunction

2022-03-08 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17502830#comment-17502830 ] Jingsong Lee commented on FLINK-26458: -- [~qingyue] Thanks > Rename Accumulator to

[jira] [Updated] (FLINK-26381) Wrong document order of Chinese version

2022-03-08 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-26381: --- Labels: pull-request-available (was: ) > Wrong document order of Chinese version >

[GitHub] [flink] echauchot commented on pull request #18973: [FLINK-25771][connectors][Cassandra][test] Raise the Cassandra driver timeouts at the Cluster level

2022-03-08 Thread GitBox
echauchot commented on pull request #18973: URL: https://github.com/apache/flink/pull/18973#issuecomment-1061605587 Hi @zentol, WDYT ? -- 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 spe

[GitHub] [flink] flinkbot edited a comment on pull request #18805: [FLINK-26516][streaming] Recover GlobalCommittables with Sink V1 GlobalCommittable serializer

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18805: URL: https://github.com/apache/flink/pull/18805#issuecomment-1041554745 ## CI report: * e0cc9d1d2036b964077a274f7425cab180404583 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-08 Thread GitBox
JingsongLi commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r821524301 ## File path: flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/FieldStatsCollector.java ## @@ -35,7 +35,7 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * ca91f03a2674f7041d3a66c618f833809c6e98aa Azure: [CANCELED](https://dev.azure.com/apache-

[GitHub] [flink] flinkbot edited a comment on pull request #19005: [FLINK-26531][kafka] KafkaWriterITCase.testMetadataPublisher failed on azure

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19005: URL: https://github.com/apache/flink/pull/19005#issuecomment-1061480820 ## CI report: * a259c21a8693b3bc8b6732f3f5a9372dc846a658 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink-table-store] JingsongLi commented on a change in pull request #33: [FLINK-26346] Add statistics collecting to sst files

2022-03-08 Thread GitBox
JingsongLi commented on a change in pull request #33: URL: https://github.com/apache/flink-table-store/pull/33#discussion_r821528073 ## File path: flink-table-store-orc/src/main/java/org/apache/flink/table/store/orc/OrcFileStatsExtractor.java ## @@ -0,0 +1,183 @@ +/* + * Licen

[GitHub] [flink] flinkbot commented on pull request #19009: [hotfix] [docs] Refer to Running in an IDE section early on

2022-03-08 Thread GitBox
flinkbot commented on pull request #19009: URL: https://github.com/apache/flink/pull/19009#issuecomment-1061628385 ## CI report: * 282572e53fc0db37c831a9486742e1b5a51663e0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

2022-03-08 Thread GitBox
flinkbot commented on pull request #19010: URL: https://github.com/apache/flink/pull/19010#issuecomment-1061632219 ## CI report: * 68d688153e4d21853ce41a4894fd6d66e1347fab UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * ca91f03a2674f7041d3a66c618f833809c6e98aa Azure: [CANCELED](https://dev.azure.com/apache-

[jira] [Updated] (FLINK-18779) Support the SupportsFilterPushDown interface for LookupTableSource

2022-03-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18779: --- Labels: auto-unassigned pull-request-available stale-assigned (was: auto-unassigned pull-re

[jira] [Updated] (FLINK-12639) FLIP-42: Rework Documentation

2022-03-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12639?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-12639: --- Labels: auto-deprioritized-major auto-deprioritized-minor pull-request-available usability

[jira] [Updated] (FLINK-26272) Elasticsearch7SinkITCase.testWriteJsonToElasticsearch fails with socket timeout

2022-03-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-26272: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-25456) FlinkKafkaProducerITCase.testScaleDownBeforeFirstCheckpoint

2022-03-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25456: --- Labels: stale-critical test-stability (was: test-stability) I am the [Flink Jira Bot|https:

[jira] [Updated] (FLINK-25306) Flink CLI end-to-end test timeout on azure

2022-03-08 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25306: --- Labels: auto-deprioritized-critical stale-major test-stability (was: auto-deprioritized-cri

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

2022-03-08 Thread loyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loyi updated FLINK-23190: - Flags: (was: Patch) > Make task-slot allocation much more evenly > --

[GitHub] [flink] flinkbot edited a comment on pull request #18978: [FLINK-25549][flink-dstl] [JUnit5 Migration] Module: flink-dstl

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18978: URL: https://github.com/apache/flink/pull/18978#issuecomment-1059111709 ## CI report: * d55c277b2822bf631c2cb22483c646ff2104d322 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19009: [hotfix] [docs] Refer to Running in an IDE section early on

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19009: URL: https://github.com/apache/flink/pull/19009#issuecomment-1061628385 ## CI report: * 282572e53fc0db37c831a9486742e1b5a51663e0 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #19010: [FLINK-26381][docs] Wrong document order of Chinese version

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #19010: URL: https://github.com/apache/flink/pull/19010#issuecomment-1061632219 ## CI report: * 68d688153e4d21853ce41a4894fd6d66e1347fab Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] zoucao commented on a change in pull request #18966: [FLINK-26422][docs-zh][table]update chinese doc with the new TablePipeline docs

2022-03-08 Thread GitBox
zoucao commented on a change in pull request #18966: URL: https://github.com/apache/flink/pull/18966#discussion_r821541527 ## File path: docs/content.zh/docs/dev/table/data_stream_api.md ## @@ -596,13 +596,13 @@ pipeline or a statement set: ```java // execute with explicit

[GitHub] [flink] flinkbot edited a comment on pull request #18978: [FLINK-25549][flink-dstl] [JUnit5 Migration] Module: flink-dstl

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18978: URL: https://github.com/apache/flink/pull/18978#issuecomment-1059111709 ## CI report: * d55c277b2822bf631c2cb22483c646ff2104d322 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #18957: [FLINK-26444][python]Window allocator supporting pyflink datastream API

2022-03-08 Thread GitBox
flinkbot edited a comment on pull request #18957: URL: https://github.com/apache/flink/pull/18957#issuecomment-1056202149 ## CI report: * ec1e0a435186082e5ac1481bc093f9bdd9d94d70 UNKNOWN * 47cdf91d5086b292f20d40700c7bd9052e32a6e0 Azure: [CANCELED](https://dev.azure.com/apache-

  1   2   3   4   >