[GitHub] [flink] flinkbot edited a comment on pull request #14570: [FLINK-20798][k8s] Use namespaced kubernetes client when creating FlinkKubeClient

flinkbot edited a comment on pull request #14570: URL: https://github.com/apache/flink/pull/14570#issuecomment-755308058 ## CI report: * fa9f13d34946414ac57a1429548879d83e0ab6e4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14568: Update the Row.toString method

flinkbot edited a comment on pull request #14568: URL: https://github.com/apache/flink/pull/14568#issuecomment-755224268 ## CI report: * 7ca6a4f3b85eff5e92c9b12d2fca2091abc6de67 Azure:

[GitHub] [flink] blublinsky commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

blublinsky commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755541392 Sorry guys, how do I force the same PR. Unfortunately not a GIT guru This is an automated message from the

[GitHub] [flink] rmetzger commented on pull request #14529: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

rmetzger commented on pull request #14529: URL: https://github.com/apache/flink/pull/14529#issuecomment-755516798 Closing as this is a duplicate of https://github.com/apache/flink/pull/14512 This is an automated message from

[GitHub] [flink] rmetzger commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

rmetzger commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755516473 The benefit of sticking to the same PR (by (force) pushing changes is that we keep track of the history of changes). I'm closing the other PR. Please push your changes

[GitHub] [flink] flinkbot edited a comment on pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

flinkbot edited a comment on pull request #14502: URL: https://github.com/apache/flink/pull/14502#issuecomment-751570047 ## CI report: * 1a28221fa5f38577e134877d1ca28c87477d9aac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14312: [FLINK-20491] Support Broadcast State in BATCH execution mode

flinkbot edited a comment on pull request #14312: URL: https://github.com/apache/flink/pull/14312#issuecomment-738876739 ## CI report: * ca72d305e20fbb2ab11a36b93a2a1e969b6b7883 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14567: [FLINK-20453][runtime][checkpoint] Move checkpointing classes to an a…

flinkbot edited a comment on pull request #14567: URL: https://github.com/apache/flink/pull/14567#issuecomment-755063547 ## CI report: * 27095134441ec13971f36c873bca2a03d904cf36 Azure:

[jira] [Closed] (FLINK-20854) Introduce BytesMultiMap to support buffering records

