[jira] [Commented] (FLINK-21103) E2e tests time out on azure

2021-03-15 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302259#comment-17302259 ] Guowei Ma commented on FLINK-21103: --- another case in the 1.12 https://dev.azure.com/ap

[GitHub] [flink] flinkbot commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-03-15 Thread GitBox
flinkbot commented on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-82978 ## CI report: * 6e7591d29175ce0541c63d7e17dcc4dfcebd6c02 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15228: [hotfix][resourceManager] fix the check that whether JobLeaderIdServi…

2021-03-15 Thread GitBox
flinkbot commented on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-82897 ## CI report: * cd66720ed825af26c41fbf6bbba898f8b0828e23 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15227: URL: https://github.com/apache/flink/pull/15227#issuecomment-799983443 ## CI report: * 6aad55f902abd4fd0acaf7e852264334c7b1315e Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15209: [FLINK-21784] Allow extension of HeapBackend RestoreOperation

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15209: URL: https://github.com/apache/flink/pull/15209#issuecomment-798996080 ## CI report: * f22543ce4a30c01b8fb50325f0578378bf90d1ea Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * e0e50dfafd63b8e043fc34672bd4a1c5c7ee8bbe Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 8a320ad9b0780b4b18c23c68314ffd2b750f259c UNKNOWN * 625559cda6f8fc99ad0722e716a063e3482a80e1 Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Assigned] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

2021-03-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-11408: Assignee: Kezhu Wang > ContinuousProcessingTimeTrigger: NPE on clear() and state

[jira] [Commented] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

2021-03-15 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302258#comment-17302258 ] Dawid Wysakowicz commented on FLINK-11408: -- Please go ahead [~kezhuw] > Contin

[GitHub] [flink] flinkbot edited a comment on pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15204: URL: https://github.com/apache/flink/pull/15204#issuecomment-798969920 ## CI report: * de733f40a33045acef6ef9b6a4e17d767c55d9b9 UNKNOWN * 251bdef8c5a4425debdc1068a62f60537b7f78b0 UNKNOWN * d1219e15f336e33d29b470a4b54a951caf64

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * 8ffda1057a568101b1458820d6f22731b50cc9a1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

