[GitHub] [flink] zentol merged pull request #15330: [hotfix][build] Add missing antlr3 plugin version

2021-03-23 Thread GitBox
zentol merged pull request #15330: URL: https://github.com/apache/flink/pull/15330 -- 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, please

[jira] [Commented] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

2021-03-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306860#comment-17306860 ] Dawid Wysakowicz commented on FLINK-21896: -- Thank you [~godfreyhe]! >

[jira] [Assigned] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

2021-03-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-21896: Assignee: godfrey he > GroupAggregateJsonPlanTest.testDistinctAggCalls fail >

[jira] [Issue Comment Deleted] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

2021-03-23 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-21896: --- Comment: was deleted (was: Thanks for reporting this, I will take this issue. ) >

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

2021-03-23 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21190. Fix Version/s: 1.13.0 Resolution: Fixed master:

[GitHub] [flink] zentol merged pull request #15049: [FLINK-21190][runtime-web] Expose exception history

2021-03-23 Thread GitBox
zentol merged pull request #15049: URL: https://github.com/apache/flink/pull/15049 -- 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, please

[jira] [Updated] (FLINK-21174) Optimize the performance of ResourceAllocationStrategy

2021-03-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21174: - Parent: (was: FLINK-14187) Issue Type: Task (was: Sub-task) > Optimize the

[jira] [Comment Edited] (FLINK-20496) RocksDB partitioned index filter option

2021-03-23 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-20496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306525#comment-17306525 ] Maciej Bryński edited comment on FLINK-20496 at 3/23/21, 7:45 AM: --

[jira] [Closed] (FLINK-21874) Check for out-dated slot allocation confirmations is insufficient

2021-03-23 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21874. Resolution: Fixed master: 63be0cd6d6434b054dde9a1779299e97d0b0545c > Check for out-dated

[GitHub] [flink] zentol merged pull request #15288: [FLINK-21874][coordination] Ignore outdated slot allocation confirmations

2021-03-23 Thread GitBox
zentol merged pull request #15288: URL: https://github.com/apache/flink/pull/15288 -- 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, please

[jira] [Created] (FLINK-21924) Fine Grained Resource Management

2021-03-23 Thread Xintong Song (Jira)
Xintong Song created FLINK-21924: Summary: Fine Grained Resource Management Key: FLINK-21924 URL: https://issues.apache.org/jira/browse/FLINK-21924 Project: Flink Issue Type: New Feature

[GitHub] [flink] rkhachatryan commented on a change in pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-23 Thread GitBox
rkhachatryan commented on a change in pull request #15331: URL: https://github.com/apache/flink/pull/15331#discussion_r599331707 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java ## @@ -192,14 +193,16 @@ private void

[GitHub] [flink] flinkbot commented on pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

2021-03-23 Thread GitBox
flinkbot commented on pull request #15339: URL: https://github.com/apache/flink/pull/15339#issuecomment-804687609 ## CI report: * 61bac18cf324bf4b282471ec37cc6ea05a41ad05 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15338: [FLINK-21922][python] Fix partition_by in Over which doesn't work for expression DSL

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15338: URL: https://github.com/apache/flink/pull/15338#issuecomment-804677128 ## CI report: * bd36bd954d126f9cc22a70ae26531d6c3b7b7e33 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-799172540 ## CI report: * 55bf3a050d7c3d1c49914d3942e900da3eb39eb1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-796635889 ## CI report: * 6314c86f14c23f286d9c2e3d8d711da8f786 Azure:

[jira] [Commented] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

2021-03-23 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306847#comment-17306847 ] godfrey he commented on FLINK-21896: Thanks for reporting this, I will take this issue. >

[jira] [Commented] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