[ https://issues.apache.org/jira/browse/FLINK-20854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-20854. --- Resolution: Fixed Fixed in master: facd51fcf5c78c5f733c203c38e3a093ba8a5218 > Introduce BytesMultiMap to

[GitHub] [flink] flinkbot commented on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

flinkbot commented on pull request #14572: URL: https://github.com/apache/flink/pull/14572#issuecomment-755905594 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] [Comment Edited] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260269#comment-17260269 ] oceanxie edited comment on FLINK-20798 at 1/7/21, 6:54 AM: --- The HA configmap

[GitHub] [flink] pnowojski opened a new pull request #14573: [FLINK-20868][task][metrics] Pause the idle/back pressure timers during processing mailbox actions

pnowojski opened a new pull request #14573: URL: https://github.com/apache/flink/pull/14573 FLINK-20717 introduced a bug, where any time spent on processing mails, when task is idle or back pressured, will be accounted to idle or back pressured time instead of the busy time. The

[jira] [Updated] (FLINK-20868) Pause the idle/back pressure timers during processing mailbox actions

[ https://issues.apache.org/jira/browse/FLINK-20868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20868: --- Labels: pull-request-available (was: ) > Pause the idle/back pressure timers during

[GitHub] [flink] fsk119 commented on a change in pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

fsk119 commented on a change in pull request #14539: URL: https://github.com/apache/flink/pull/14539#discussion_r553144882 ## File path: flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java ## @@ -128,6 +128,9 @@ Decoder

[GitHub] [flink] wuchong commented on a change in pull request #14569: [FLINK-20856][table-planner-blink] Separate the implementation of stream window aggregate nodes

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

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 5601ca0f26b9fdb130b0a030e7326d8b1287c76c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][json] Support to parse unescaped control chars in string node

flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

flinkbot edited a comment on pull request #14561: URL: https://github.com/apache/flink/pull/14561#issuecomment-754574127 ## CI report: * d2f645553ea7f6051cb81fee377672920ef871e0 Azure:

[GitHub] [flink] xintongsong commented on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

xintongsong commented on pull request #14557: URL: https://github.com/apache/flink/pull/14557#issuecomment-755937641 It's weird that the flinkbot command is not working. I've rebased the latest master and pushed to trigger the ci tests.

[GitHub] [flink] KarmaGYZ commented on a change in pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

KarmaGYZ commented on a change in pull request #14561: URL: https://github.com/apache/flink/pull/14561#discussion_r553153813 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java ## @@ -464,7 +464,11 @@ private void

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

flinkbot edited a comment on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * 34d88a71b61f62f2775a41eb291c017c6d76b8ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 09d3419bc7ef88969ad62f2d19a66e586610bdcf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * f1c012ecf5d3d91f13bb9bfa24ea7c31c775c9c7 Azure:

[jira] [Commented] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260257#comment-17260257 ] Qingsheng Ren commented on FLINK-20655: --- I used Flink integrated state machine example with 4

[jira] [Commented] (FLINK-20798) Using PVC as high-availability.storageDir could not work

[ https://issues.apache.org/jira/browse/FLINK-20798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260269#comment-17260269 ] oceanxie commented on FLINK-20798: -- The HA configmap would't be deleted when I delete the flink

[GitHub] [flink] V1ncentzzZ commented on pull request #14508: [FLINK-20773][json] Support to parse unescaped control chars in string node

V1ncentzzZ commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-755936508 Thanks @wuchong , Sounds good to me. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] flinkbot edited a comment on pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

flinkbot edited a comment on pull request #14561: URL: https://github.com/apache/flink/pull/14561#issuecomment-754574127 ## CI report: * d2f645553ea7f6051cb81fee377672920ef871e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14554: [FLINK-20798] add kubernates config in ha doc

flinkbot edited a comment on pull request #14554: URL: https://github.com/apache/flink/pull/14554#issuecomment-754363035 ## CI report: * c8a962e989edd60ad2da562729a8e61decbee41b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[GitHub] [flink] flinkbot edited a comment on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

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

[GitHub] [flink] flinkbot commented on pull request #14573: [FLINK-20868][task][metrics] Pause the idle/back pressure timers during processing mailbox actions

flinkbot commented on pull request #14573: URL: https://github.com/apache/flink/pull/14573#issuecomment-755944752 ## CI report: * 55a5642324516b32ce04521ac5881ce2b5985940 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-web] rmetzger commented on a change in pull request #408: Add security page for Flink

rmetzger commented on a change in pull request #408: URL: https://github.com/apache/flink-web/pull/408#discussion_r553158138 ## File path: _includes/navbar.html ## @@ -177,7 +177,9 @@ https://www.apache.org/licenses/; target="_blank">License -

[GitHub] [flink] rmetzger closed pull request #14529: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

rmetzger closed pull request #14529: URL: https://github.com/apache/flink/pull/14529 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[GitHub] [flink] xintongsong commented on a change in pull request #14560: [FLINK-20837] Refactor dynamic SlotID

xintongsong commented on a change in pull request #14560: URL: https://github.com/apache/flink/pull/14560#discussion_r553155630 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java ## @@ -288,22 +288,13 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #14508: [FLINK-20773][json] Support to parse unescaped control chars in string node

flinkbot edited a comment on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-751734163 ## CI report: * f1332b021d33a6e4681b0a08ad1c5b58f153c417 UNKNOWN * f4d02e921d2641fc5692617a4dd50ba2fda1128c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a9a50e78d0ba6ff84d02fbadee1484970fac2c79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * bbfc0d96eb419932d49a54bf95f008c3155fbc81 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * 1e34e16b05f86ea121ecefb4d7ff49f2b42b23a7 Azure:

[jira] [Commented] (FLINK-20773) Support to parse unescaped control chars in string node

[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260273#comment-17260273 ] Jark Wu commented on FLINK-20773: - After an offline discussion with [~xiaozilong], we both think that we

[GitHub] [flink] flinkbot edited a comment on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

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

[GitHub] [flink] fsk119 commented on a change in pull request #14539: [FLINK-20321][formats] Fix NPE when using AvroDeserializationSchema to deserialize null input

fsk119 commented on a change in pull request #14539: URL: https://github.com/apache/flink/pull/14539#discussion_r553116137 ## File path: flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java ## @@ -94,6 +94,9 @@ public

[GitHub] [flink] xiaoHoly commented on pull request #14531: [FLINK-20777][Connector][Kafka] Property "partition.discovery.interval.ms" shoule be enabled by default for unbounded mode, and disable for

xiaoHoly commented on pull request #14531: URL: https://github.com/apache/flink/pull/14531#issuecomment-755945542 Hi, @PatrickRen,@becketqin. Do you have time to review? This is an automated message from the Apache Git

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

maosuhan commented on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-755900070 @wuchong , I have updated the code formatting in my PR. This is an automated message from the Apache Git

[jira] [Created] (FLINK-20877) Refactor BytesHashMap and BytesMultiMap to support window key

Jark Wu created FLINK-20877: --- Summary: Refactor BytesHashMap and BytesMultiMap to support window key Key: FLINK-20877 URL: https://issues.apache.org/jira/browse/FLINK-20877 Project: Flink Issue

[jira] [Commented] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

[ https://issues.apache.org/jira/browse/FLINK-20872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260248#comment-17260248 ] Yun Tang commented on FLINK-20872: -- [~Jiangang] If I understand correct. You did not enable the

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * 5601ca0f26b9fdb130b0a030e7326d8b1287c76c Azure:

[GitHub] [flink] flinkbot commented on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

flinkbot commented on pull request #14572: URL: https://github.com/apache/flink/pull/14572#issuecomment-755910110 ## CI report: * 3f1d5189abe80623eba977235da6969663b535dc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

flinkbot edited a comment on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-754563038 ## CI report: * a4504bda6bf4e1b38aefb248bc8355bc7864f496 UNKNOWN * b19b9ae12b807b3e012b0952a70b824a91df0ce5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

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

[GitHub] [flink] wuchong commented on pull request #14508: [FLINK-20773][format] Support allow-unescaped-control-chars option for JSON format.

wuchong commented on pull request #14508: URL: https://github.com/apache/flink/pull/14508#issuecomment-755925759 Hi @V1ncentzzZ , I helped to rebase the branch to trigger build again. I also move the test into `TestSpec` list, because it is a general case now. If you don't have

[jira] [Updated] (FLINK-20863) Exclude network memory from ResourceProfile

[ https://issues.apache.org/jira/browse/FLINK-20863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20863: - Component/s: Runtime / Network > Exclude network memory from ResourceProfile >

[GitHub] [flink] KarmaGYZ commented on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

KarmaGYZ commented on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-755933152 Thanks for the review @xintongsong . PR updated. This is an automated message from the Apache Git Service. To

[GitHub] [flink] haydenzhourepo commented on a change in pull request #14554: [FLINK-20798] add kubernates config in ha doc

haydenzhourepo commented on a change in pull request #14554: URL: https://github.com/apache/flink/pull/14554#discussion_r553148565 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -52,6 +52,10 @@ In order to identify the Flink cluster, you have to specify a

[GitHub] [flink] haydenzhourepo commented on a change in pull request #14554: [FLINK-20798] add kubernates config in ha doc

haydenzhourepo commented on a change in pull request #14554: URL: https://github.com/apache/flink/pull/14554#discussion_r553148565 ## File path: docs/deployment/ha/kubernetes_ha.md ## @@ -52,6 +52,10 @@ In order to identify the Flink cluster, you have to specify a

[GitHub] [flink] flinkbot edited a comment on pull request #14516: [FLINK-20783][table-planner-blink] Separate implementation of ExecNode and PhysicalNode in batch join

flinkbot edited a comment on pull request #14516: URL: https://github.com/apache/flink/pull/14516#issuecomment-752024061 ## CI report: * b87220ccdee330380bc015427b9f4b445173e324 Azure:

[jira] [Updated] (FLINK-20877) Refactor BytesHashMap and BytesMultiMap to support window key

[ https://issues.apache.org/jira/browse/FLINK-20877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20877: --- Labels: pull-request-available (was: ) > Refactor BytesHashMap and BytesMultiMap to

[GitHub] [flink] wuchong opened a new pull request #14572: [FLINK-20877][table-runtime-blink] Refactor BytesHashMap and BytesMultiMap to support window key

wuchong opened a new pull request #14572: URL: https://github.com/apache/flink/pull/14572 ## What is the purpose of the change Currently, the BytesHashMap and BytesMultiMap only support BinaryRowData as the key. However, for window operators, the key should be groupKey +

[GitHub] [flink] flinkbot edited a comment on pull request #14560: [FLINK-20837] Refactor dynamic SlotID

flinkbot edited a comment on pull request #14560: URL: https://github.com/apache/flink/pull/14560#issuecomment-754563038 ## CI report: * a4504bda6bf4e1b38aefb248bc8355bc7864f496 UNKNOWN * b19b9ae12b807b3e012b0952a70b824a91df0ce5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * d3230f5b6087c8c3c3453c9d69a68e69305010b4 Azure:

[jira] [Updated] (FLINK-20773) Support to parse unescaped control chars in string node

[ https://issues.apache.org/jira/browse/FLINK-20773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20773: Summary: Support to parse unescaped control chars in string node (was: Support

[jira] [Updated] (FLINK-20420) ES6 ElasticsearchSinkITCase failed due to no output for 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-20420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias updated FLINK-20420: - Labels: test-stability (was: testability) > ES6 ElasticsearchSinkITCase failed due to no output for

[GitHub] [flink] flinkbot commented on pull request #14573: [FLINK-20868][task][metrics] Pause the idle/back pressure timers during processing mailbox actions

flinkbot commented on pull request #14573: URL: https://github.com/apache/flink/pull/14573#issuecomment-755932613 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-20871) Make DataStream#executeAndCollectWithClient() public

[ https://issues.apache.org/jira/browse/FLINK-20871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Zhen Wu updated FLINK-20871: --- Summary: Make DataStream#executeAndCollectWithClient() public (was: Make

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * d4d6f9aa45758753d7dfd55dd253c1c540626646 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * d4d6f9aa45758753d7dfd55dd253c1c540626646 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

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

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

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553093799 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

flinkbot edited a comment on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * Unknown: [CANCELED](TBD) * 34d88a71b61f62f2775a41eb291c017c6d76b8ab UNKNOWN Bot commands The @flinkbot bot supports the

[GitHub] [flink] godfreyhe closed pull request #14502: [Flink-20766][table-planner-blink] Separate implementations of sort ExecNode and PhysicalNode.

godfreyhe closed pull request #14502: URL: https://github.com/apache/flink/pull/14502 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

[jira] [Created] (FLINK-20872) Job resume from history savepoint when failover if checkpoint is disabled

Liu created FLINK-20872: --- Summary: Job resume from history savepoint when failover if checkpoint is disabled Key: FLINK-20872 URL: https://issues.apache.org/jira/browse/FLINK-20872 Project: Flink

[GitHub] [flink] stevenzwu opened a new pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

stevenzwu opened a new pull request #14571: URL: https://github.com/apache/flink/pull/14571 …ient() public This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Created] (FLINK-20873) Upgrade Calcite version to 1.27

Jark Wu created FLINK-20873: --- Summary: Upgrade Calcite version to 1.27 Key: FLINK-20873 URL: https://issues.apache.org/jira/browse/FLINK-20873 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

flinkbot commented on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * 54088a5e88bc0f7ab29c21b754a6733c45d1a8bc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] blublinsky commented on pull request #14512: FLINK-20359 Added Owner Reference to Job Manager in native kubernetes

blublinsky commented on pull request #14512: URL: https://github.com/apache/flink/pull/14512#issuecomment-755848208 Oh, my problem is that I am working from the local fork, that I updated to get the latest version. So my previous fork is gone, thats why it created a new commit. So now

[GitHub] [flink] godfreyhe commented on a change in pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

godfreyhe commented on a change in pull request #14562: URL: https://github.com/apache/flink/pull/14562#discussion_r552627854 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/ExecNodeUtil.java ## @@ -35,6

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

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553102794 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

[GitHub] [flink] godfreyhe commented on a change in pull request #14562: [FLINK-20738][table-planner-blink] Separate the implementation of batch group aggregate nodes

godfreyhe commented on a change in pull request #14562: URL: https://github.com/apache/flink/pull/14562#discussion_r552627854 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/utils/ExecNodeUtil.java ## @@ -35,6

[jira] [Created] (FLINK-20870) FlinkKafkaSink

xx chai created FLINK-20870: --- Summary: FlinkKafkaSink Key: FLINK-20870 URL: https://issues.apache.org/jira/browse/FLINK-20870 Project: Flink Issue Type: Improvement Components: API /

[jira] [Commented] (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:comment-tabpanel=17260156#comment-17260156 ] Danny Chen commented on FLINK-18027: Fixed in https://issues.apache.org/jira/browse/CALCITE-4456,

[GitHub] [flink] flinkbot edited a comment on pull request #14557: [FLINK-20781] Avoid NPE after SourceOperator is closed.

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

[jira] [Commented] (FLINK-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

[ https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260168#comment-17260168 ] Jark Wu commented on FLINK-20861: - Feel free to open pull request. > Provide an option for serializing

[jira] [Updated] (FLINK-20861) Provide an option for serializing DECIMALs in JSON as plain number instead of scientific notation

[ https://issues.apache.org/jira/browse/FLINK-20861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-20861: Fix Version/s: 1.13.0 > Provide an option for serializing DECIMALs in JSON as plain number instead of >

[jira] [Updated] (FLINK-20832) flink.apache.org site Typography exception

[ https://issues.apache.org/jira/browse/FLINK-20832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 谢波 updated FLINK-20832: --- Component/s: API / Core > flink.apache.org site Typography exception > -- >

[GitHub] [flink] flinkbot edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

flinkbot edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-744252765 ## CI report: * a9a50e78d0ba6ff84d02fbadee1484970fac2c79 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * aa9776ffae2b203d7c6980f4f7a32b70c26c6477 Azure:

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

maosuhan commented on a change in pull request #14376: URL: https://github.com/apache/flink/pull/14376#discussion_r553094997 ## File path: flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/PbSchemaValidator.java ## @@ -0,0 +1,148 @@ +/* + * Licensed

[jira] [Closed] (FLINK-20766) Separate the implementation of sort nodes

[ https://issues.apache.org/jira/browse/FLINK-20766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-20766. -- Resolution: Fixed Fixed in 1.13.0: 6c75072f..7668e4e3 > Separate the implementation of sort nodes >

[GitHub] [flink] flinkbot edited a comment on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

flinkbot edited a comment on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755845385 ## CI report: * Unknown: [CANCELED](TBD) * 34d88a71b61f62f2775a41eb291c017c6d76b8ab Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * aa9776ffae2b203d7c6980f4f7a32b70c26c6477 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14538: [FLINK-20681][yarn] Support remote path for shipping archives and files

flinkbot edited a comment on pull request #14538: URL: https://github.com/apache/flink/pull/14538#issuecomment-752991523 ## CI report: * af57879d33f5d7e1717518a475fd601916c5c7c1 UNKNOWN * f1c012ecf5d3d91f13bb9bfa24ea7c31c775c9c7 Azure:

[jira] [Updated] (FLINK-20870) FlinkKafkaSink

[ https://issues.apache.org/jira/browse/FLINK-20870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xx chai updated FLINK-20870: Issue Type: Bug (was: Improvement) > FlinkKafkaSink > -- > > Key:

[jira] [Created] (FLINK-20871) Make DataStream#executeAndCollectWithClient public

Steven Zhen Wu created FLINK-20871: -- Summary: Make DataStream#executeAndCollectWithClient public Key: FLINK-20871 URL: https://issues.apache.org/jira/browse/FLINK-20871 Project: Flink Issue

[GitHub] [flink] flinkbot commented on pull request #14571: [FLINK-20871][API/DataStream] Make DataStream#executeAndCollectWithCl…

flinkbot commented on pull request #14571: URL: https://github.com/apache/flink/pull/14571#issuecomment-755840587 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] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260178#comment-17260178 ] Jark Wu edited comment on FLINK-20795 at 1/7/21, 2:38 AM: -- If we want to

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260178#comment-17260178 ] Jark Wu edited comment on FLINK-20795 at 1/7/21, 2:38 AM: -- If we want to

[jira] [Comment Edited] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260178#comment-17260178 ] Jark Wu edited comment on FLINK-20795 at 1/7/21, 2:37 AM: -- If we want to

[jira] [Commented] (FLINK-20795) add a parameter to decide whether print dirty record when `ignore-parse-errors` is true

[ https://issues.apache.org/jira/browse/FLINK-20795?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260178#comment-17260178 ] Jark Wu commented on FLINK-20795: - If we want to refactor this configuration. I would suggest to

[GitHub] [flink] xintongsong commented on a change in pull request #14561: [FLINK-20836] Register TaskManager with total and default slot resource profile in SlotManager

xintongsong commented on a change in pull request #14561: URL: https://github.com/apache/flink/pull/14561#discussion_r553079447 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManager.java ## @@ -275,7 +275,10 @@

[GitHub] [flink] wenlong88 commented on a change in pull request #14569: [FLINK-20856][table-planner-blink] Separate the implementation of stream window aggregate nodes

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

[GitHub] [flink] flinkbot edited a comment on pull request #14477: [FLINK-16005][yarn] Support yarn and hadoop config override

flinkbot edited a comment on pull request #14477: URL: https://github.com/apache/flink/pull/14477#issuecomment-750231028 ## CI report: * aa9776ffae2b203d7c6980f4f7a32b70c26c6477 Azure:

  1   2   3   >