[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

[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

[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

[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] 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

[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] 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

[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:

[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] [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

[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,

[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:

[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 @@

[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 >

[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:

[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: -

[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-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

[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-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] 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] 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-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] 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

[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] [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: -

[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-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] 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] 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

[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

[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

[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 #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:

[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] 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

[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] [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] 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-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] 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:

[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-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

[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

[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-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 #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] 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] 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] flinkbot edited a comment on pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

flinkbot edited a comment on pull request #16962: URL: https://github.com/apache/flink/pull/16962#issuecomment-904541061 ## CI report: * 8e2252bcb560bb6168f69f51d004e5ac849b8729 Azure:

[jira] [Commented] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460488#comment-17460488 ] ZhuoYu Chen commented on FLINK-7129: Hi [~MartijnVisser] You will assign it to me, and I will have

[jira] [Comment Edited] (FLINK-7129) Support dynamically changing CEP patterns

[ https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460488#comment-17460488 ] ZhuoYu Chen edited comment on FLINK-7129 at 12/16/21, 8:28 AM: --- Hi

[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-995547926 > You can build the doc with `mvn clean package -Dgenerate-config-docs -pl flink-docs -am -nsu -DskipTests -Dcheckstyle.skip`. Thanks @KarmaGYZ . Got it. Any other

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * d2242677110bbd6b38963379d4f8624f13c7 Azure:

[jira] [Updated] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

[ https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-25332: Component/s: API / Python (was: Table SQL / API) > When using Pyflink Table API,

[jira] [Commented] (FLINK-25332) When using Pyflink Table API, 'where' clause seems to work incorrectly

[ https://issues.apache.org/jira/browse/FLINK-25332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460506#comment-17460506 ] Dian Fu commented on FLINK-25332: - Just posting the plan you shared: {code:java}

[GitHub] [flink] MartijnVisser commented on a change in pull request #18110: [FLINK-25310][Documentation] Fix the incorrect description for output network buffers in buffer debloat documenation

MartijnVisser commented on a change in pull request #18110: URL: https://github.com/apache/flink/pull/18110#discussion_r770299807 ## File path: docs/content/docs/deployment/memory/network_mem_tuning.md ## @@ -114,7 +114,7 @@ Unlike the input buffer pool, the output buffer pool

[GitHub] [flink] godfreyhe commented on a change in pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

godfreyhe commented on a change in pull request #17845: URL: https://github.com/apache/flink/pull/17845#discussion_r770345473 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java ## @@ -4711,6 +4711,11 @@ private

[GitHub] [flink] PatrickRen commented on a change in pull request #18128: [FLINK-25340][testutils] Remove JM temp files before stopping container to avoid file permission issues

PatrickRen commented on a change in pull request #18128: URL: https://github.com/apache/flink/pull/18128#discussion_r770349706 ## 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] KarmaGYZ commented on a change in pull request #18087: [FLINK-25268] Support task manager node-label in Yarn deployment

KarmaGYZ commented on a change in pull request #18087: URL: https://github.com/apache/flink/pull/18087#discussion_r770313868 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java ## @@ -296,6 +296,12 @@

[GitHub] [flink] flinkbot commented on pull request #18129: [FLINK-25326][connectors/kafka] Fix application of log levels in KafkaUtils.createKafkacontainer (backport)

flinkbot commented on pull request #18129: URL: https://github.com/apache/flink/pull/18129#issuecomment-995581838 ## CI report: * 1f246f860b547d7d440480cac4d89da5cbc216a9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25342) DataStream.sinkTo will not add sink to the sinks field in the StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-25342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hang Ruan updated FLINK-25342: -- Attachment: streamGraph.png > DataStream.sinkTo will not add sink to the sinks field in the

[jira] [Commented] (FLINK-25342) DataStream.sinkTo will not add sink to the sinks field in the StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-25342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17460531#comment-17460531 ] Fabian Paul commented on FLINK-25342: - I think the problem lies in the design of the two sinks.

[GitHub] [flink] wanglijie95 opened a new pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

wanglijie95 opened a new pull request #18130: URL: https://github.com/apache/flink/pull/18130 ## What is the purpose of the change Let shuffle service supports consuming subpartition range. In adaptive batch scheduler, the shuffle service needs to support a SingleInputGate to consume a

[GitHub] [flink] flinkbot edited a comment on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot edited a comment on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912328 ## CI report: * 73c8c9d510e79d12800ba1d4ca4962b14d90b0fc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

flinkbot edited a comment on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985991840 ## CI report: * 5c0958638bde9496a73510898e24d6d344d5fc5a Azure:

[jira] [Created] (FLINK-25343) HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure

Yun Gao created FLINK-25343: --- Summary: HBaseConnectorITCase.testTableSourceSinkWithDDL fail on azure Key: FLINK-25343 URL: https://issues.apache.org/jira/browse/FLINK-25343 Project: Flink Issue

[jira] [Updated] (FLINK-17314) 【Flink Kafka Connector】The Config（connector.topic）support list topic

[ https://issues.apache.org/jira/browse/FLINK-17314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17314: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-20732) Pulsar Sink

[ https://issues.apache.org/jira/browse/FLINK-20732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20732: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-18193) Replace all documentation self links with {% link %} tag

[ https://issues.apache.org/jira/browse/FLINK-18193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18193: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-22614) Provide build artifacts for YARN e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22614: --- Labels: auto-deprioritized-major stale-minor starter (was: auto-deprioritized-major

[jira] [Updated] (FLINK-11733) Provide HadoopMapFunction for org.apache.hadoop.mapreduce.Mapper

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

[jira] [Updated] (FLINK-18278) Translate new documenation homepage

[ https://issues.apache.org/jira/browse/FLINK-18278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18278: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[jira] [Updated] (FLINK-18013) Refactor Hadoop Utility classes/functions into a common Maven module

[ https://issues.apache.org/jira/browse/FLINK-18013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18013: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned

[jira] [Updated] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-11793: --- Labels: auto-deprioritized-major auto-unassigned stale-minor (was:

[jira] [Updated] (FLINK-18027) ROW value constructor cannot deal with complex expressions

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

[jira] [Updated] (FLINK-11698) Add readMapRedTextFile API for HadoopInputs

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

[jira] [Updated] (FLINK-11697) Add readMapReduceTextFile API for HadoopInputs

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

[jira] [Updated] (FLINK-17486) ClassCastException when checkpointing AVRO SpecificRecord with decimal fields

[ https://issues.apache.org/jira/browse/FLINK-17486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17486: --- Labels: AVRO auto-deprioritized-critical auto-deprioritized-major

[jira] [Updated] (FLINK-17525) Support to parse millisecond and nanoseconds for TIME type in CSV and JSON format

[ https://issues.apache.org/jira/browse/FLINK-17525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17525: --- Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned (was:

[GitHub] [flink] flinkbot edited a comment on pull request #18000: [hotfix][connectors/kinesis] Refactored utilities class out into a separate base connector

flinkbot edited a comment on pull request #18000: URL: https://github.com/apache/flink/pull/18000#issuecomment-984912328 ## CI report: * 73c8c9d510e79d12800ba1d4ca4962b14d90b0fc Azure:

[GitHub] [flink] twalthr commented on a change in pull request #18088: [FLINK-25174][table] Introduce managed table interfaces and callback

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

[jira] [Updated] (FLINK-22615) can't use test harness to test Scala UDF because of two versions of ProcessWindowFunction

[ https://issues.apache.org/jira/browse/FLINK-22615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22615: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-22270) Python test pipeline no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-22270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22270: --- Labels: auto-deprioritized-major stale-minor test-stability (was: auto-deprioritized-major

[GitHub] [flink] flinkbot edited a comment on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

flinkbot edited a comment on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985991840 ## CI report: * 5c0958638bde9496a73510898e24d6d344d5fc5a Azure:

[GitHub] [flink] akalash commented on a change in pull request #18092: [FLINK-25191] Skip savepoints for recovery

akalash commented on a change in pull request #18092: URL: https://github.com/apache/flink/pull/18092#discussion_r770415935 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1200,48 +1200,63 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18108: [FLINK-25282][table-planner][table-runtime] Move every runtime dependency from planner to runtime

flinkbot edited a comment on pull request #18108: URL: https://github.com/apache/flink/pull/18108#issuecomment-993777362 ## CI report: * d2350e31a85898f2149ff3a3198376cb7db8b6c6 Azure:

[GitHub] [flink] dawidwys commented on a change in pull request #18092: [FLINK-25191] Skip savepoints for recovery

dawidwys commented on a change in pull request #18092: URL: https://github.com/apache/flink/pull/18092#discussion_r770436638 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1200,92 +1200,69 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #18128: [FLINK-25340][testutils] Remove JM temp files before stopping container to avoid file permission issues

flinkbot edited a comment on pull request #18128: URL: https://github.com/apache/flink/pull/18128#issuecomment-995537647 ## CI report: * 9a210399961f395c5367213ca829bd159910d038 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18013: [FLINK-24227][connectors/kinesis] Kinesis DataStreams connector using Kinesis async client

flinkbot edited a comment on pull request #18013: URL: https://github.com/apache/flink/pull/18013#issuecomment-985991840 ## CI report: * 0ee67a45f1b05fa76a3208e5d662e22646889df4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18119: [FLINK-24947] Support hostNetwork for native K8s integration on session mode

flinkbot edited a comment on pull request #18119: URL: https://github.com/apache/flink/pull/18119#issuecomment-994734000 ## CI report: * 5b002cac167fdb0bc36bc284b346855330c9e43f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

flinkbot edited a comment on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-995629902 ## CI report: * 502f1eb9b879f0237e7dd0716edd74fa96a9017d Azure:

[GitHub] [flink] zentol commented on pull request #18125: [FLINK-25210][pulsar][e2e][tests] add resource file to test jar

zentol commented on pull request #18125: URL: https://github.com/apache/flink/pull/18125#issuecomment-995694338 The test is still failing. -- 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

  1   2   3   4   5   6   7   >