[GitHub] [flink] JingsongLi commented on a change in pull request #15236: [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

JingsongLi commented on a change in pull request #15236: URL: https://github.com/apache/flink/pull/15236#discussion_r597424374 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/WindowKeySerializer.java ## @@ -109,10

[GitHub] [flink] JingsongLi commented on a change in pull request #15236: [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

JingsongLi commented on a change in pull request #15236: URL: https://github.com/apache/flink/pull/15236#discussion_r597420746 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/WindowKeySerializer.java ## @@ -109,10

[GitHub] [flink] jiamo commented on a change in pull request #15157: [FLINK-21661][kinesis] Fix fetch interval for polling consumer

jiamo commented on a change in pull request #15157: URL: https://github.com/apache/flink/pull/15157#discussion_r597419965 ## File path:

[GitHub] [flink] JingsongLi commented on a change in pull request #15236: [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

JingsongLi commented on a change in pull request #15236: URL: https://github.com/apache/flink/pull/15236#discussion_r597419792 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/WindowKeySerializer.java ## @@ -109,10

[GitHub] [flink] wenlong88 commented on a change in pull request #15272: [FLINK-21816][table-planner-blink] Suport json ser/de for StreamExecMatch

wenlong88 commented on a change in pull request #15272: URL: https://github.com/apache/flink/pull/15272#discussion_r597419515 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/RexNodeJsonDeserializer.java ##

[jira] [Updated] (FLINK-21865) Add a Docker Compose greeter example to StateFun playgrounds