2021-03-15 Thread Guowei Ma (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302257#comment-17302257 ] Guowei Ma commented on FLINK-21103: --- another case in the 1.11 https://dev.azure.com/ap

[GitHub] [flink] flinkbot edited a comment on pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15112: URL: https://github.com/apache/flink/pull/15112#issuecomment-792620617 ## CI report: * 928bf6ee7c0b59a07dcb9f6125b9e45b66df1338 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * e82fe2aac9edd6def8c5ef83ccafe5846c1ac7e4 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] knaufk commented on a change in pull request #15064: [FLINK-21074][FLINK-21076][docs][coord] Document Reactive Mode

2021-03-15 Thread GitBox
knaufk commented on a change in pull request #15064: URL: https://github.com/apache/flink/pull/15064#discussion_r593266223 ## File path: docs/content/docs/deployment/elastic_scaling.md ## @@ -0,0 +1,107 @@ +--- +title: Elastic Scaling +weight: 5 +type: docs + +--- + + +# Elasti

[jira] [Comment Edited] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

2021-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302213#comment-17302213 ] Yang Wang edited comment on FLINK-21685 at 3/16/21, 6:40 AM: -

[jira] [Comment Edited] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302255#comment-17302255 ] Terry Wang edited comment on FLINK-21802 at 3/16/21, 6:40 AM:

[jira] [Commented] (FLINK-21802) LogicalTypeJsonDeserializer/Serializer custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread Terry Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302255#comment-17302255 ] Terry Wang commented on FLINK-21802: It seems I mistakenly put this issure under FLI

[GitHub] [flink] Myasuka commented on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

2021-03-15 Thread GitBox
Myasuka commented on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-75221 If we enable track the latency of state access, there would exist some performance regression as we need to calculate the latency via two times call of `System.nanoTime`. Bel

[GitHub] [flink] flinkbot commented on pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-03-15 Thread GitBox
flinkbot commented on pull request #15229: URL: https://github.com/apache/flink/pull/15229#issuecomment-799986953 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 pro

[jira] [Updated] (FLINK-19142) Investigate slot hijacking from preceding pipelined regions after failover

2021-03-15 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19142: --- Labels: pull-request-available (was: ) > Investigate slot hijacking from preceding pipeline

[GitHub] [flink] zhuzhurk opened a new pull request #15229: [FLINK-19142][runtime] Fix slot hijacking after task failover

2021-03-15 Thread GitBox
zhuzhurk opened a new pull request #15229: URL: https://github.com/apache/flink/pull/15229 ## What is the purpose of the change See FLINK-19142 ## Verifying this change - *Added UT* ## Does this pull request potentially affect one of the following parts:

[GitHub] [flink] flinkbot commented on pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

2021-03-15 Thread GitBox
flinkbot commented on pull request #15227: URL: https://github.com/apache/flink/pull/15227#issuecomment-799983443 ## CI report: * 6aad55f902abd4fd0acaf7e852264334c7b1315e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15228: [hotfix][resourceManager] fix the check that whether JobLeaderIdServi…

2021-03-15 Thread GitBox
flinkbot commented on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-799983331 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 pro

[GitHub] [flink] flinkbot edited a comment on pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15226: URL: https://github.com/apache/flink/pull/15226#issuecomment-799974052 ## CI report: * 174d3bffbdc765f2eafe5c5295fe90554f4db6f7 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15209: [FLINK-21784] Allow extension of HeapBackend RestoreOperation

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15209: URL: https://github.com/apache/flink/pull/15209#issuecomment-798996080 ## CI report: * f22543ce4a30c01b8fb50325f0578378bf90d1ea Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15204: URL: https://github.com/apache/flink/pull/15204#issuecomment-798969920 ## CI report: * de733f40a33045acef6ef9b6a4e17d767c55d9b9 UNKNOWN * 251bdef8c5a4425debdc1068a62f60537b7f78b0 UNKNOWN * d1219e15f336e33d29b470a4b54a951caf64

[GitHub] [flink] flinkbot edited a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15205: URL: https://github.com/apache/flink/pull/15205#issuecomment-798969965 ## CI report: * 8087d8f7d23911e311e212464badff6c89945e1d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15206: [FLINK-21673] Add extension points to snapshot reading/wr…

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15206: URL: https://github.com/apache/flink/pull/15206#issuecomment-798969998 ## CI report: * e78660dd022b3beface3ea8307e8f89292127c03 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * c9e2228fabe711bfa14d967084f2580cf51bdf4f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Closed] (FLINK-21707) Job is possible to hang when restarting a FINISHED task with POINTWISE BLOCKING consumers

2021-03-15 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-21707. --- Resolution: Fixed fixed via: master(1.13): c1aa6b41841342ddf6e168f326a183db8a8edcac 1.12: f935621fb357613a50

[GitHub] [flink] pengkangjing opened a new pull request #15228: [hotfix][resourceManager] fix the check that whether JobLeaderIdServi…

2021-03-15 Thread GitBox
pengkangjing opened a new pull request #15228: URL: https://github.com/apache/flink/pull/15228 ## What is the purpose of the change **fix the check that whether JobLeaderIdService has been stated** ## Brief change log **fix the check that whether JobLeaderId

[GitHub] [flink] flinkbot commented on pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

2021-03-15 Thread GitBox
flinkbot commented on pull request #15226: URL: https://github.com/apache/flink/pull/15226#issuecomment-799974052 ## CI report: * 174d3bffbdc765f2eafe5c5295fe90554f4db6f7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * abf3a6ff6c11d774b842af456a1c356a5292463a Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15206: [FLINK-21673] Add extension points to snapshot reading/wr…

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15206: URL: https://github.com/apache/flink/pull/15206#issuecomment-798969998 ## CI report: * e78660dd022b3beface3ea8307e8f89292127c03 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15205: [FLINK-21649] Refactor CopyOnWrite state classes

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15205: URL: https://github.com/apache/flink/pull/15205#issuecomment-798969965 ## CI report: * 8087d8f7d23911e311e212464badff6c89945e1d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * c9e2228fabe711bfa14d967084f2580cf51bdf4f Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

2021-03-15 Thread GitBox
flinkbot commented on pull request #15227: URL: https://github.com/apache/flink/pull/15227#issuecomment-799972353 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 pro

[GitHub] [flink] pengkangjing opened a new pull request #15227: [hotfix][checkpoint] Incorrect calculation of timeInQueue

2021-03-15 Thread GitBox
pengkangjing opened a new pull request #15227: URL: https://github.com/apache/flink/pull/15227 ## What is the purpose of the change **the correct timeInQueue is subtract request.timestamp from currentTimeMillis()** ## Brief change log **the correct timeInQueue is

[jira] [Created] (FLINK-21808) Support DQL in HiveParser

2021-03-15 Thread Rui Li (Jira)
Rui Li created FLINK-21808: -- Summary: Support DQL in HiveParser Key: FLINK-21808 URL: https://issues.apache.org/jira/browse/FLINK-21808 Project: Flink Issue Type: Sub-task Components: Conn

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

2021-03-15 Thread GitBox
flinkbot commented on pull request #15226: URL: https://github.com/apache/flink/pull/15226#issuecomment-799960289 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 pro

[GitHub] [flink] wuchong opened a new pull request #15226: [FLINK-20977][sql-client] Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped

2021-03-15 Thread GitBox
wuchong opened a new pull request #15226: URL: https://github.com/apache/flink/pull/15226 ## What is the purpose of the change Fix USE DATABASE & USE CATALOG fails with quoted identifiers containing characters to be escaped in SQL Client. ## Brief change log

[jira] [Created] (FLINK-21807) Make ApplicationDeployer interface public

2021-03-15 Thread Yang Wang (Jira)
Yang Wang created FLINK-21807: - Summary: Make ApplicationDeployer interface public Key: FLINK-21807 URL: https://issues.apache.org/jira/browse/FLINK-21807 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot edited a comment on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799908523 ## CI report: * a112ca39e0b124df96e5c143ac37a263c0340671 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Created] (FLINK-21806) ContinuousEventTimeTrigger should register its first timer base on current watermark

2021-03-15 Thread Kezhu Wang (Jira)
Kezhu Wang created FLINK-21806: -- Summary: ContinuousEventTimeTrigger should register its first timer base on current watermark Key: FLINK-21806 URL: https://issues.apache.org/jira/browse/FLINK-21806 Proj

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15200: [FLINK-21355] Send changes to the state changelog

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15200: URL: https://github.com/apache/flink/pull/15200#issuecomment-798902665 ## CI report: * 5e1342d9916f5c4356c622a40bc27bcbdacde9d7 UNKNOWN * ece208b9da559a725362de3d5c4e39e05de5d35e Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 7c1b2b19a27ad6411875c2cd49e4d0bdfac5d174 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21685) Flink JobManager failed to restart from checkpoint in kubernetes HA setup

2021-03-15 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302213#comment-17302213 ] Yang Wang commented on FLINK-21685: --- [~petrizhang] After submitting more jobs in the s

[jira] [Comment Edited] (FLINK-20130) Add ZStandard format to inputs

2021-03-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302212#comment-17302212 ] Xintong Song edited comment on FLINK-20130 at 3/16/21, 4:50 AM: --

[jira] [Reopened] (FLINK-20130) Add ZStandard format to inputs

2021-03-15 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reopened FLINK-20130: -- I have reverted the changes (f220277c907852c028150a26fb5aff55dcff9d57), because it breaks the mas

[GitHub] [flink] flinkbot edited a comment on pull request #15223: [hotfix][javadocs] Expand JavaDoc for AccumulatorHelper

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15223: URL: https://github.com/apache/flink/pull/15223#issuecomment-799779491 ## CI report: * f12a1ac3afc264fe3b4b2cd81e6a9b01dae8bef2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15204: [FLINK-21783] Allow extension of HeapBackend SnapshotStrategy

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15204: URL: https://github.com/apache/flink/pull/15204#issuecomment-798969920 ## CI report: * de733f40a33045acef6ef9b6a4e17d767c55d9b9 UNKNOWN * 251bdef8c5a4425debdc1068a62f60537b7f78b0 UNKNOWN * d1219e15f336e33d29b470a4b54a951caf64

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 7c1b2b19a27ad6411875c2cd49e4d0bdfac5d174 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] KurtYoung commented on pull request #14054: [FLINK-20130][core] Add ZStandard to FileInputFormat

