[GitHub] [flink] AHeise commented on a change in pull request #18105: [FLINK-17510][e2e] Convert StreamingKafkaITCase to SmokeKafkaITCase covering application packaging

AHeise commented on a change in pull request #18105: URL: https://github.com/apache/flink/pull/18105#discussion_r771176056 ## File path: flink-end-to-end-tests/flink-end-to-end-tests-common/src/main/java/org/apache/flink/tests/util/flink/container/FlinkContainers.java ## @@

[GitHub] [flink] alpreu commented on pull request #17819: [FLINK-15816][k8s] Limit kubernetes.cluster-id to a maximum of 40 characters

alpreu commented on pull request #17819: URL: https://github.com/apache/flink/pull/17819#issuecomment-996510750 Sure, I can do this, just have to deprioritize it for some SDK stuff for now -- This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] wanglijie95 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

wanglijie95 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r771175287 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[jira] [Commented] (FLINK-25223) ElasticsearchWriterITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461253#comment-17461253 ] Arvid Heise commented on FLINK-25223: - [~alexanderpreuss] could you please double-check if we need a

[jira] [Resolved] (FLINK-25223) ElasticsearchWriterITCase fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-25223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-25223. - Resolution: Fixed Reactivated tests and provided memory limit in master as

[GitHub] [flink] AHeise merged pull request #18064: [FLINK-25223][connectors/elasticsearch] Limit Elasticsearch testcontainer memory allocation

AHeise merged pull request #18064: URL: https://github.com/apache/flink/pull/18064 -- 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] wanglijie95 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

wanglijie95 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r771171607 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[GitHub] [flink] wanglijie95 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

wanglijie95 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r771171790 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[GitHub] [flink] wanglijie95 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

wanglijie95 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r771171607 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[jira] [Commented] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461250#comment-17461250 ] Arvid Heise commented on FLINK-25167: - I assigned. [~MartijnVisser] could you please keep an eye on

[jira] [Assigned] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-25167: --- Assignee: Lsw_aka_laplace > Support user-defined `StreamOperatorFactory` in

[jira] [Commented] (FLINK-25319) Quickstarts Scala nightly end-to-end test failed due to akka rpc server failed to start

