[GitHub] [flink] flinkbot edited a comment on pull request #18370: [hotfix][table-common] Introduce ObjectIdentifier.ofAnonymous to allow storing anonymous, but still uniquely identified, names in Obj

flinkbot edited a comment on pull request #18370: URL: https://github.com/apache/flink/pull/18370#issuecomment-1013215185 ## CI report: * c94bcef6bc47aef3ef09176b57c950cc064be725 Azure:

[GitHub] [flink] dawidwys commented on pull request #18368: [FLINK-18356][Azure] Enforce memory limits for docker containers

dawidwys commented on pull request #18368: URL: https://github.com/apache/flink/pull/18368#issuecomment-1014234098 @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-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477011#comment-17477011 ] Yun Gao commented on FLINK-25667: - Hi [~chesnay] ~ Could you have a look at this test~? It could be

[jira] [Updated] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

[ https://issues.apache.org/jira/browse/FLINK-25667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25667: Labels: test-stability (was: ) > AdaptiveSchedulerTest.testStatusMetrics is not stable >

[jira] [Created] (FLINK-25667) AdaptiveSchedulerTest.testStatusMetrics is not stable

Yun Gao created FLINK-25667: --- Summary: AdaptiveSchedulerTest.testStatusMetrics is not stable Key: FLINK-25667 URL: https://issues.apache.org/jira/browse/FLINK-25667 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #18370: [hotfix][table-common] Introduce ObjectIdentifier.ofAnonymous to allow storing anonymous, but still uniquely identified, names in Obj

flinkbot edited a comment on pull request #18370: URL: https://github.com/apache/flink/pull/18370#issuecomment-1013215185 ## CI report: * c94bcef6bc47aef3ef09176b57c950cc064be725 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18375: [FLINK-25476][table-planner] support CHAR type in function MAX and MIN

flinkbot edited a comment on pull request #18375: URL: https://github.com/apache/flink/pull/18375#issuecomment-1014163755 ## CI report: * 6436e2a7ddb9462a86143dae7c716612a86bd818 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

flinkbot edited a comment on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1013081147 ## CI report: * 39228325201d57243fd118cd66c30f24ed62125c 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: * 77ab6bda7acd263817ed9a661d743b013c8ab18d Azure:

[GitHub] [flink] fapaul commented on a change in pull request #18288: [FLINK-20188][Connectors][Docs][FileSystem] Added documentation for File Source

fapaul commented on a change in pull request #18288: URL: https://github.com/apache/flink/pull/18288#discussion_r785706129 ## File path: docs/content/docs/connectors/datastream/filesystem.md ## @@ -25,12 +27,243 @@ specific language governing permissions and limitations under

[GitHub] [flink] wsry commented on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry commented on pull request #18365: URL: https://github.com/apache/flink/pull/18365#issuecomment-1014231754 @1996fanrui Thanks for your update. The change LGTM. Let's wait for @pnowojski review. -- This is an automated message from the Apache Git Service. To respond to the message,

[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: * 77ab6bda7acd263817ed9a661d743b013c8ab18d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18372: [FLINK-25659] LogicalRelDataTypeConverterTest is flaky on Azure

flinkbot edited a comment on pull request #18372: URL: https://github.com/apache/flink/pull/18372#issuecomment-1013269241 ## CI report: * 6cdd8542289bd3e736a6e932dfcc8dd0f6d34091 Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #16962: [FLINK-15352][connector-jdbc] Develop MySQLCatalog to connect Flink with MySQL tables and ecosystem.

RocMarshal commented on a change in pull request #16962: URL: https://github.com/apache/flink/pull/16962#discussion_r785705471 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/mysql/MySQLTypeMapper.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #18372: [FLINK-25659] LogicalRelDataTypeConverterTest is flaky on Azure

flinkbot edited a comment on pull request #18372: URL: https://github.com/apache/flink/pull/18372#issuecomment-1013269241 ## CI report: * 6cdd8542289bd3e736a6e932dfcc8dd0f6d34091 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

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

[GitHub] [flink] twalthr commented on pull request #18372: [FLINK-25659] LogicalRelDataTypeConverterTest is flaky on Azure

twalthr commented on pull request #18372: URL: https://github.com/apache/flink/pull/18372#issuecomment-1014223058 @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] [Created] (FLINK-25666) Remove LegacyTypeInfoDataTypeConverter

RocMarshal created FLINK-25666: -- Summary: Remove LegacyTypeInfoDataTypeConverter Key: FLINK-25666 URL: https://issues.apache.org/jira/browse/FLINK-25666 Project: Flink Issue Type: Technical

[GitHub] [flink] flinkbot edited a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

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

[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=17477004#comment-17477004 ] Yun Gao commented on FLINK-24119: - Another instance for

[GitHub] [flink] mingwayXue removed a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

mingwayXue removed a comment on pull request #18362: URL: https://github.com/apache/flink/pull/18362#issuecomment-1014188373 @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

[GitHub] [flink] mingwayXue commented on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

mingwayXue commented on pull request #18362: URL: https://github.com/apache/flink/pull/18362#issuecomment-1014220665 > ## CI report: > * [5cf7c25](https://github.com/apache/flink/commit/5cf7c25f9ab637f5bebb7205e8078c146c5653d3) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

flinkbot edited a comment on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1012086932 ## CI report: * d2a210e11ac1e19a4df79090321bc98fba8d4e02 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * ce5293639c33d92109455f6d831678dba9858f83 Azure:

[jira] [Updated] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25665: Affects Version/s: 1.13.5 (was: 1.14.2) >

[jira] [Updated] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25665: Description: {code:java} 2022-01-16T01:11:12.5984060Z Jan 16 01:11:12 [ERROR] Tests run: 21, Failures:

[jira] [Updated] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25665: Description: {code:java} 2022-01-16T01:11:12.5984060Z Jan 16 01:11:12 [ERROR] Tests run: 21, Failures:

[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: * 77ab6bda7acd263817ed9a661d743b013c8ab18d Azure:

[jira] [Updated] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25665: Description: {code:java} 2022-01-16T01:11:12.5984060Z Jan 16 01:11:12 [ERROR] Tests run: 21, Failures:

[jira] [Created] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

Yun Gao created FLINK-25665: --- Summary: DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure Key: FLINK-25665 URL: https://issues.apache.org/jira/browse/FLINK-25665

[jira] [Updated] (FLINK-25665) DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor timeout on azure

[ https://issues.apache.org/jira/browse/FLINK-25665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25665: Component/s: Table SQL / Runtime > DistinctITCase.testCorrectnessOfDistinctOnCustomTypeWithTypeExtractor

[GitHub] [flink] flinkbot edited a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

flinkbot edited a comment on pull request #18362: URL: https://github.com/apache/flink/pull/18362#issuecomment-1012985250 ## CI report: * 5cf7c25f9ab637f5bebb7205e8078c146c5653d3 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: * 41eeab31ee52a29d71acf018f9d1ef5a7750bb85 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

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

[GitHub] [flink] flinkbot edited a comment on pull request #18360: [FLINK-25329][runtime] Support memory execution graph store in session cluster

flinkbot edited a comment on pull request #18360: URL: https://github.com/apache/flink/pull/18360#issuecomment-1012981724 ## CI report: * 36e5148ffb71691d7c9798b51fb52e88f1927748 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

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

[GitHub] [flink] mingwayXue commented on pull request #18362: [hotfix][Apache Kafka Connector][docs] Fixed kafka.md sink example error

mingwayXue commented on pull request #18362: URL: https://github.com/apache/flink/pull/18362#issuecomment-1014188373 @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] flinkbot edited a comment on pull request #18364: [FLINK-25654][network] Remove the redundant locks in SortMergeResultPartition

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

[GitHub] [flink] flinkbot edited a comment on pull request #18364: [FLINK-25654][network] Remove the redundant locks in SortMergeResultPartition

flinkbot edited a comment on pull request #18364: URL: https://github.com/apache/flink/pull/18364#issuecomment-1012985415 ## CI report: * 0ef0841f223efb53c1d8af0eefc64cb628ca81c0 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: * 12880feeedbbba9d3beb93225843218f4d6776f6 Azure:

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

wanglijie95 commented on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-1014182533 @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] TanYuxin-tyx commented on a change in pull request #18364: [FLINK-25654][network] Remove the redundant locks in SortMergeResultPartition

TanYuxin-tyx commented on a change in pull request #18364: URL: https://github.com/apache/flink/pull/18364#discussion_r785665050 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionSortedBuffer.java ## @@ -65,7 +63,6 @@

[jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[jira] [Commented] (FLINK-22194) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers fail due to commit timeout

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

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[jira] [Commented] (FLINK-25655) FlinkKafkaInternalProducerITCase.testInitTransactionId failed on azure

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

[jira] [Updated] (FLINK-25663) SqlParser seems not support using udf in the column of row when writing dml

[ https://issues.apache.org/jira/browse/FLINK-25663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiang Yang updated FLINK-25663: --- Summary: SqlParser seems not support using udf in the column of row when writing dml (was:

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18361: [FLINK-25631][table] Support enhanced `show tables` syntax

flinkbot edited a comment on pull request #18361: URL: https://github.com/apache/flink/pull/18361#issuecomment-1012985152 ## CI report: * be68a936d3efddd37a731cdbd5608741850ca1bf Azure:

[jira] [Commented] (FLINK-25475) When windowAgg and groupAgg are included at the same time, there is no assigner generated but MiniBatch optimization is still used.

[ https://issues.apache.org/jira/browse/FLINK-25475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476968#comment-17476968 ] xuyang commented on FLINK-25475: Hi ,[~ChangjiGuo] . Are you glad to provide the test case to be

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] zhuzhurk commented on a change in pull request #18102: [FLINK-25033][runtime] Let some scheduler components updatable

zhuzhurk commented on a change in pull request #18102: URL: https://github.com/apache/flink/pull/18102#discussion_r785638944 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/SchedulingResultPartition.java ## @@ -48,11 +49,11 @@

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

flinkbot edited a comment on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1012086932 ## CI report: * 12b8e43a7fdce98b7e6338f9cae3fba4b88daca9 Azure:

[GitHub] [flink] 1996fanrui commented on a change in pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui commented on a change in pull request #18365: URL: https://github.com/apache/flink/pull/18365#discussion_r785655328 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -112,6 +115,35 @@

[jira] [Updated] (FLINK-25664) Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true

[ https://issues.apache.org/jira/browse/FLINK-25664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Cai Liuyang updated FLINK-25664: Description: For now, there might be case like: # PipelinedSubPartition only have one

[jira] [Created] (FLINK-25664) Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true

Cai Liuyang created FLINK-25664: --- Summary: Notify will be not triggered for PipelinedSubpartition if more than one buffer is added during isBlocked == true Key: FLINK-25664 URL:

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

flinkbot edited a comment on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1012086932 ## CI report: * 12b8e43a7fdce98b7e6338f9cae3fba4b88daca9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18375: [FLINK-25476][table-planner] support CHAR type in function MAX and MIN

flinkbot edited a comment on pull request #18375: URL: https://github.com/apache/flink/pull/18375#issuecomment-1014163755 ## CI report: * 6436e2a7ddb9462a86143dae7c716612a86bd818 Azure:

[GitHub] [flink] flinkbot commented on pull request #18375: [FLINK-25476][table-planner] support CHAR type in function MAX and MIN

flinkbot commented on pull request #18375: URL: https://github.com/apache/flink/pull/18375#issuecomment-1014164264 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[GitHub] [flink] flinkbot commented on pull request #18375: [FLINK-25476][table-planner] support CHAR type in function MAX and MIN

flinkbot commented on pull request #18375: URL: https://github.com/apache/flink/pull/18375#issuecomment-1014163755 ## CI report: * 6436e2a7ddb9462a86143dae7c716612a86bd818 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-25662) Access KeyedStateStore in WindowAssigner

[ https://issues.apache.org/jira/browse/FLINK-25662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sun Sheng updated FLINK-25662: -- Description: Currently, when implement our own WindowAssigner, by the WindowAssignerContext, we can

[jira] [Updated] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

[ https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25476: --- Labels: pull-request-available (was: ) > CharType lost in the creation of MaxAggFunction &

[GitHub] [flink] xuyangzhong opened a new pull request #18375: [FLINK-25476][table-planner] support CHAR type in function MAX and MIN

xuyangzhong opened a new pull request #18375: URL: https://github.com/apache/flink/pull/18375 ## What is the purpose of the change Now function MAX and MIN does not support the type CHAR and will throw the exception like following: `Caused by:

[GitHub] [flink] wsry commented on a change in pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry commented on a change in pull request #18365: URL: https://github.com/apache/flink/pull/18365#discussion_r785651059 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -112,6 +115,35 @@ public

[jira] [Updated] (FLINK-25662) Access KeyedStateStore in WindowAssigner

[ https://issues.apache.org/jira/browse/FLINK-25662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sun Sheng updated FLINK-25662: -- Description: Currently, when implement our own WindowAssigner, by the WindowAssignerContext, we can

[jira] [Closed] (FLINK-25644) Introduce interfaces between file-table-store and flink connector sink

[ https://issues.apache.org/jira/browse/FLINK-25644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-25644. Resolution: Fixed master: e1ce970c6c1663efd30955004c38f2cb76342324 > Introduce interfaces

[GitHub] [flink-table-store] JingsongLi merged pull request #9: [FLINK-25644] Introduce interfaces between file-table-store and flink connector sink

JingsongLi merged pull request #9: URL: https://github.com/apache/flink-table-store/pull/9 -- 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 #17982: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connecto…

flinkbot edited a comment on pull request #17982: URL: https://github.com/apache/flink/pull/17982#issuecomment-983637773 ## CI report: * eb5ce3e693e637aad231e75cf3fbb1a40d315ccc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] flinkbot edited a comment on pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

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

[GitHub] [flink] 1996fanrui commented on a change in pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui commented on a change in pull request #18365: URL: https://github.com/apache/flink/pull/18365#discussion_r785640419 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -112,6 +115,35 @@

[GitHub] [flink] 1996fanrui commented on a change in pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

1996fanrui commented on a change in pull request #18365: URL: https://github.com/apache/flink/pull/18365#discussion_r785639386 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -112,6 +115,35 @@

[GitHub] [flink] zhuzhurk commented on a change in pull request #18130: [FLINK-25035][runtime] Shuffle service supports consuming subpartition range

zhuzhurk commented on a change in pull request #18130: URL: https://github.com/apache/flink/pull/18130#discussion_r785635577 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateTest.java ## @@ -645,13 +616,13 @@

[jira] [Updated] (FLINK-25663) SqlParser seems do not support using udf in the column of row when writing dml

[ https://issues.apache.org/jira/browse/FLINK-25663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiang Yang updated FLINK-25663: --- Component/s: Table SQL / Planner Affects Version/s: 1.13.5 Description: It

[jira] [Commented] (FLINK-25476) CharType lost in the creation of MaxAggFunction & MinAggFunction

[ https://issues.apache.org/jira/browse/FLINK-25476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476949#comment-17476949 ] xuyang commented on FLINK-25476: I'll try to fix this issue. > CharType lost in the creation of

[jira] [Created] (FLINK-25663) SqlParse

Xiang Yang created FLINK-25663: -- Summary: SqlParse Key: FLINK-25663 URL: https://issues.apache.org/jira/browse/FLINK-25663 Project: Flink Issue Type: Improvement Reporter: Xiang

[jira] [Commented] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945 ] Zhu Zhu commented on FLINK-25649: - Hi Gil, just to confirm the scenario, 1. are all the jobs unbounded

[jira] [Comment Edited] (FLINK-25649) Scheduling jobs fails with org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945 ] Zhu Zhu edited comment on FLINK-25649 at 1/17/22, 3:59 AM: --- Hi [~gdegrove],

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * 61c6ae82d925e66c3d13bd9894e718113543f5aa Azure:

[GitHub] [flink] wsry commented on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

wsry commented on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1014116122 @gaoyunhaii Thanks for your review and feedbacks. I have updated the PR. The change for ```taskmanager.network.blocking-shuffle.compression.enabled``` is in another PR:

[GitHub] [flink] flinkbot edited a comment on pull request #17938: [FLINK-25073][streaming] Introduce TreeMode description for vertices

flinkbot edited a comment on pull request #17938: URL: https://github.com/apache/flink/pull/17938#issuecomment-981363546 ## CI report: * 61c6ae82d925e66c3d13bd9894e718113543f5aa Azure:

[GitHub] [flink] wsry commented on a change in pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry commented on a change in pull request #18365: URL: https://github.com/apache/flink/pull/18365#discussion_r785620947 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -112,6 +115,35 @@ public

[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: * 3dbd53a6bc03cad9a218fdc080d367d85f15ec96 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: * 3dbd53a6bc03cad9a218fdc080d367d85f15ec96 Azure:

[GitHub] [flink] wsry commented on a change in pull request #18365: [FLINK-22643][network] Reuse tpc connections between taskmanagers

wsry commented on a change in pull request #18365: URL: https://github.com/apache/flink/pull/18365#discussion_r785618029 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactoryTest.java ## @@ -112,6 +115,35 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

flinkbot edited a comment on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1012086932 ## CI report: * 12b8e43a7fdce98b7e6338f9cae3fba4b88daca9 Azure:

[jira] [Commented] (FLINK-25660) Failed to build flink-runtime-web

[ https://issues.apache.org/jira/browse/FLINK-25660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476943#comment-17476943 ] Junhan Yang commented on FLINK-25660: - Please try remove

[GitHub] [flink] flinkbot edited a comment on pull request #18350: [FLINK-25636][network] Change some default config values of blocking shuffle for better usability

flinkbot edited a comment on pull request #18350: URL: https://github.com/apache/flink/pull/18350#issuecomment-1012086932 ## CI report: * 12b8e43a7fdce98b7e6338f9cae3fba4b88daca9 Azure:

[jira] [Updated] (FLINK-25662) Access KeyedStateStore in WindowAssigner

[ https://issues.apache.org/jira/browse/FLINK-25662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sun Sheng updated FLINK-25662: -- Description: Currently, when implement our own WindowAssigner, by the WindowAssignerContext, we can

[GitHub] [flink] flinkbot edited a comment on pull request #17982: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connecto…

flinkbot edited a comment on pull request #17982: URL: https://github.com/apache/flink/pull/17982#issuecomment-983637773 ## CI report: * 527f7f934533e53fec741c0ea89c476a74df46b5 Azure:

[GitHub] [flink] wenlong88 commented on pull request #16207: [FLINK-23031][table-runtime]Make processing time trigger dont repeat itself when no new element come in

wenlong88 commented on pull request #16207: URL: https://github.com/apache/flink/pull/16207#issuecomment-1014105715 LGTM，cc @JingsongLi to take a final review -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Created] (FLINK-25662) Access KeyedStateStore in WindowAssigner

Sun Sheng created FLINK-25662: - Summary: Access KeyedStateStore in WindowAssigner Key: FLINK-25662 URL: https://issues.apache.org/jira/browse/FLINK-25662 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #17982: [FLINK-24490][docs] The sample code is wrong in Apache Kafka Connecto…

flinkbot edited a comment on pull request #17982: URL: https://github.com/apache/flink/pull/17982#issuecomment-983637773 ## CI report: * 527f7f934533e53fec741c0ea89c476a74df46b5 Azure:

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

wanglijie95 commented on pull request #18130: URL: https://github.com/apache/flink/pull/18130#issuecomment-1014094008 @wsry This change involves some modifications to the network. Would you review it? -- This is an automated message from the Apache Git Service. To respond to the

  1   2   3   >