2021-03-23 Thread godfrey he (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306848#comment-17306848 ] godfrey he commented on FLINK-21896: Thanks for reporting this, I will take this issue. >

[jira] [Closed] (FLINK-21045) Improve Usability of Pluggable Modules

2021-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21045. --- Resolution: Fixed Thanks a lot for the great contribution [~qingyue]. I will close the umbrella issue. >

[jira] [Closed] (FLINK-21300) Update module documentation

2021-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21300. --- Resolution: Fixed Fixed in master: 15b56977cf6370d01a2bab1b7dab72fd7ae38351 > Update module documentation

[GitHub] [flink] wuchong merged pull request #15230: [FLINK-21300][docs] Update module-related documentation

2021-03-23 Thread GitBox
wuchong merged pull request #15230: URL: https://github.com/apache/flink/pull/15230 -- 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] Myasuka commented on a change in pull request #15119: [FLINK-21736][state] Introduce state scope latency tracking metrics

2021-03-23 Thread GitBox
Myasuka commented on a change in pull request #15119: URL: https://github.com/apache/flink/pull/15119#discussion_r599325612 ## File path: flink-core/src/main/java/org/apache/flink/configuration/StateBackendOptions.java ## @@ -0,0 +1,95 @@ +/* + * Licensed to the Apache

[GitHub] [flink] WeiZhong94 commented on pull request #15149: [FLINK-21294][python] Support state access API for the map/flat_map operation of Python ConnectedStreams

2021-03-23 Thread GitBox
WeiZhong94 commented on pull request #15149: URL: https://github.com/apache/flink/pull/15149#issuecomment-804680736 @HuangXingBo Thanks for your comments. I have updated this PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Commented] (FLINK-20824) BlockingShuffleITCase. testSortMergeBlockingShuffle test failed with "Inconsistent availability: expected true"

2021-03-23 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306837#comment-17306837 ] Yingjie Cao commented on FLINK-20824: - Hi, I am pretty sure this is the same issue with FLINK-20547.

[GitHub] [flink] flinkbot commented on pull request #15338: [FLINK-21922][python] Fix partition_by in Over which doesn't work for expression DSL

2021-03-23 Thread GitBox
flinkbot commented on pull request #15338: URL: https://github.com/apache/flink/pull/15338#issuecomment-804677128 ## CI report: * bd36bd954d126f9cc22a70ae26531d6c3b7b7e33 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-21330) Optimize the performance of PipelinedRegionSchedulingStrategy

2021-03-23 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21330: - Description: PipelinedRegionSchedulingStrategy is used for task scheduling. Its initialization

[GitHub] [flink] flinkbot commented on pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

2021-03-23 Thread GitBox
flinkbot commented on pull request #15339: URL: https://github.com/apache/flink/pull/15339#issuecomment-804676941 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-21330) Optimize the performance of PipelinedRegionSchedulingStrategy

2021-03-23 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21330: - Summary: Optimize the performance of PipelinedRegionSchedulingStrategy (was: Optimize the

[jira] [Closed] (FLINK-21809) PyFlink end-to-end test fails

2021-03-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21809. Resolution: Invalid Closing as it happened for flink-ci repository only. > PyFlink

[jira] [Updated] (FLINK-21448) Test Changelog State backend (Wrapper)

2021-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21448: --- Labels: pull-request-available (was: ) > Test Changelog State backend (Wrapper) >

[GitHub] [flink] curcur opened a new pull request #15339: [FLINK-21448] Randomize ITTests for delegating state backend

2021-03-23 Thread GitBox
curcur opened a new pull request #15339: URL: https://github.com/apache/flink/pull/15339 ## 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 them on

[jira] [Commented] (FLINK-20824) BlockingShuffleITCase. testSortMergeBlockingShuffle test failed with "Inconsistent availability: expected true"

2021-03-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306831#comment-17306831 ] Dawid Wysakowicz commented on FLINK-20824: -- Hey [~guoweima] [~kevin.cyj] any update on this

[GitHub] [flink] kezhuw commented on a change in pull request #15331: [FLINK-21626][core] Make RuntimeContext.jobID non-optional

2021-03-23 Thread GitBox
kezhuw commented on a change in pull request #15331: URL: https://github.com/apache/flink/pull/15331#discussion_r599316682 ## File path: flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java ## @@ -192,14 +193,16 @@ private void initCache(Set

[jira] [Updated] (FLINK-21731) Add benchmarks for DefaultScheduler's creation, scheduling and deploying

2021-03-23 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21731: - Description: We notice that {{DefaultScheduler#allocateSlotsAndDeploy}} is not covered in the

[jira] [Commented] (FLINK-21895) IncrementalAggregateJsonPlanTest.testIncrementalAggregate fail

2021-03-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306827#comment-17306827 ] Dawid Wysakowicz commented on FLINK-21895: -- Hey [~jark] [~godfreyhe] could you take a look? >

[jira] [Updated] (FLINK-21731) Add benchmarks for DefaultScheduler's creation, scheduling and deploying

2021-03-23 Thread Zhilong Hong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21731: - Summary: Add benchmarks for DefaultScheduler's creation, scheduling and deploying (was: Add

[jira] [Commented] (FLINK-21896) GroupAggregateJsonPlanTest.testDistinctAggCalls fail

2021-03-23 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306826#comment-17306826 ] Dawid Wysakowicz commented on FLINK-21896: -- Hey [~jark] [~godfreyhe] could you take a look? >

[jira] [Commented] (FLINK-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver

2021-03-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306823#comment-17306823 ] Yi Tang commented on FLINK-21921: - Actually, if the watch for retrieval begin after the updating (looks

[GitHub] [flink] HuangXingBo commented on pull request #15212: [FLINK-21628][python] Support Python UDAF in Tumbling Window

2021-03-23 Thread GitBox
HuangXingBo commented on pull request #15212: URL: https://github.com/apache/flink/pull/15212#issuecomment-804666733 @WeiZhong94 Thanks a lot for the review. I have addressed the comments at the latest commit. -- This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] xiangtao commented on a change in pull request #15332: [FLINK-21701][sql-client] Improve support "RESET key" statement in the SQL Client

2021-03-23 Thread GitBox
xiangtao commented on a change in pull request #15332: URL: https://github.com/apache/flink/pull/15332#discussion_r599311194 ## File path: flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/SessionContextTest.java ## @@ -153,6 +154,188 @@

[jira] [Assigned] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21923: --- Assignee: tartarus > SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the

[jira] [Closed] (FLINK-21918) Add execution.runtime-mode setter in StreamExecutionEnvironment

2021-03-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-21918. --- Resolution: Fixed Merged to master via 86685c4d3d3c1f886cc6f15d0d205d852bf61b8f > Add

[GitHub] [flink] dianfu closed pull request #15335: [FLINK-21918][python] Add execution.runtime-mode setter in StreamExecutionEnvironment

2021-03-23 Thread GitBox
dianfu closed pull request #15335: URL: https://github.com/apache/flink/pull/15335 -- 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, please

[GitHub] [flink] flinkbot commented on pull request #15338: [FLINK-21922][python] Fix partition_by in Over which doesn't work for expression DSL

2021-03-23 Thread GitBox
flinkbot commented on pull request #15338: URL: https://github.com/apache/flink/pull/15338#issuecomment-804664712 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] [Commented] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-03-23 Thread tartarus (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306820#comment-17306820 ] tartarus commented on FLINK-21923: -- [~jark] Please assign it to me, thanks > SplitAggregateRule will

[GitHub] [flink] dianfu commented on pull request #15335: [FLINK-21918][python] Add execution.runtime-mode setter in StreamExecutionEnvironment

2021-03-23 Thread GitBox
dianfu commented on pull request #15335: URL: https://github.com/apache/flink/pull/15335#issuecomment-804664574 @SteNicholas Thanks a lot for the review. Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Created] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

2021-03-23 Thread tartarus (Jira)
tartarus created FLINK-21923: Summary: SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time Key: FLINK-21923 URL: https://issues.apache.org/jira/browse/FLINK-21923

[jira] [Updated] (FLINK-21922) The method partition_by in Over doesn't work for expression dsl

2021-03-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21922: Summary: The method partition_by in Over doesn't work for expression dsl (was: The method partition_by

[jira] [Updated] (FLINK-21922) The method partition_by in Over doesn't work

2021-03-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21922: --- Labels: pull-request-available (was: ) > The method partition_by in Over doesn't work >

[GitHub] [flink] dianfu opened a new pull request #15338: [FLINK-21922][python] Fix partition_by in Over which doesn't work for expression DSL

2021-03-23 Thread GitBox
dianfu opened a new pull request #15338: URL: https://github.com/apache/flink/pull/15338 ## What is the purpose of the change *This pull request fixes partition_by in Over which doesn't work* ## Verifying this change This change added tests and can be verified as

[GitHub] [flink] cuibo01 commented on pull request #15115: [FLINK-21640]Job fails to be submitted in tenant scenario

2021-03-23 Thread GitBox
cuibo01 commented on pull request #15115: URL: https://github.com/apache/flink/pull/15115#issuecomment-804662422 @zentol can u review and merge the PR? thx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] cuibo01 commented on pull request #15115: [FLINK-21640]Job fails to be submitted in tenant scenario

2021-03-23 Thread GitBox
cuibo01 commented on pull request #15115: URL: https://github.com/apache/flink/pull/15115#issuecomment-804661475 @tillrohrmann @wangyang0918 can u review and merge the PR? thx -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-21922) The method partition_by in Over doesn't work

2021-03-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21922: Description: For the following example: {code} t = t_env.from_elements([(1, 1, "Hello")], ['a', 'b',

[jira] [Commented] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper

2021-03-23 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306807#comment-17306807 ] Kezhu Wang commented on FLINK-21626: [~roman_khachatryan] Thanks, I will. > Consider shaping newly

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

2021-03-23 Thread Kezhu Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306805#comment-17306805 ] Kezhu Wang commented on FLINK-21817: I guess we four are probably talking about two inconsistencies:

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

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802508808 ## CI report: * e09ac7a498542d5f2bb31ba9f02ad45fdb3499dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15248: [FLINK-21382][doc] Update documentation for standalone Flink on Kubernetes with standby JobManagers

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15248: URL: https://github.com/apache/flink/pull/15248#issuecomment-800773858 ## CI report: * 138d7fb66ca0375288960ce2fbca305c4f21d90b Azure:

[jira] [Comment Edited] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper

2021-03-23 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306802#comment-17306802 ] Roman Khachatryan edited comment on FLINK-21626 at 3/23/21, 6:36 AM: -

[jira] [Commented] (FLINK-21626) Consider shaping newly introduced RuntimeContext.getJobId to return JobID with no Optional wrapper

2021-03-23 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306802#comment-17306802 ] Roman Khachatryan commented on FLINK-21626: --- I've published a PR to make the JobID

[jira] [Closed] (FLINK-21892) Add documentation for the DESC statement syntax

2021-03-23 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21892. --- Fix Version/s: 1.13.0 Resolution: Fixed Fixed in master: cb338293d36a120c7962a1f3563df4b5e366cfed >

[GitHub] [flink] wuchong merged pull request #15325: [FLINK-21892][doc] Add documentation for the DESC statement syntax

2021-03-23 Thread GitBox
wuchong merged pull request #15325: URL: https://github.com/apache/flink/pull/15325 -- 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-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver

2021-03-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-21921: Description: The comment is not exactly accurate in case of JM restarting or ConfigMap watching

[jira] [Created] (FLINK-21922) The method partition_by in Over doesn't work

2021-03-23 Thread Dian Fu (Jira)
Dian Fu created FLINK-21922: --- Summary: The method partition_by in Over doesn't work Key: FLINK-21922 URL: https://issues.apache.org/jira/browse/FLINK-21922 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver

2021-03-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306795#comment-17306795 ] Yi Tang commented on FLINK-21921: - cc [~fly_in_gis] > Drop ADDED event in callback handler in

[jira] [Updated] (FLINK-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver

2021-03-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-21921: Description: The comment is not exactly accurate in case of JM restarting or ConfigMap

[jira] [Updated] (FLINK-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver

2021-03-23 Thread Yi Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-21921: Description: The comment is not exactly accurate in case of JM restarting or ConfigMap

[jira] [Created] (FLINK-21921) Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver

2021-03-23 Thread Yi Tang (Jira)
Yi Tang created FLINK-21921: --- Summary: Drop ADDED event in callback handler in KubernetesLeaderRetrievalDriver Key: FLINK-21921 URL: https://issues.apache.org/jira/browse/FLINK-21921 Project: Flink

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

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-802508808 ## CI report: * e09ac7a498542d5f2bb31ba9f02ad45fdb3499dc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15248: [FLINK-21382][doc] Update documentation for standalone Flink on Kubernetes with standby JobManagers

2021-03-23 Thread GitBox
flinkbot edited a comment on pull request #15248: URL: https://github.com/apache/flink/pull/15248#issuecomment-800773858 ## CI report: * 138d7fb66ca0375288960ce2fbca305c4f21d90b Azure:

[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-23 Thread GitBox
flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 33f5e95ff1020b26c602c44537f30cc890c07363 Azure:

[GitHub] [flink] xiangtao commented on a change in pull request #15332: [FLINK-21701][sql-client] Improve support "RESET key" statement in the SQL Client

2021-03-23 Thread GitBox
xiangtao commented on a change in pull request #15332: URL: https://github.com/apache/flink/pull/15332#discussion_r599292000 ## File path: flink-table/flink-sql-client/src/test/resources/sql/set.q ## @@ -104,3 +104,70 @@ Was expecting one of: "," ... !error + +# test

<    1   2   3   4   5   6