[ https://issues.apache.org/jira/browse/FLINK-21865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21865: --- Labels: pull-request-available (was: ) > Add a Docker Compose greeter example to StateFun

[GitHub] [flink-statefun-playground] tzulitai opened a new pull request #4: [FLINK-21865] Add a Docker Compose greeter example

tzulitai opened a new pull request #4: URL: https://github.com/apache/flink-statefun-playground/pull/4 This example is intended as a follow-up after completion of the Java SDK Showcase Tutorial. If users are already familiar with the Java SDK fundamentals and would like to get a

[jira] [Created] (FLINK-21865) Add a Docker Compose greeter example to StateFun playgrounds

Tzu-Li (Gordon) Tai created FLINK-21865: --- Summary: Add a Docker Compose greeter example to StateFun playgrounds Key: FLINK-21865 URL: https://issues.apache.org/jira/browse/FLINK-21865 Project:

[jira] [Commented] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304643#comment-17304643 ] tim yu commented on FLINK-21747: Hello [~jark] and [~chesnay] Through a review of metrics system code,

[GitHub] [flink] flinkbot edited a comment on pull request #15276: [FLINK-21837][flink-table-planner-blink] support StreamExecIntervalJoin serialization/deserialization

flinkbot edited a comment on pull request #15276: URL: https://github.com/apache/flink/pull/15276#issuecomment-802542650 ## CI report: * 0d5e735e81bfe061bbec689dda74e152553ee19d UNKNOWN * 865591e0c6465384ca646fd723760c77fa819f1f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15256: [FLINK-21851][table-runtime] Refactor BinaryRowDataKeySelector in testing

flinkbot edited a comment on pull request #15256: URL: https://github.com/apache/flink/pull/15256#issuecomment-801601761 ## CI report: * 31a064e494baca38cf8185fe7d84c2b3579cf28f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15276: [FLINK-21837][flink-table-planner-blink] support StreamExecIntervalJoin serialization/deserialization

flinkbot edited a comment on pull request #15276: URL: https://github.com/apache/flink/pull/15276#issuecomment-802542650 ## CI report: * 0d5e735e81bfe061bbec689dda74e152553ee19d UNKNOWN * 865591e0c6465384ca646fd723760c77fa819f1f UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15256: [FLINK-21851][table-runtime] Refactor BinaryRowDataKeySelector in testing

flinkbot edited a comment on pull request #15256: URL: https://github.com/apache/flink/pull/15256#issuecomment-801601761 ## CI report: * 31a064e494baca38cf8185fe7d84c2b3579cf28f Azure:

[GitHub] [flink] wuchong commented on a change in pull request #15236: [FLINK-21818][table] Refactor SlicingWindowAggOperatorBuilder to accept serializer instead of LogicalType

wuchong commented on a change in pull request #15236: URL: https://github.com/apache/flink/pull/15236#discussion_r597401185 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/WindowKeySerializer.java ## @@ -109,10 +106,9

[jira] [Created] (FLINK-21864) Support StreamExecTemporalJoin json serialization/deserialization

Terry Wang created FLINK-21864: -- Summary: Support StreamExecTemporalJoin json serialization/deserialization Key: FLINK-21864 URL: https://issues.apache.org/jira/browse/FLINK-21864 Project: Flink

[GitHub] [flink] godfreyhe commented on a change in pull request #15272: [FLINK-21816][table-planner-blink] Suport json ser/de for StreamExecMatch

godfreyhe commented on a change in pull request #15272: URL: https://github.com/apache/flink/pull/15272#discussion_r597400191 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/jsonplan/MatchRecognizeJsonPlanITCase.java

[GitHub] [flink] flinkbot commented on pull request #15276: [FLINK-21837][flink-table-planner-blink] support StreamExecIntervalJoin serialization/deserialization

flinkbot commented on pull request #15276: URL: https://github.com/apache/flink/pull/15276#issuecomment-802542650 ## CI report: * 0d5e735e81bfe061bbec689dda74e152553ee19d UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-21701) Support "RESET key" statement in the SQL Client

[ https://issues.apache.org/jira/browse/FLINK-21701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304628#comment-17304628 ] Shengkai Fang commented on FLINK-21701: --- [~xiangtao] Please make a try. >From my side, my

[GitHub] [flink] flinkbot commented on pull request #15276: [FLINK-21837][flink-table-planner-blink] support StreamExecIntervalJoin serialization/deserialization

flinkbot commented on pull request #15276: URL: https://github.com/apache/flink/pull/15276#issuecomment-802536047 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

[jira] [Updated] (FLINK-21837) Support StreamExecIntervalJoin json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21837: --- Labels: pull-request-available (was: ) > Support StreamExecIntervalJoin json ser/de >

[GitHub] [flink] zjuwangg opened a new pull request #15276: [FLINK-21837][flink-table-planner-blink] support StreamExecIntervalJoin serialization/deserialization

zjuwangg opened a new pull request #15276: URL: https://github.com/apache/flink/pull/15276 ## What is the purpose of the change *support StreamExecIntervalJoin serialization/deserialization* ## Brief change log - 0d5e735 *support StreamExecIntervalJoin

[GitHub] [flink] flinkbot edited a comment on pull request #15271: [FLINK-21813][table-planner-blink] Support json ser/de for StreamExecOverAggregate

flinkbot edited a comment on pull request #15271: URL: https://github.com/apache/flink/pull/15271#issuecomment-802067101 ## CI report: * 9800b92650659d48d1abfe6974b4fe1b9cb5257f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15272: [FLINK-21816][table-planner-blink] Suport json ser/de for StreamExecMatch

flinkbot edited a comment on pull request #15272: URL: https://github.com/apache/flink/pull/15272#issuecomment-802067367 ## CI report: * e96eaf020bcec88f7e5364264f15ac4bf6ed34b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

flinkbot edited a comment on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234 ## CI report: * 4dd5e4e8e3f0a1a89d1e05a1547217939c9ff703 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15270: [FLINK-21843][table-planner-blink] Support json ser/de for StreamExecGroupWindowAggregate

flinkbot edited a comment on pull request #15270: URL: https://github.com/apache/flink/pull/15270#issuecomment-802066772 ## CI report: * bff3961bf9c86186d08014044f28843a4dd72397 Azure:

[GitHub] [flink] godfreyhe commented on a change in pull request #15270: [FLINK-21843][table-planner-blink] Support json ser/de for StreamExecGroupWindowAggregate

godfreyhe commented on a change in pull request #15270: URL: https://github.com/apache/flink/pull/15270#discussion_r597386827 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecGroupWindowAggregate.java

[jira] [Closed] (FLINK-21852) Introduce SupportsAnyNull to BinaryRowData

[ https://issues.apache.org/jira/browse/FLINK-21852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-21852. Resolution: Fixed master (release-3.0): d84bf8064c2d0b66d1e2cd7e668376c171316530 > Introduce

[GitHub] [flink] JingsongLi merged pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

JingsongLi merged pull request #15257: URL: https://github.com/apache/flink/pull/15257 -- 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. For queries about this service,

[jira] [Updated] (FLINK-21747) Encounter an exception that contains "max key length exceeded ..." when reporting metrics to influxdb

[ https://issues.apache.org/jira/browse/FLINK-21747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tim yu updated FLINK-21747: --- Description: I run a streaming job with insert statement whose size is too large, it reports metrics to

[jira] [Closed] (FLINK-21861) Support StreamExecIncrementalGroupAggregate json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21861. -- Resolution: Fixed Fixed in 1.13.0: 8f08001bb2ebf53a332d07257dc6d42c3b6205aa > Support

[GitHub] [flink] godfreyhe closed pull request #15269: [FLINK-21861][table-planner-blink] Support StreamExecIncrementalGroupAggregate json serialization/deserialization

godfreyhe closed pull request #15269: URL: https://github.com/apache/flink/pull/15269 -- 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. For queries about this service,

[jira] [Updated] (FLINK-21837) Support StreamExecIntervalJoin json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-21837: --- Description: Support StreamExecIntervalJoin json ser/des (was: Support

[jira] [Updated] (FLINK-21837) Support StreamExecIntervalJoin json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Terry Wang updated FLINK-21837: --- Summary: Support StreamExecIntervalJoin json ser/de (was: Support

[GitHub] [flink] flinkbot edited a comment on pull request #15275: [hotfix][docs]add 'IF NOT EXISTS' to create table statement

flinkbot edited a comment on pull request #15275: URL: https://github.com/apache/flink/pull/15275#issuecomment-802508892 ## CI report: * 4d815720a65c9884045069e85b196be6dc112a11 Azure:

[GitHub] [flink] flinkbot commented on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

flinkbot commented on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234 ## CI report: * 4dd5e4e8e3f0a1a89d1e05a1547217939c9ff703 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] godfreyhe commented on pull request #15269: [FLINK-21861][table-planner-blink] Support StreamExecIncrementalGroupAggregate json serialization/deserialization

godfreyhe commented on pull request #15269: URL: https://github.com/apache/flink/pull/15269#issuecomment-802519191 Thanks for the review @wenlong88 , I resolve the conflict in my local and merge this pr -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

flinkbot edited a comment on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802508808 ## CI report: * 99f0b12ad7cd87ca9dfd5d9d3e97030eb41135f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15272: [FLINK-21816][table-planner-blink] Suport json ser/de for StreamExecMatch

flinkbot edited a comment on pull request #15272: URL: https://github.com/apache/flink/pull/15272#issuecomment-802067367 ## CI report: * e96eaf020bcec88f7e5364264f15ac4bf6ed34b4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15271: [FLINK-21813][table-planner-blink] Support json ser/de for StreamExecOverAggregate

flinkbot edited a comment on pull request #15271: URL: https://github.com/apache/flink/pull/15271#issuecomment-802067101 ## CI report: * 9800b92650659d48d1abfe6974b4fe1b9cb5257f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15270: [FLINK-21843][table-planner-blink] Support json ser/de for StreamExecGroupWindowAggregate

flinkbot edited a comment on pull request #15270: URL: https://github.com/apache/flink/pull/15270#issuecomment-802066772 ## CI report: * bff3961bf9c86186d08014044f28843a4dd72397 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

flinkbot edited a comment on pull request #15257: URL: https://github.com/apache/flink/pull/15257#issuecomment-801601825 ## CI report: * c75184bb0b59c6bd548ba481d96525991a2bac07 UNKNOWN * e98801c410ec95737e91892661e393752f5e4468 Azure:

[jira] [Closed] (FLINK-21860) Support StreamExecExpand json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21860?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21860. -- Resolution: Fixed Fixed in 1.13.0: f026dd6ec81eee2cc64dd9d0ff0a2faf964b6a10 > Support

[GitHub] [flink] godfreyhe closed pull request #15268: [FLINK-21860][table-planner-blink] Support StreamExecExpand json serialization/deserialization

godfreyhe closed pull request #15268: URL: https://github.com/apache/flink/pull/15268 -- 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. For queries about this service,

[GitHub] [flink] godfreyhe commented on pull request #15268: [FLINK-21860][table-planner-blink] Support StreamExecExpand json serialization/deserialization

godfreyhe commented on pull request #15268: URL: https://github.com/apache/flink/pull/15268#issuecomment-802516630 Thanks for the review @wenlong88 , I will resolve the conflict in my local and merge the pr -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Closed] (FLINK-21791) Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21791?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21791. -- Resolution: Fixed Fixed in 1.13.0: fdcadc4684e82d3cf69a78d87ec5033ac534e728 > Support

[GitHub] [flink] godfreyhe merged pull request #15264: [FLINK-21791][table-planner-blink] Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserialization

godfreyhe merged pull request #15264: URL: https://github.com/apache/flink/pull/15264 -- 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. For queries about this service,

[GitHub] [flink] kezhuw commented on a change in pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

kezhuw commented on a change in pull request #15273: URL: https://github.com/apache/flink/pull/15273#discussion_r597375675 ## File path: flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java ## @@ -217,10 +222,14 @@ public int size() { /** *

[GitHub] [flink] godfreyhe commented on pull request #15264: [FLINK-21791][table-planner-blink] Support StreamExecLocalGroupAggregate and StreamExecGlobalGroupAggregate json serialization/deserializat

godfreyhe commented on pull request #15264: URL: https://github.com/apache/flink/pull/15264#issuecomment-802512285 My private azure is green, https://dev.azure.com/godfreyhe/godfreyhe-flink/_build/results?buildId=354=results -- This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-21841) Can not find kafka-connect with sql-kafka-connector

[ https://issues.apache.org/jira/browse/FLINK-21841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieFang.He closed FLINK-21841. -- Resolution: Not A Problem > Can not find kafka-connect with sql-kafka-connector >

[GitHub] [flink] flinkbot commented on pull request #15275: [hotfix][docs]add 'IF NOT EXISTS' to create table statement

flinkbot commented on pull request #15275: URL: https://github.com/apache/flink/pull/15275#issuecomment-802508892 ## CI report: * 4d815720a65c9884045069e85b196be6dc112a11 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

flinkbot commented on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802508808 ## CI report: * 99f0b12ad7cd87ca9dfd5d9d3e97030eb41135f9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15270: [FLINK-21843][table-planner-blink] Support json ser/de for StreamExecGroupWindowAggregate

flinkbot edited a comment on pull request #15270: URL: https://github.com/apache/flink/pull/15270#issuecomment-802066772 ## CI report: * bff3961bf9c86186d08014044f28843a4dd72397 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15257: [FLINK-21852][table] Introduce SupportsAnyNull to BinaryRowData

flinkbot edited a comment on pull request #15257: URL: https://github.com/apache/flink/pull/15257#issuecomment-801601825 ## CI report: * c75184bb0b59c6bd548ba481d96525991a2bac07 UNKNOWN * e98801c410ec95737e91892661e393752f5e4468 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

flinkbot edited a comment on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-79889 ## CI report: * 95bf51ed50d7706aeca72db222e5862a1c78eb79 Azure:

[jira] [Commented] (FLINK-21841) Can not find kafka-connect with sql-kafka-connector

[ https://issues.apache.org/jira/browse/FLINK-21841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304609#comment-17304609 ] JieFang.He commented on FLINK-21841: [~jark] Thank you for your answers. It works. I used the wrong

[GitHub] [flink] hehuiyuan commented on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

hehuiyuan commented on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-802500849 @flinkbot re-run -- 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] hehuiyuan closed pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

hehuiyuan closed pull request #15274: URL: https://github.com/apache/flink/pull/15274 -- 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. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #15275: [hotfix][docs]add 'IF NOT EXISTS' to create table statement

flinkbot commented on pull request #15275: URL: https://github.com/apache/flink/pull/15275#issuecomment-802498311 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

[jira] [Closed] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21805. -- Resolution: Fixed Fixed in 1.13.0: ca80fc9e63c923893efd3d61b816bb731d5400b1 > Support StreamExecRank

[jira] [Updated] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21805: --- Fix Version/s: 1.13.0 > Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json

[jira] [Updated] (FLINK-21805) Support StreamExecRank and StreamExecSortLimit and StreamExecLimit Json ser/de

[ https://issues.apache.org/jira/browse/FLINK-21805?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21805: --- Component/s: Table SQL / Planner > Support StreamExecRank and StreamExecSortLimit and

[GitHub] [flink] godfreyhe closed pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

godfreyhe closed pull request #15231: URL: https://github.com/apache/flink/pull/15231 -- 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. For queries about this service,

[GitHub] [flink] zhuxiaoshang opened a new pull request #15275: [hotfix][docs]add 'IF NOT EXISTS' to create table statement

zhuxiaoshang opened a new pull request #15275: URL: https://github.com/apache/flink/pull/15275 ## What is the purpose of the change add 'IF NOT EXISTS' to create table statement docs ## Brief change log add 'IF NOT EXISTS' to create table statement docs

[GitHub] [flink] flinkbot edited a comment on pull request #15270: [FLINK-21843][table-planner-blink] Support json ser/de for StreamExecGroupWindowAggregate

flinkbot edited a comment on pull request #15270: URL: https://github.com/apache/flink/pull/15270#issuecomment-802066772 ## CI report: * bff3961bf9c86186d08014044f28843a4dd72397 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

flinkbot edited a comment on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-79889 ## CI report: * 95bf51ed50d7706aeca72db222e5862a1c78eb79 Azure:

[GitHub] [flink] becketqin commented on pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

becketqin commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-802492952 Thanks for the patch. LGTM. Merged to master: 844601b9c1468e241325bcff9695a52035192661 -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] godfreyhe commented on pull request #15231: [FLINK-21805][table-planner-blink] Support json ser/de for StreamExecRank, StreamExecLimit and StreamExecSortLimit

godfreyhe commented on pull request #15231: URL: https://github.com/apache/flink/pull/15231#issuecomment-802492993 The failed test has nothing with this pr, I will merge this pr. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot commented on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

flinkbot commented on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-802492492 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] becketqin merged pull request #14784: [FLINK-21160][connector/kafka] Fix bug of referencing uninitialized deserializer when using KafkaRecordDeserializer#valueOnly

becketqin merged pull request #14784: URL: https://github.com/apache/flink/pull/14784 -- 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. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

flinkbot commented on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802491454 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] hehuiyuan opened a new pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

hehuiyuan opened a new pull request #15274: URL: https://github.com/apache/flink/pull/15274 ## What is the purpose of the change There is no prompt when the the path to hadoop conf configured is wrong unintentional. It is better to load hadoop conf from possiable hadoop path when

[GitHub] [flink] xintongsong commented on pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

xintongsong commented on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802490464 cc @tillrohrmann @kezhuw -- 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

[jira] [Updated] (FLINK-21800) Guard MemorySegment against concurrent frees.

[ https://issues.apache.org/jira/browse/FLINK-21800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21800: --- Labels: pull-request-available (was: ) > Guard MemorySegment against concurrent frees. >

[GitHub] [flink] xintongsong opened a new pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

xintongsong opened a new pull request #15273: URL: https://github.com/apache/flink/pull/15273 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring

[GitHub] [flink] KarmaGYZ commented on a change in pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

KarmaGYZ commented on a change in pull request #15249: URL: https://github.com/apache/flink/pull/15249#discussion_r597364645 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java ## @@ -636,6 +637,15 @@

[jira] [Closed] (FLINK-21811) Support StreamExecJoin json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21811. -- Resolution: Fixed Fixed in 1.13.0: 3582bb23ba3919b10f36c35d214048ecfaabe5c3 > Support StreamExecJoin

[GitHub] [flink] godfreyhe closed pull request #15239: [FLINK-21811][blink-table-planner]Support StreamExecJoin json serialization/deserialization

godfreyhe closed pull request #15239: URL: https://github.com/apache/flink/pull/15239 -- 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. For queries about this service,

[GitHub] [flink] hehuiyuan closed pull request #15244: [FLINK-21829][Hive Connect]Fix to create HiveCatalog with custom hadoopconfdir first

hehuiyuan closed pull request #15244: URL: https://github.com/apache/flink/pull/15244 -- 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. For queries about this service,

[GitHub] [flink] zuston commented on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

zuston commented on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-802467775 > Thanks for creating this PR @zuston. LGTM. Merging once AZP gives green light. Thanks. -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] zuston commented on pull request #15185: [FLINK-21768][clients]Optimize system.exit() logic of CliFrontend

zuston commented on pull request #15185: URL: https://github.com/apache/flink/pull/15185#issuecomment-802467665 > @zuston nit: The commit message could be refined. > > * Commit title`[clients]` -> `[client]` > * Remove the magic commit message content `Change-Id:

[GitHub] [flink] vthinkxie commented on a change in pull request #15249: [FLINK-21794][metrics] Support retrieving slot details via rest api

vthinkxie commented on a change in pull request #15249: URL: https://github.com/apache/flink/pull/15249#discussion_r597360427 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java ## @@ -636,6 +637,15 @@

[jira] [Closed] (FLINK-21744) Support StreamExecDeduplicate json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21744. -- Resolution: Fixed Fixed in 1.13.0: 606ef6989c96ae376c969bf103d7275750323a8f > Support

[GitHub] [flink] godfreyhe closed pull request #15220: [FLINK-21744][table-planner-blink]Support StreamExecDeduplicate json serialization/deserialization

godfreyhe closed pull request #15220: URL: https://github.com/apache/flink/pull/15220 -- 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. For queries about this service,

[jira] [Closed] (FLINK-21236) Don't explicitly use HeapMemorySegment in raw format serde

[ https://issues.apache.org/jira/browse/FLINK-21236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-21236. Resolution: Fixed Fixed via: * master (1.13): 51ead52ef2aa22b201ef28a247eb84b5f0528244 > Don't

[jira] [Assigned] (FLINK-21861) Support StreamExecIncrementalGroupAggregate json serialization/deserialization

[ https://issues.apache.org/jira/browse/FLINK-21861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-21861: -- Assignee: godfrey he > Support StreamExecIncrementalGroupAggregate json

[GitHub] [flink] hehuiyuan commented on pull request #15250: [FLINK-20318][Connector/kafka]Fix cast question for properies() method in kafka ConnectorDescriptor

hehuiyuan commented on pull request #15250: URL: https://github.com/apache/flink/pull/15250#issuecomment-802457256 hi @rmetzger , who can help look at this problem? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] xintongsong closed pull request #15258: [FLINK-21236][core] Remove HeapMemorySegment

xintongsong closed pull request #15258: URL: https://github.com/apache/flink/pull/15258 -- 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. For queries about this service,

[GitHub] [flink] leonardBang commented on pull request #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

leonardBang commented on pull request #15254: URL: https://github.com/apache/flink/pull/15254#issuecomment-802440012 ok, I'll review this one -- 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] [Closed] (FLINK-21862) Add a Java SDK showcase tutorial to StateFun playground

[ https://issues.apache.org/jira/browse/FLINK-21862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21862. --- Resolution: Fixed flink-statefun-playground/dev:

[GitHub] [flink-statefun-playground] asfgit closed pull request #3: [FLINK-21862] Add a Java SDK Showcase tutorial

asfgit closed pull request #3: URL: https://github.com/apache/flink-statefun-playground/pull/3 -- 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. For queries about this

[GitHub] [flink-statefun-playground] tzulitai commented on pull request #3: [FLINK-21862] Add a Java SDK Showcase tutorial

tzulitai commented on pull request #3: URL: https://github.com/apache/flink-statefun-playground/pull/3#issuecomment-802432567 Thanks for the review, merging this. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[GitHub] [flink-statefun-playground] tzulitai closed pull request #3: [FLINK-21862] Add a Java SDK Showcase tutorial

tzulitai closed pull request #3: URL: https://github.com/apache/flink-statefun-playground/pull/3 -- 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. For queries about this

[GitHub] [flink-statefun-playground] tzulitai commented on a change in pull request #3: [FLINK-21862] Add a Java SDK Showcase tutorial

tzulitai commented on a change in pull request #3: URL: https://github.com/apache/flink-statefun-playground/pull/3#discussion_r597341146 ## File path: java/showcase/pom.xml ## @@ -0,0 +1,115 @@ + + +http://maven.apache.org/POM/4.0.0; +

[GitHub] [flink-statefun-playground] afedulov commented on pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

afedulov commented on pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#issuecomment-802346950 Hey @igalshilman , thanks for the comments! I addressed, them. There are just a couple of small open questions. -- This is an automated message from the Apache

[GitHub] [flink-statefun-playground] afedulov commented on a change in pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

afedulov commented on a change in pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#discussion_r597280377 ## File path: java/shopping-cart/Dockerfile ## @@ -0,0 +1,19 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more

[GitHub] [flink-statefun-playground] afedulov commented on a change in pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

afedulov commented on a change in pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#discussion_r597278166 ## File path: java/shopping-cart/src/main/statefun-config-sample/module.yaml ## @@ -0,0 +1,72 @@ +# Licensed to the Apache Software

[GitHub] [flink-statefun-playground] afedulov commented on a change in pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

afedulov commented on a change in pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#discussion_r597277393 ## File path: java/shopping-cart/pom.xml ## @@ -0,0 +1,82 @@ + + +http://www.w3.org/2001/XMLSchema-instance; +

[GitHub] [flink-statefun-playground] afedulov commented on a change in pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

afedulov commented on a change in pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#discussion_r597276568 ## File path: java/shopping-cart/src/main/java/org/apache/flink/statefun/examples/shoppingcart/InventoryFn.java ## @@ -0,0 +1,70 @@ +/* +

[GitHub] [flink-statefun-playground] igalshilman commented on a change in pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

igalshilman commented on a change in pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#discussion_r597264336 ## File path: java/shopping-cart/Dockerfile ## @@ -0,0 +1,19 @@ +# Licensed to the Apache Software Foundation (ASF) under one or more

[GitHub] [flink-statefun-playground] afedulov commented on a change in pull request #2: [FLINK-21826] Migrate the shopping-cart-example to the new SDK.

afedulov commented on a change in pull request #2: URL: https://github.com/apache/flink-statefun-playground/pull/2#discussion_r597261620 ## File path: java/shopping-cart/src/main/java/org/apache/flink/statefun/examples/shoppingcart/Expose.java ## @@ -0,0 +1,104 @@ +/* + *

  1   2   3   4   5   >