2021-03-15 Thread GitBox
KurtYoung commented on pull request #14054: URL: https://github.com/apache/flink/pull/14054#issuecomment-799937333 Looks like this PR will break the tests. This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] kezhuw commented on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
kezhuw commented on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799937144 Hi @xintongsong, I have pushed a fixup commit according to you review comments. Please checkout and verify whether it meet your expectation. Thanks.

[jira] [Commented] (FLINK-21190) Expose extended exception history through REST handler and adapt UI accordingly

2021-03-15 Thread John Phelan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302203#comment-17302203 ] John Phelan commented on FLINK-21190: - hi [~mapohl] would you mind doing a call to t

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 6b317a312546abfb536c1358a331f1878e65e5d3 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15119: URL: https://github.com/apache/flink/pull/15119#issuecomment-792934307 ## CI report: * 7c1b2b19a27ad6411875c2cd49e4d0bdfac5d174 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on a change in pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
xintongsong commented on a change in pull request #15224: URL: https://github.com/apache/flink/pull/15224#discussion_r594840818 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java ## @@ -213,4 +213,16 @@ void releaseMemory(@Nonnega

[GitHub] [flink] xintongsong commented on a change in pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
xintongsong commented on a change in pull request #15224: URL: https://github.com/apache/flink/pull/15224#discussion_r594842999 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/memory/MemoryManagerTest.java ## @@ -351,4 +352,27 @@ private void testCannotReser

