[jira] [Created] (FLINK-28603) Flink runtime.rpc.RpcServiceUtils code style

2022-07-18 Thread wuqingzhi (Jira)
wuqingzhi created FLINK-28603: - Summary: Flink runtime.rpc.RpcServiceUtils code style Key: FLINK-28603 URL: https://issues.apache.org/jira/browse/FLINK-28603 Project: Flink Issue Type:

[jira] [Commented] (FLINK-28121) Translate "Extension Points" and "Full Stack Example" in "User-defined Sources & Sinks" page

2022-07-18 Thread hunter (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568334#comment-17568334 ] hunter commented on FLINK-28121: [~yckkcy] Hi,Chengkai,I have completed the translation of the above

[GitHub] [flink] hunter-cloud09 commented on pull request #20283: [FLINK-28122][docs-zh] Translate "User-defined Sources & Sinks" page into Chinese

2022-07-18 Thread GitBox
hunter-cloud09 commented on PR #20283: URL: https://github.com/apache/flink/pull/20283#issuecomment-1188620526 @PatrickRen Hi,Patrick,I just saw that FLINK-28121 has already translated the following content -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #132: [FLINK-28571]Add Chi-squared test as Transformer to ml.feature

2022-07-18 Thread GitBox
yunfengzhou-hub commented on code in PR #132: URL: https://github.com/apache/flink-ml/pull/132#discussion_r924035970 ## flink-ml-lib/src/test/java/org/apache/flink/ml/feature/ChiSqTestTransformerTest.java: ## @@ -0,0 +1,144 @@ +/* + * Licensed to the Apache Software Foundation

[jira] [Created] (FLINK-28602) Changelog cannot close stream normally while enabling compression

2022-07-18 Thread Hangxiang Yu (Jira)
Hangxiang Yu created FLINK-28602: Summary: Changelog cannot close stream normally while enabling compression Key: FLINK-28602 URL: https://issues.apache.org/jira/browse/FLINK-28602 Project: Flink

[jira] [Closed] (FLINK-28307) FLIP-241: Completed Jobs Information Enhancement

2022-07-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28307. Release Note: We have enhanced the experiences of viewing completed jobs’ information in this

[jira] [Closed] (FLINK-28555) Update history server documentation

2022-07-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-28555. Fix Version/s: 1.16.0 Resolution: Done master (1.16):

[GitHub] [flink] xintongsong closed pull request #20297: [FLINK-28307][doc] Update history server docs w.r.t. FLIP-241.

2022-07-18 Thread GitBox
xintongsong closed pull request #20297: [FLINK-28307][doc] Update history server docs w.r.t. FLIP-241. URL: https://github.com/apache/flink/pull/20297 -- 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

[GitHub] [flink] fredia commented on a diff in pull request #20217: [FLINK-27693][state] Support local recovery for non-materialized part

2022-07-18 Thread GitBox
fredia commented on code in PR #20217: URL: https://github.com/apache/flink/pull/20217#discussion_r924060396 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/LocalStateRegistry.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[jira] [Commented] (FLINK-28499) resource leak when job failed with unknown status In Application Mode

2022-07-18 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568322#comment-17568322 ] Yang Wang commented on FLINK-28499: --- Maybe we could improve this by deleting the init error pods when

[GitHub] [flink] fredia commented on a diff in pull request #20217: [FLINK-27693][state] Support local recovery for non-materialized part

2022-07-18 Thread GitBox
fredia commented on code in PR #20217: URL: https://github.com/apache/flink/pull/20217#discussion_r924056241 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/changelog/ChangelogStateBackendLocalHandle.java: ## @@ -0,0 +1,116 @@ +/* + * Licensed to the Apache

[GitHub] [flink] xintongsong commented on pull request #20297: [FLINK-28307][doc] Update history server docs w.r.t. FLIP-241.

2022-07-18 Thread GitBox
xintongsong commented on PR #20297: URL: https://github.com/apache/flink/pull/20297#issuecomment-1188580620 @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

[jira] [Closed] (FLINK-28579) Supports predicate testing for new columns

2022-07-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28579. Resolution: Fixed master: 4d36d8dcb5d20c9517e3532d8aa42aa828ac4c23 > Supports predicate testing

[GitHub] [flink-table-store] JingsongLi merged pull request #223: [FLINK-28579] Supports predicate testing for new columns

2022-07-18 Thread GitBox
JingsongLi merged PR #223: URL: https://github.com/apache/flink-table-store/pull/223 -- 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-28601) Support FeatureHasher in FlinkML

2022-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28601: --- Labels: pull-request-available (was: ) > Support FeatureHasher in FlinkML >

[GitHub] [flink-ml] weibozhao opened a new pull request, #133: [FLINK-28601] Support FeatureHasher in FlinkML

2022-07-18 Thread GitBox
weibozhao opened a new pull request, #133: URL: https://github.com/apache/flink-ml/pull/133 Support FeatureHasher in FlinkML -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[GitHub] [flink] xintongsong commented on pull request #20297: [FLINK-28307][doc] Update history server docs w.r.t. FLIP-241.

2022-07-18 Thread GitBox
xintongsong commented on PR #20297: URL: https://github.com/apache/flink/pull/20297#issuecomment-1188571408 @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

[jira] [Created] (FLINK-28601) Support FeatureHasher in FlinkML

2022-07-18 Thread weibo zhao (Jira)
weibo zhao created FLINK-28601: -- Summary: Support FeatureHasher in FlinkML Key: FLINK-28601 URL: https://issues.apache.org/jira/browse/FLINK-28601 Project: Flink Issue Type: New Feature

[GitHub] [flink] flinkbot commented on pull request #20304: [FLINK-28600][connectors] Support FilterPushDown in flink-connector-jdbc

2022-07-18 Thread GitBox
flinkbot commented on PR #20304: URL: https://github.com/apache/flink/pull/20304#issuecomment-1188570834 ## CI report: * 5a43fbab2b9c1fe1780df4d77cf1b5de9dad1915 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28600) Support FilterPushDown in flink-connector-jdbc

2022-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28600: --- Labels: pull-request-available (was: ) > Support FilterPushDown in flink-connector-jdbc >

[GitHub] [flink] hailin0 opened a new pull request, #20304: [FLINK-28600][connectors] Support FilterPushDown in flink-connector-jdbc

2022-07-18 Thread GitBox
hailin0 opened a new pull request, #20304: URL: https://github.com/apache/flink/pull/20304 ## 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-transferring them

[jira] [Created] (FLINK-28600) Support FilterPushDown in flink-connector-jdbc

2022-07-18 Thread Hailin Wang (Jira)
Hailin Wang created FLINK-28600: --- Summary: Support FilterPushDown in flink-connector-jdbc Key: FLINK-28600 URL: https://issues.apache.org/jira/browse/FLINK-28600 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #20303: [FLINK-28599][table-planner] Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join

2022-07-18 Thread GitBox
flinkbot commented on PR #20303: URL: https://github.com/apache/flink/pull/20303#issuecomment-1188565617 ## CI report: * 15dfbaf1a0ab15dd8ff38b6b4660b46bbc2d48e7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join

2022-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28599: --- Labels: pull-request-available (was: ) > Adding FlinkJoinToMultiJoinRule to support

[GitHub] [flink] flinkbot commented on pull request #20302: [hotfix][table-runtime] Avoid NPE for SliceAssigner and improve error message

2022-07-18 Thread GitBox
flinkbot commented on PR #20302: URL: https://github.com/apache/flink/pull/20302#issuecomment-1188562448 ## CI report: * 32453a6ad95e01d3a1785d1207d2ebb64756fa20 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] swuferhong opened a new pull request, #20303: [FLINK-28599][table-planner] Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join

2022-07-18 Thread GitBox
swuferhong opened a new pull request, #20303: URL: https://github.com/apache/flink/pull/20303 ## What is the purpose of the change For some join cases, like `SELECT * FROM T1 LEFT OUTER JOIN T2 ON a = c LEFT OUTER JOIN (SELECT * FROM T3) ON a = e`, tables `T1`, `T2` and `T3`

[jira] [Closed] (FLINK-28533) SchemaChange supports updateColumnNullability and updateColumnComment

2022-07-18 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-28533. Resolution: Fixed master: d9b3eeef306efa10a8c4f1a5d09be11a33849ead > SchemaChange supports

[GitHub] [flink-table-store] JingsongLi merged pull request #215: [FLINK-28533] SchemaChange supports updateColumnNullability and updateColumnComment

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

[GitHub] [flink] lincoln-lil opened a new pull request, #20302: [hotfix][table-runtime] Avoid NPE for SliceAssigner and improve error message

2022-07-18 Thread GitBox
lincoln-lil opened a new pull request, #20302: URL: https://github.com/apache/flink/pull/20302 ## What is the purpose of the change NPE may occurs at LocalSlicingWindowAggOperator.processElement when an input row with null timestamp column, it would be better to avoid a NPE and improve

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-07-18 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568300#comment-17568300 ] Yuan Mei commented on FLINK-24932: -- Hey, [~yunta] , I think it would be good to resolve this issue

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20233: [FLINK-28474][checkpoint] Simplify the ChannelStateWriterImpl due to concurrent unaligned checkpoint isn't supported

2022-07-18 Thread GitBox
1996fanrui commented on code in PR #20233: URL: https://github.com/apache/flink/pull/20233#discussion_r923351868 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java: ## @@ -60,89 +63,78 @@ public class ChannelStateWriterImpl

[GitHub] [flink] hunter-cloud09 commented on pull request #20283: [FLINK-28122][docs-zh] Translate "User-defined Sources & Sinks" page into Chinese

2022-07-18 Thread GitBox
hunter-cloud09 commented on PR #20283: URL: https://github.com/apache/flink/pull/20283#issuecomment-1188552304 @PatrickRen yep, but the latter part seems a bit heavy and may take some times -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20233: [FLINK-28474][checkpoint] Simplify the ChannelStateWriterImpl due to concurrent unaligned checkpoint isn't supported

2022-07-18 Thread GitBox
1996fanrui commented on code in PR #20233: URL: https://github.com/apache/flink/pull/20233#discussion_r923351868 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java: ## @@ -60,89 +63,78 @@ public class ChannelStateWriterImpl

[GitHub] [flink] PatrickRen commented on pull request #20283: [FLINK-28122][docs-zh] Translate "User-defined Sources & Sinks" page into Chinese

2022-07-18 Thread GitBox
PatrickRen commented on PR #20283: URL: https://github.com/apache/flink/pull/20283#issuecomment-1188548478 @hunter-cloud09 No worries  Would you like to translate the remain part of the doc? It's better to finish the entire page in one PR. -- This is an automated message from the

[GitHub] [flink] hunter-cloud09 commented on pull request #20283: [FLINK-28122][docs-zh] Translate "User-defined Sources & Sinks" page into Chinese

2022-07-18 Thread GitBox
hunter-cloud09 commented on PR #20283: URL: https://github.com/apache/flink/pull/20283#issuecomment-1188546768 @PatrickRen I'm so sorry for these problems. For these problems, they have been solved in the new commit. Please help me review again. -- This is an automated message from

[jira] [Commented] (FLINK-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-07-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568294#comment-17568294 ] Huang Xingbo commented on FLINK-28267: --

[jira] [Commented] (FLINK-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-07-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568292#comment-17568292 ] Huang Xingbo commented on FLINK-28267: --

[jira] [Commented] (FLINK-28267) KafkaSourceLegacyITCase.testBrokerFailure hang on azure

2022-07-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568293#comment-17568293 ] Huang Xingbo commented on FLINK-28267: -- Hi [~renqs] Any updates on the progress? >

[GitHub] [flink-table-store] LadyForest commented on a diff in pull request #223: [FLINK-28579] Supports predicate testing for new columns

2022-07-18 Thread GitBox
LadyForest commented on code in PR #223: URL: https://github.com/apache/flink-table-store/pull/223#discussion_r924013592 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/BinaryTableStats.java: ## @@ -59,8 +59,12 @@ public BinaryTableStats( }

[jira] [Commented] (FLINK-28529) ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode failed with CheckpointException: Checkpoint expired before comple

2022-07-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568291#comment-17568291 ] Huang Xingbo commented on FLINK-28529: -- Hi [~Yanfei Lei], I have merged the PR

[GitHub] [flink-ml] yunfengzhou-hub commented on a diff in pull request #130: [FLINK-28502] Add Transformer for RegexTokenizer

2022-07-18 Thread GitBox
yunfengzhou-hub commented on code in PR #130: URL: https://github.com/apache/flink-ml/pull/130#discussion_r924009394 ## flink-ml-lib/src/main/java/org/apache/flink/ml/feature/regextokenizer/RegexTokenizerParams.java: ## @@ -0,0 +1,77 @@ +/* + * Licensed to the Apache Software

[jira] [Commented] (FLINK-28177) Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with 503 Service Unavailable

2022-07-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568290#comment-17568290 ] Huang Xingbo commented on FLINK-28177: --

[GitHub] [flink] TanYuxin-tyx commented on pull request #20294: [FLINK-28514][network] Remove data flush in SortMergeResultPartition

2022-07-18 Thread GitBox
TanYuxin-tyx commented on PR #20294: URL: https://github.com/apache/flink/pull/20294#issuecomment-1188536886 @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

[jira] [Updated] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to multi join

2022-07-18 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-28599: -- Summary: Adding FlinkJoinToMultiJoinRule to support translating left/right outer join to

[GitHub] [flink] fredia commented on a diff in pull request #20300: [WIP][FLINK-28597][state] Discard non-initial checkpoints without a delay

2022-07-18 Thread GitBox
fredia commented on code in PR #20300: URL: https://github.com/apache/flink/pull/20300#discussion_r924011917 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/SharedStateRegistryImpl.java: ## @@ -192,6 +208,8 @@ public void registerAll( @Override public

[GitHub] [flink] PatrickRen commented on a diff in pull request #20283: [FLINK-28122][docs-zh] Translate "User-defined Sources & Sinks" page into Chinese

2022-07-18 Thread GitBox
PatrickRen commented on code in PR #20283: URL: https://github.com/apache/flink/pull/20283#discussion_r924002285 ## docs/content.zh/docs/dev/table/sourcesSinks.md: ## @@ -24,113 +24,84 @@ specific language governing permissions and limitations under the License. --> -#

[jira] [Updated] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support left/right outer join be translated to multi join

2022-07-18 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28599?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yunhong Zheng updated FLINK-28599: -- Summary: Adding FlinkJoinToMultiJoinRule to support left/right outer join be translated to

[jira] [Commented] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support left/right outer join can be translated to multi join

2022-07-18 Thread Yunhong Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568287#comment-17568287 ] Yunhong Zheng commented on FLINK-28599: --- Hi, [~godfreyhe] , could you assign this to me ! Thanks !

[jira] [Created] (FLINK-28599) Adding FlinkJoinToMultiJoinRule to support left/right outer join can be translated to multi join

2022-07-18 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-28599: - Summary: Adding FlinkJoinToMultiJoinRule to support left/right outer join can be translated to multi join Key: FLINK-28599 URL:

[jira] [Created] (FLINK-28598) ClusterEntryPoint can't get the real exit reason when shutting down

2022-07-18 Thread zlzhang0122 (Jira)
zlzhang0122 created FLINK-28598: --- Summary: ClusterEntryPoint can't get the real exit reason when shutting down Key: FLINK-28598 URL: https://issues.apache.org/jira/browse/FLINK-28598 Project: Flink

[GitHub] [flink] flinkbot commented on pull request #20301: [FLINK-28544][python][e2e] Clean up python environment after e2e tests

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

[GitHub] [flink] WencongLiu commented on a diff in pull request #20236: [FLINK-27769][sql-gateway]Introduce the REST endpoint framework

2022-07-18 Thread GitBox
WencongLiu commented on code in PR #20236: URL: https://github.com/apache/flink/pull/20236#discussion_r924006512 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/versioning/APIVersion.java: ## @@ -0,0 +1,43 @@ +/* + * Licensed to the Apache Software Foundation (ASF)

[GitHub] [flink-table-store] liyubin117 commented on pull request #134: [FLINK-27207] Support built-in parquet format

2022-07-18 Thread GitBox
liyubin117 commented on PR #134: URL: https://github.com/apache/flink-table-store/pull/134#issuecomment-1188528042 @JingsongLi Thanks for your kind reminds, I will refactor parquet formats to adapt the new framework in the late days. :) -- This is an automated message from the Apache

[jira] [Updated] (FLINK-28544) Elasticsearch6SinkE2ECase failed with no space left on device

2022-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28544: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #215: [FLINK-28533] SchemaChange supports updateColumnNullability and updateColumnComment

2022-07-18 Thread GitBox
JingsongLi commented on code in PR #215: URL: https://github.com/apache/flink-table-store/pull/215#discussion_r924001994 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/file/schema/DataType.java: ## @@ -45,6 +45,22 @@ public LogicalType logicalType() {

[GitHub] [flink] HuangXingBo opened a new pull request, #20301: [FLINK-28544][python][e2e] Clean up python environment after e2e tests

2022-07-18 Thread GitBox
HuangXingBo opened a new pull request, #20301: URL: https://github.com/apache/flink/pull/20301 ## What is the purpose of the change *This pull request will clean up python environment after e2e tests* ## Brief change log - *Clean up python environment after e2e

[GitHub] [flink] swuferhong commented on pull request #20084: [FLINK-27988][table-planner] Let HiveTableSource extend from SupportStatisticsReport

2022-07-18 Thread GitBox
swuferhong commented on PR #20084: URL: https://github.com/apache/flink/pull/20084#issuecomment-1188522296 @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

[jira] [Closed] (FLINK-27162) RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed on azure

2022-07-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo closed FLINK-27162. Resolution: Fixed Merged into master via bf983ab1f9bdc7ef1daed15397abf0b032ad2919 >

[GitHub] [flink] HuangXingBo closed pull request #19864: [FLINK-27162][runtime] Trigger non-periodic checkpoint in 'timer' thread

2022-07-18 Thread GitBox
HuangXingBo closed pull request #19864: [FLINK-27162][runtime] Trigger non-periodic checkpoint in 'timer' thread URL: https://github.com/apache/flink/pull/19864 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] xintongsong commented on pull request #20297: [FLINK-28307][doc] Update history server docs w.r.t. FLIP-241.

2022-07-18 Thread GitBox
xintongsong commented on PR #20297: URL: https://github.com/apache/flink/pull/20297#issuecomment-1188517346 @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

[jira] [Commented] (FLINK-28562) Rocksdb state backend is too slow when using AggregateFunction

2022-07-18 Thread Yue Shang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568279#comment-17568279 ] Yue Shang commented on FLINK-28562: --- ok, i will reach out to the community for help.   thank you.

[GitHub] [flink] luoyuxia commented on pull request #20283: [FLINK-28122][docs-zh] Translate "User-defined Sources & Sinks" page into Chinese

2022-07-18 Thread GitBox
luoyuxia commented on PR #20283: URL: https://github.com/apache/flink/pull/20283#issuecomment-1188507492 @PatrickRen Could you please help review when you are free? -- 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] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

2022-07-18 Thread GitBox
zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r923989858 ## flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html: ## @@ -551,15 +551,15 @@ -

[GitHub] [flink] zoltar9264 commented on a diff in pull request #20103: [FLINK-28178][runtime-web] Show the delegated StateBackend and whethe…

2022-07-18 Thread GitBox
zoltar9264 commented on code in PR #20103: URL: https://github.com/apache/flink/pull/20103#discussion_r923988243 ## flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointConfigInfo.java: ## @@ -65,6 +65,8 @@ public class CheckpointConfigInfo

[GitHub] [flink-table-store] JingsongLi commented on a diff in pull request #216: [FLINK-28482] num-sorted-run.stop-trigger introduced a unstable merging

2022-07-18 Thread GitBox
JingsongLi commented on code in PR #216: URL: https://github.com/apache/flink-table-store/pull/216#discussion_r923982350 ## flink-table-store-core/src/main/java/org/apache/flink/table/store/CoreOptions.java: ## @@ -429,6 +438,10 @@ public int maxFileNum() { return

[jira] [Updated] (FLINK-28590) flink on yarn checkpoint exception

2022-07-18 Thread wangMu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangMu updated FLINK-28590: --- Component/s: Deployment / YARN Runtime / Checkpointing > flink on yarn checkpoint

[GitHub] [flink] xinbinhuang commented on pull request #20289: [FLINK-23633][FLIP-150][connector/common] HybridSource: Support dynamic stop position in FileSource

2022-07-18 Thread GitBox
xinbinhuang commented on PR #20289: URL: https://github.com/apache/flink/pull/20289#issuecomment-1188474251 @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

[GitHub] [flink] lindong28 commented on a diff in pull request #20275: [FLINK-26029][Runtime/Checkpointing] Generalize the checkpoint protocol of OperatorCoordinator

2022-07-18 Thread GitBox
lindong28 commented on code in PR #20275: URL: https://github.com/apache/flink/pull/20275#discussion_r923952394 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorEventDispatcherImpl.java: ## @@ -82,6 +83,10 @@ public void

[GitHub] [flink] flinkbot commented on pull request #20300: [WIP][FLINK-28597][state] Discard non-initial checkpoints without a delay

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

[jira] [Updated] (FLINK-28597) Empty checkpoint folders not deleted on job cancellation if their shared state is still in use

2022-07-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-28597: --- Labels: pull-request-available (was: ) > Empty checkpoint folders not deleted on job

[GitHub] [flink] rkhachatryan opened a new pull request, #20300: [WIP][FLINK-28597][state] Discard non-initial checkpoints without a delay

2022-07-18 Thread GitBox
rkhachatryan opened a new pull request, #20300: URL: https://github.com/apache/flink/pull/20300 ## What is the purpose of the change ``` Newly created checkpoints can be discarded right after subsumption. But the initial checkpoint needs to be kept until all of its private AND

[jira] [Updated] (FLINK-28597) Empty checkpoint folders not deleted on job cancellation if their shared state is still in use

2022-07-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-28597: -- Description: After FLINK-25872, SharedStateRegistry registers all state handles,

[jira] [Created] (FLINK-28597) Empty checkpoint folders not deleted on job cancellation if their shared state is still in use

2022-07-18 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-28597: - Summary: Empty checkpoint folders not deleted on job cancellation if their shared state is still in use Key: FLINK-28597 URL:

[jira] [Updated] (FLINK-27701) HashMapStateBackendWindowITCase. testAggregateWindowStateReader failed with Not all required tasks are currently running

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

[jira] [Updated] (FLINK-24434) PyFlink YARN per-job on Docker test fails on Azure

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

[jira] [Updated] (FLINK-25119) The name of freeSlots parameter in SlotSharingSlotAllocator#determineParallelism method is named incorrectly.

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

[jira] [Updated] (FLINK-25962) Flink generated Avro schemas can't be parsed using Python

2022-07-18 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-25962: --- Labels: auto-deprioritized-major pull-request-available stale-major (was:

[jira] [Updated] (FLINK-27695) KafkaTransactionLogITCase failed on azure due to Could not find a valid Docker environment

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

[jira] [Commented] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector

2022-07-18 Thread Bobby Richard (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568218#comment-17568218 ] Bobby Richard commented on FLINK-28596: --- Looking at the code it looks like the

[jira] [Created] (FLINK-28596) Support writing arrays to postgres array columns in Flink SQL JDBC connector

2022-07-18 Thread Bobby Richard (Jira)
Bobby Richard created FLINK-28596: - Summary: Support writing arrays to postgres array columns in Flink SQL JDBC connector Key: FLINK-28596 URL: https://issues.apache.org/jira/browse/FLINK-28596

[jira] [Created] (FLINK-28595) KafkaSource should not read metadata of unmatched regex topics

2022-07-18 Thread Afzal Mazhar (Jira)
Afzal Mazhar created FLINK-28595: Summary: KafkaSource should not read metadata of unmatched regex topics Key: FLINK-28595 URL: https://issues.apache.org/jira/browse/FLINK-28595 Project: Flink

[GitHub] [flink-kubernetes-operator] gyfora merged pull request #321: [FLINK-27714][hotfix] Update NOTICE file

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

[GitHub] [flink-kubernetes-operator] morhidi opened a new pull request, #321: [FLINK-27914][hotfix] Update NOTICE file

2022-07-18 Thread GitBox
morhidi opened a new pull request, #321: URL: https://github.com/apache/flink-kubernetes-operator/pull/321 ## What is the purpose of the change Update NOTICE file with dependency changes from [FLINK-27914] ## Brief change log ``` --

[GitHub] [flink] lindong28 commented on a diff in pull request #20275: [FLINK-26029][Runtime/Checkpointing] Generalize the checkpoint protocol of OperatorCoordinator

2022-07-18 Thread GitBox
lindong28 commented on code in PR #20275: URL: https://github.com/apache/flink/pull/20275#discussion_r923461372 ## flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/CloseableSubtaskGateway.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2022-07-18 Thread GitBox
maosuhan commented on PR #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-1187643038 protobuf can also work in sql client now ![image](https://user-images.githubusercontent.com/1617828/179546646-ca90b724-4f26-44a8-81b8-7a6e10dcf7ac.png) -- This is an automated

[GitHub] [flink] maosuhan commented on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2022-07-18 Thread GitBox
maosuhan commented on PR #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-1187639170 @libenchao Thanks for your detailed code review. It is really helpful. There are still some unresolved conversations left, could you take a look them again? Does the code look

[GitHub] [flink] maosuhan commented on a diff in pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2022-07-18 Thread GitBox
maosuhan commented on code in PR #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r923499714 ## flink-formats/flink-protobuf/pom.xml: ## @@ -0,0 +1,146 @@ + + +http://maven.apache.org/POM/4.0.0; +

[jira] [Comment Edited] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-07-18 Thread Sebastian Mattheis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568049#comment-17568049 ] Sebastian Mattheis edited comment on FLINK-24932 at 7/18/22 3:01 PM: -

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-07-18 Thread Sebastian Mattheis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568049#comment-17568049 ] Sebastian Mattheis commented on FLINK-24932: [~yunta] Building FRocksDB on M1 silicon is not

[GitHub] [flink] zstraw commented on pull request #17956: [FLINK-18779][table sql/planner]Support the SupportsFilterPushDown for LookupTableSource

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

[GitHub] [flink] 1996fanrui commented on pull request #20233: [FLINK-28474][checkpoint] Simplify the ChannelStateWriterImpl due to concurrent unaligned checkpoint isn't supported

2022-07-18 Thread GitBox
1996fanrui commented on PR #20233: URL: https://github.com/apache/flink/pull/20233#issuecomment-1187589584 @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

[GitHub] [flink] WencongLiu commented on pull request #20236: [FLINK-27769][sql-gateway]Introduce the REST endpoint framework

2022-07-18 Thread GitBox
WencongLiu commented on PR #20236: URL: https://github.com/apache/flink/pull/20236#issuecomment-1187588579 @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

[jira] [Commented] (FLINK-12655) SlotCountExceedingParallelismTest failed on Travis

2022-07-18 Thread Wencong Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568037#comment-17568037 ] Wencong Liu commented on FLINK-12655: -

[GitHub] [flink] 1996fanrui commented on pull request #20233: [FLINK-28474][checkpoint] Simplify the ChannelStateWriterImpl due to concurrent unaligned checkpoint isn't supported

2022-07-18 Thread GitBox
1996fanrui commented on PR #20233: URL: https://github.com/apache/flink/pull/20233#issuecomment-1187561410 @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

[jira] [Commented] (FLINK-28518) Exception: AssertionError: Cannot add expression of different type to set in sub-query with ROW type

2022-07-18 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568023#comment-17568023 ] Martijn Visser commented on FLINK-28518: [~KoylubaevNT] A Calcite upgrade is not an easy task;

[jira] [Commented] (FLINK-28518) Exception: AssertionError: Cannot add expression of different type to set in sub-query with ROW type

2022-07-18 Thread Koylubaev Nikita (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568014#comment-17568014 ] Koylubaev Nikita commented on FLINK-28518: -- [~martijnvisser] I found that error was in calcite.

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-07-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568010#comment-17568010 ] Yun Tang commented on FLINK-24932: -- BTW, I noticed that the CI on circle seems disabled on

[jira] [Commented] (FLINK-24932) Frocksdb cannot run on Apple M1

2022-07-18 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568009#comment-17568009 ] Yun Tang commented on FLINK-24932: -- [~smattheis] In case of that you are not so familiar with FRocksDB,

[GitHub] [flink] 1996fanrui commented on a diff in pull request #20233: [FLINK-28474][checkpoint] Simplify the ChannelStateWriterImpl due to concurrent unaligned checkpoint isn't supported

2022-07-18 Thread GitBox
1996fanrui commented on code in PR #20233: URL: https://github.com/apache/flink/pull/20233#discussion_r923351868 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java: ## @@ -60,89 +63,78 @@ public class ChannelStateWriterImpl

[GitHub] [flink] lincoln-lil commented on a diff in pull request #20243: [FLINK-28491][table-planner] Introduce APPROX_COUNT_DISTINCT aggregate function for batch sql

2022-07-18 Thread GitBox
lincoln-lil commented on code in PR #20243: URL: https://github.com/apache/flink/pull/20243#discussion_r923368739 ## tools/maven/suppressions.xml: ## @@ -45,6 +45,9 @@ under the License. + Review Comment: nit: the comment

  1   2   3   >