[ https://issues.apache.org/jira/browse/FLINK-25319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461249#comment-17461249 ] Yangze Guo commented on FLINK-25319: another instance

[GitHub] [flink] wanglijie95 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

wanglijie95 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r771163449 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartition.java ## @@ -77,6 +85,69 @@ public

[jira] [Updated] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25185: Affects Version/s: 1.15.0 > StreamFaultToleranceTestBase hangs on AZP >

[jira] [Commented] (FLINK-25185) StreamFaultToleranceTestBase hangs on AZP

[ https://issues.apache.org/jira/browse/FLINK-25185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461237#comment-17461237 ] Yun Gao commented on FLINK-25185: -

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 075b1874f67ad8a148e73e8a00e0fcd122d5a7f7 Azure:

[jira] [Commented] (FLINK-25359) flink1.13.2 心跳超时

[ https://issues.apache.org/jira/browse/FLINK-25359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461234#comment-17461234 ] Caizhi Weng commented on FLINK-25359: - Hi! There are various reasons causing heartbeat timeout,

[jira] [Closed] (FLINK-25359) flink1.13.2 心跳超时

[ https://issues.apache.org/jira/browse/FLINK-25359?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng closed FLINK-25359. --- Resolution: Not A Problem > flink1.13.2 心跳超时 > > > Key:

[jira] [Created] (FLINK-25359) flink1.13.2 心跳超时

mindezhi created FLINK-25359: Summary: flink1.13.2 心跳超时 Key: FLINK-25359 URL: https://issues.apache.org/jira/browse/FLINK-25359 Project: Flink Issue Type: Bug Reporter: mindezhi

[jira] [Commented] (FLINK-25338) Improvement of connection from TM to JM in session cluster

[ https://issues.apache.org/jira/browse/FLINK-25338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461226#comment-17461226 ] Xintong Song commented on FLINK-25338: -- In general, I like the idea that the JM process maintains

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 3bfb0e859ac9f775571ecb6ab8db2c27a1b0fcce Azure:

[GitHub] [flink] RocMarshal commented on pull request #18114: [FLINK-25173][table][hive] Introduce CatalogLock and implement HiveCatalogLock

RocMarshal commented on pull request #18114: URL: https://github.com/apache/flink/pull/18114#issuecomment-996475009 @JingsongLi Thanks for the efforts. Shall we add a description section into the relevant documentation page based on `HiveConfOptions.java`? -- This is an automated

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * b4e978359c87b33f8c5de84f6e0987f712335b19 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * ed1e59cced3590c5cbb27e0214b3746d148c8aa2 Azure:

[jira] [Comment Edited] (FLINK-25328) Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461218#comment-17461218 ] Xintong Song edited comment on FLINK-25328 at 12/17/21, 6:24 AM: -

[GitHub] [flink] zuston commented on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

zuston commented on pull request #18087: URL: https://github.com/apache/flink/pull/18087#issuecomment-996469650 All done @KarmaGYZ Could you help review it again? Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] zuston commented on a change in pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

zuston commented on a change in pull request #18087: URL: https://github.com/apache/flink/pull/18087#discussion_r771131336 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManagerDriver.java ## @@ -550,7 +559,33 @@ private FinalApplicationStatus

[jira] [Commented] (FLINK-25328) Improvement of share memory manager between jobs if they use the same slot in TaskManager for flink olap queries

[ https://issues.apache.org/jira/browse/FLINK-25328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461218#comment-17461218 ] Xintong Song commented on FLINK-25328: -- [~zjureel], The reason we have operators, rocksdb and

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

flinkbot edited a comment on pull request #18087: URL: https://github.com/apache/flink/pull/18087#issuecomment-992135476 ## CI report: * 89360d57d3e879d255d53229f20c96279ad2ecb8 Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

zhipeng93 commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r771129221 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[jira] [Closed] (FLINK-24845) Add allreduce utility function in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-24845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24845. --- Assignee: Zhipeng Zhang Resolution: Fixed > Add allreduce utility function in FlinkML >

[jira] [Updated] (FLINK-24845) Add allreduce utility function in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-24845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24845: Fix Version/s: ml-0.1.0 > Add allreduce utility function in FlinkML >

[GitHub] [flink] flinkbot edited a comment on pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

flinkbot edited a comment on pull request #18087: URL: https://github.com/apache/flink/pull/18087#issuecomment-992135476 ## CI report: * 89360d57d3e879d255d53229f20c96279ad2ecb8 Azure:

[jira] [Commented] (FLINK-24845) Add allreduce utility function in FlinkML

[ https://issues.apache.org/jira/browse/FLINK-24845?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461216#comment-17461216 ] Yun Gao commented on FLINK-24845: - Fix on master via eeccb82129dd666070a9c1c220f2f8de3b0e5aec > Add

[GitHub] [flink-ml] gaoyunhaii closed pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

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

[GitHub] [flink-ml] gaoyunhaii commented on pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

gaoyunhaii commented on pull request #30: URL: https://github.com/apache/flink-ml/pull/30#issuecomment-996464991 Will merge~ -- 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-ml] gaoyunhaii commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

gaoyunhaii commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r771127080 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink-ml] gaoyunhaii commented on a change in pull request #30: [FLINK-24845] Add allreduce utility function in FlinkML

gaoyunhaii commented on a change in pull request #30: URL: https://github.com/apache/flink-ml/pull/30#discussion_r771125346 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/common/datastream/AllReduceUtils.java ## @@ -0,0 +1,286 @@ +/* + * Licensed to the Apache

[GitHub] [flink] flinkbot edited a comment on pull request #18132: [FLINK-25223][connectors/elasticsearch] Disable Elasticsearch 7 Testcontainer tests due to frequent CI failures

flinkbot edited a comment on pull request #18132: URL: https://github.com/apache/flink/pull/18132#issuecomment-995779473 ## CI report: * 4211aa4e7ddc72673fc57693a0db63a55d833d5c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18132: [FLINK-25223][connectors/elasticsearch] Disable Elasticsearch 7 Testcontainer tests due to frequent CI failures

flinkbot edited a comment on pull request #18132: URL: https://github.com/apache/flink/pull/18132#issuecomment-995779473 ## CI report: * 4211aa4e7ddc72673fc57693a0db63a55d833d5c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18131: [FLINK-25223][connectors/elasticsearch] Disable Elasticsearch 7 Testcontainer tests due to frequent CI failures

flinkbot edited a comment on pull request #18131: URL: https://github.com/apache/flink/pull/18131#issuecomment-995779333 ## CI report: * 3db9717e8cc373c68ec93b0b78aae3191469984d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18131: [FLINK-25223][connectors/elasticsearch] Disable Elasticsearch 7 Testcontainer tests due to frequent CI failures

flinkbot edited a comment on pull request #18131: URL: https://github.com/apache/flink/pull/18131#issuecomment-995779333 ## CI report: * 3db9717e8cc373c68ec93b0b78aae3191469984d Azure:

[jira] [Closed] (FLINK-24728) Batch SQL file sink forgets to close the output stream

[ https://issues.apache.org/jira/browse/FLINK-24728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24728. Resolution: Fixed master: 6af0b9965293cb732a540b9364b6aae76a9b356a

[GitHub] [flink] JingsongLi merged pull request #18074: [FLINK-24728][table-runtime-blink] Close output stream in batch SQL file sink

JingsongLi merged pull request #18074: URL: https://github.com/apache/flink/pull/18074 -- 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] JingsongLi merged pull request #18073: [FLINK-24728][tests] Add tests to ensure SQL file sink closes all created files

JingsongLi merged pull request #18073: URL: https://github.com/apache/flink/pull/18073 -- 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-25278) Azure failed due to unable to transfer jar from confluent maven repo

[ https://issues.apache.org/jira/browse/FLINK-25278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25278: Priority: Critical (was: Major) > Azure failed due to unable to transfer jar from confluent maven repo >

[jira] [Commented] (FLINK-25278) Azure failed due to unable to transfer jar from confluent maven repo

[ https://issues.apache.org/jira/browse/FLINK-25278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461199#comment-17461199 ] Yun Gao commented on FLINK-25278: -

[jira] [Updated] (FLINK-25358) New File Sink end-to-end test failed due to TM could not connect to RM

[ https://issues.apache.org/jira/browse/FLINK-25358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25358: Labels: test-stability (was: ) > New File Sink end-to-end test failed due to TM could not connect to RM

[jira] [Created] (FLINK-25358) New File Sink end-to-end test failed due to TM could not connect to RM

Yun Gao created FLINK-25358: --- Summary: New File Sink end-to-end test failed due to TM could not connect to RM Key: FLINK-25358 URL: https://issues.apache.org/jira/browse/FLINK-25358 Project: Flink

[GitHub] [flink] wenlong88 commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

wenlong88 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-996448224 LGTM，cc @godfreyhe to do the final check -- 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] JingsongLi commented on a change in pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

JingsongLi commented on a change in pull request #18088: URL: https://github.com/apache/flink/pull/18088#discussion_r77853 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java ## @@ -620,10 +620,16 @@ public static

[jira] [Commented] (FLINK-25283) End-to-end application modules create oversized jars

[ https://issues.apache.org/jira/browse/FLINK-25283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461196#comment-17461196 ] Dian Fu commented on FLINK-25283: - [~chesnay]  [~MartijnVisser] Could you share more information about

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * ed1e59cced3590c5cbb27e0214b3746d148c8aa2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

flinkbot edited a comment on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-953241058 ## CI report: * ed1e59cced3590c5cbb27e0214b3746d148c8aa2 Azure:

[GitHub] [flink] mbalassi commented on pull request #17582: [FLINK-24674][kubernetes] Create corresponding resouces for task manager Pods

mbalassi commented on pull request #17582: URL: https://github.com/apache/flink/pull/17582#issuecomment-996443534 @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

[jira] [Commented] (FLINK-24119) KafkaITCase.testTimestamps fails due to "Topic xxx already exist"

[ https://issues.apache.org/jira/browse/FLINK-24119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461192#comment-17461192 ] Yun Gao commented on FLINK-24119: -

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[jira] [Comment Edited] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461169#comment-17461169 ] Xue Wang edited comment on FLINK-25021 at 12/17/21, 3:22 AM: - Hi

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] xiangqiao123 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

xiangqiao123 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r770484017 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[jira] [Closed] (FLINK-24955) Add One-hot Encoder to Flink ML

[ https://issues.apache.org/jira/browse/FLINK-24955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-24955. --- Assignee: Yunfeng Zhou Resolution: Fixed > Add One-hot Encoder to Flink ML >

[jira] [Commented] (FLINK-24955) Add One-hot Encoder to Flink ML

[ https://issues.apache.org/jira/browse/FLINK-24955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461174#comment-17461174 ] Yun Gao commented on FLINK-24955: - Merge on master via 79d0c247e0cc900c9a16e045a99000423003780b > Add

[jira] [Updated] (FLINK-24955) Add One-hot Encoder to Flink ML

[ https://issues.apache.org/jira/browse/FLINK-24955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-24955: Fix Version/s: ml-0.1.0 > Add One-hot Encoder to Flink ML > --- > >

[GitHub] [flink] xiangqiao123 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

xiangqiao123 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r770483911 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink-ml] gaoyunhaii closed pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

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

[GitHub] [flink-ml] gaoyunhaii commented on pull request #37: [FLINK-24955] Add Estimator and Transformer for One Hot Encoder

gaoyunhaii commented on pull request #37: URL: https://github.com/apache/flink-ml/pull/37#issuecomment-996403629 merging... -- 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] xiangqiao123 commented on a change in pull request #18050: [FLINK-25034][runtime] Support flexible number of subpartitions in IntermediateResultPartition

xiangqiao123 commented on a change in pull request #18050: URL: https://github.com/apache/flink/pull/18050#discussion_r770484017 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartitionTest.java ## @@ -140,6 +150,127 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[jira] [Created] (FLINK-25357) SQL planner incorrectly changes a streaming join with FLOOR(rowtime) into interval join

Caizhi Weng created FLINK-25357: --- Summary: SQL planner incorrectly changes a streaming join with FLOOR(rowtime) into interval join Key: FLINK-25357 URL: https://issues.apache.org/jira/browse/FLINK-25357

[jira] [Commented] (FLINK-25167) Support user-defined `StreamOperatorFactory` in `ConnectedStreams`#transform

[ https://issues.apache.org/jira/browse/FLINK-25167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461171#comment-17461171 ] Lsw_aka_laplace commented on FLINK-25167: - [~pnowojski] Sorry for late reply. I guess we have

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] jelly-1203 commented on pull request #18017: [FLINK-25171] Validation of duplicate fields in ddl sql

jelly-1203 commented on pull request #18017: URL: https://github.com/apache/flink/pull/18017#issuecomment-996393881 Hi, @wenlong88 Could you please review it and see what needs to be improved -- This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[jira] [Commented] (FLINK-25021) Source/Sink for Azure Data Explorer (ADX)

[ https://issues.apache.org/jira/browse/FLINK-25021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461169#comment-17461169 ] Xue Wang commented on FLINK-25021: -- Hi [~MartijnVisser], I checked the Kusto Java client in detail

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * d143a927289d7f6a88851d6db732169c4752ff6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * d143a927289d7f6a88851d6db732169c4752ff6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] yangjunhan commented on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

yangjunhan commented on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-996390103 > I think this will confuse the majority of developers as most do not work on the UI. Can we do something to restore the old behavior of not producing output unless the

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[jira] [Commented] (FLINK-25337) Check whether the target table is valid when SqlToOperationConverter.convertSqlInsert

[ https://issues.apache.org/jira/browse/FLINK-25337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461167#comment-17461167 ] vim-wang commented on FLINK-25337: -- 英文不好，我用中文描述一下哈。 是想实现对一段sql做语法检测的功能，比如下面这段sql： CREATE TABLE

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[jira] [Commented] (FLINK-25330) Flink SQL doesn't retract all versions of Hbase data

[ https://issues.apache.org/jira/browse/FLINK-25330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461166#comment-17461166 ] Bruce Wong commented on FLINK-25330: Hi, [~jingge]  As for HBase usage in the CDC scenario, I can

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

flinkbot edited a comment on pull request #18088: URL: https://github.com/apache/flink/pull/18088#issuecomment-992202380 ## CI report: * 08822a7f25a5dd09e3e235da0c6e8738bb9c6bde Azure:

[jira] [Created] (FLINK-25356) Add benchmarks for performance in OLAP scenarios

Xintong Song created FLINK-25356: Summary: Add benchmarks for performance in OLAP scenarios Key: FLINK-25356 URL: https://issues.apache.org/jira/browse/FLINK-25356 Project: Flink Issue Type:

[jira] [Commented] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461164#comment-17461164 ] Xintong Song commented on FLINK-25318: -- I think [~pnowojski] has raised a very important point.

[jira] [Commented] (FLINK-25318) Improvement of scheduler and execution for Flink OLAP

[ https://issues.apache.org/jira/browse/FLINK-25318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461158#comment-17461158 ] Shammon commented on FLINK-25318: - Hi [~pnowojski] Thanks for your comment. The suggestion about tests

[jira] [Comment Edited] (FLINK-25321) standalone deploy on k8s,pod always OOM killed,actual heap memory usage is normal, gc is normal

[ https://issues.apache.org/jira/browse/FLINK-25321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17461157#comment-17461157 ] Gao Fei edited comment on FLINK-25321 at 12/17/21, 1:52 AM: [~wangyang0918] 

  1   2   3   4   5   6   7   >