[GitHub] [flink] zjuwangg commented on a change in pull request #15215: [FLINK-21785][blink-table-planner] Support json ser/de for StreamExecCorrelate

2021-03-15 Thread GitBox
zjuwangg commented on a change in pull request #15215: URL: https://github.com/apache/flink/pull/15215#discussion_r594845347 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecCorrelate.java ## @@ -

[GitHub] [flink] wenlong88 commented on a change in pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
wenlong88 commented on a change in pull request #15219: URL: https://github.com/apache/flink/pull/15219#discussion_r594841777 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/serde/LogicalTypeSerdeTest.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * 6b317a312546abfb536c1358a331f1878e65e5d3 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * faff60c6e9ec1eedd27c3f1d221d7fc2de8f99c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21727) Support DDL in HiveParser

2021-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302199#comment-17302199 ] Jark Wu commented on FLINK-21727: - Fixed in master: 95d6278e522d3716d1932cbb97993b56ab38

[jira] [Closed] (FLINK-21727) Support DDL in HiveParser

2021-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21727. --- Assignee: Rui Li Resolution: Fixed > Support DDL in HiveParser > - > >

[GitHub] [flink] wuchong merged pull request #15151: [FLINK-21727][hive] Support DDL in HiveParser

2021-03-15 Thread GitBox
wuchong merged pull request #15151: URL: https://github.com/apache/flink/pull/15151 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-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21803: Component/s: (was: API / Core) Table SQL / API > Tumbling / Sliding windows are unawa

[jira] [Commented] (FLINK-21803) Tumbling / Sliding windows are unaware of daylight savings time

2021-03-15 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302196#comment-17302196 ] Jark Wu commented on FLINK-21803: - I think maybe FLINK-20387 can fix this problem. We wi

[GitHub] [flink] lindong28 commented on pull request #15161: [FLINK-20114][connector/kafka,common] Fix a few KafkaSource-related bugs

2021-03-15 Thread GitBox
lindong28 commented on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-799917097 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot edited a comment on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799908523 ## CI report: * a112ca39e0b124df96e5c143ac37a263c0340671 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-795141489 ## CI report: * faff60c6e9ec1eedd27c3f1d221d7fc2de8f99c7 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

2021-03-15 Thread GitBox
fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594834406 ## File path: flink-table/flink-sql-client/src/test/resources/sql/set.q ## @@ -42,20 +42,11 @@ CREATE TABLE hive_table ( [INFO] Table has been created. !

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

2021-03-15 Thread GitBox
fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594834367 ## File path: flink-table/flink-sql-client/src/test/resources/sql/set.q ## @@ -42,20 +42,11 @@ CREATE TABLE hive_table ( [INFO] Table has been created. !

[GitHub] [flink] xintongsong commented on a change in pull request #15112: [FLINK-21480][runtime] Respect external resources from resource requirements

2021-03-15 Thread GitBox
xintongsong commented on a change in pull request #15112: URL: https://github.com/apache/flink/pull/15112#discussion_r594812450 ## File path: flink-core/src/main/java/org/apache/flink/api/common/resources/Resource.java ## @@ -30,7 +30,8 @@ /** Base class for resources one c

[GitHub] [flink] fsk119 commented on a change in pull request #15197: [FLINK-21462][sql client] Use configuration to store the option and value in Sql client

2021-03-15 Thread GitBox
fsk119 commented on a change in pull request #15197: URL: https://github.com/apache/flink/pull/15197#discussion_r594830451 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/LocalExecutorITCase.java ## @@ -444,6 +444,7 @@ publi

[GitHub] [flink] flinkbot commented on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

2021-03-15 Thread GitBox
flinkbot commented on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799908523 ## CI report: * a112ca39e0b124df96e5c143ac37a263c0340671 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] leonardBang commented on pull request #15136: [FLINK-21622][table-planner] Introduce function TO_TIMESTAMP_LTZ(numeric [, precision])

2021-03-15 Thread GitBox
leonardBang commented on pull request #15136: URL: https://github.com/apache/flink/pull/15136#issuecomment-799908446 rebase and fix last comment This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] flinkbot edited a comment on pull request #15219: [FLINK-21802][table-planner-blink]LogicalTypeJsonDeserializer/Serializer support custom RowType/MapType/ArrayType/MultisetType

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15219: URL: https://github.com/apache/flink/pull/15219#issuecomment-799585147 ## CI report: * 1e37067b8a1c322f928aadb38418160667bf3923 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * 1afde0cb4e55f09d68c42afaa709c645b992784a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * e82fe2aac9edd6def8c5ef83ccafe5846c1ac7e4 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-11408) ContinuousProcessingTimeTrigger: NPE on clear() and state is lost on merge

2021-03-15 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302181#comment-17302181 ] Kezhu Wang commented on FLINK-11408: I think it is same as FLINK-5717 and similar to

[jira] [Commented] (FLINK-21634) ALTER TABLE statement enhancement

2021-03-15 Thread Zheng Hu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17302180#comment-17302180 ] Zheng Hu commented on FLINK-21634: -- Thanks for the update, Looks good to me (from iceb

[GitHub] [flink] flinkbot commented on pull request #15224: [FLINK-21753][runtime] Don't cycle reference between memory manager and gc cleaner action

2021-03-15 Thread GitBox
flinkbot commented on pull request #15224: URL: https://github.com/apache/flink/pull/15224#issuecomment-799901815 ## CI report: * a61ff8f4fa887ca43d9e7e0b938b8519aab032c8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15214: [FLINK-21793][k8s] Use RM generated JVM memory options.

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15214: URL: https://github.com/apache/flink/pull/15214#issuecomment-799249041 ## CI report: * 5e9149267553ea5925bf4f59fe875bd7bfc324cd Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

2021-03-15 Thread GitBox
flinkbot commented on pull request #15225: URL: https://github.com/apache/flink/pull/15225#issuecomment-799901617 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 pro

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

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-768786978 ## CI report: * e82fe2aac9edd6def8c5ef83ccafe5846c1ac7e4 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

2021-03-15 Thread GitBox
flinkbot edited a comment on pull request #15215: URL: https://github.com/apache/flink/pull/15215#issuecomment-799415392 ## CI report: * 1afde0cb4e55f09d68c42afaa709c645b992784a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] paul8263 opened a new pull request #15225: [hotfix][docs] Add missing semicolons and remove unnecessary semicolo…

2021-03-15 Thread GitBox
paul8263 opened a new pull request #15225: URL: https://github.com/apache/flink/pull/15225 [hotfix][docs] Add missing semicolons and remove unnecessary semicolons for learn-flink documents. ## What is the purpose of the change Fix several typos in Flink doc: learning-flink, by

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

2021-03-15 Thread Wenlong Lyu (Jira)
Wenlong Lyu created FLINK-21805: --- Summary: Support StreamExecRank and StreamExecSortLimit Json ser/de Key: FLINK-21805 URL: https://issues.apache.org/jira/browse/FLINK-21805 Project: Flink Issu

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

2021-03-15 Thread GitBox
PatrickRen commented on pull request #14784: URL: https://github.com/apache/flink/pull/14784#issuecomment-799897177 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, plea

  1   2   3   4   5   6   >