[GitHub] [flink] flinkbot edited a comment on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

flinkbot edited a comment on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-787621304 ## CI report: * a1687a0edd159a5b8be339a59c08a79ddfee5069 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

flinkbot edited a comment on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-779315285 ## CI report: * f80b97c479ec82663e971553c54c8a6cda3122ff UNKNOWN * 8584b9ca7b9cf29f0f845aafe422f356e068cfe6 UNKNOWN *

[jira] [Commented] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293477#comment-17293477 ] Dian Fu commented on FLINK-21552: - Thanks [~xintongsong] for the analysis. Agree with you. I think we

[GitHub] [flink] rmetzger commented on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

rmetzger commented on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-788701091 @XComp I pushed a new version of this change, it is still work in progress because some tests are missing.

[jira] [Updated] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21552: Description: If there is exception thrown in createPythonExecutionEnvironment, [the job will

[jira] [Updated] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21552: Description: If there is exception thrown in 

[jira] [Assigned] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-21552: Assignee: Xintong Song > The managed memory was not released if exception was thrown in

[GitHub] [flink] curcur commented on pull request #14943: [FLINK-21354] Introduce ChangelogStateBackend to delegate state access

curcur commented on pull request #14943: URL: https://github.com/apache/flink/pull/14943#issuecomment-788699250 @rkhachatryan Hey Roman, I believe I've addressed most of your comments except two: 1. "Flag in API" we discussed yesterday 2. Introduce test interface for

[GitHub] [flink] flinkbot commented on pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

flinkbot commented on pull request #15056: URL: https://github.com/apache/flink/pull/15056#issuecomment-788698094 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] [Assigned] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-21552: --- Assignee: (was: Dian Fu) > The managed memory was not released if exception was thrown in >

[jira] [Updated] (FLINK-21128) Rethink how Kubernetes interfaces with our docker image

[ https://issues.apache.org/jira/browse/FLINK-21128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21128: --- Labels: pull-request-available (was: ) > Rethink how Kubernetes interfaces with our docker

[GitHub] [flink] gaoyunhaii closed pull request #14831: [FLINK-21086][runtime][checkpoint] CheckpointBarrierHandler Insert barriers for channels received EndOfPartition

gaoyunhaii closed pull request #14831: URL: https://github.com/apache/flink/pull/14831 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] wangyang0918 opened a new pull request #15056: [FLINK-21128][k8s] Introduce dedicated scripts for native K8s integration

wangyang0918 opened a new pull request #15056: URL: https://github.com/apache/flink/pull/15056 ## What is the purpose of the change Currently, the native Kubernetes integration assembles a java command that is passed to the docker-script, which first does some magical stuff

[GitHub] [flink] gaoyunhaii commented on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

gaoyunhaii commented on pull request #15055: URL: https://github.com/apache/flink/pull/15055#issuecomment-788690935 Hi Piotr @pnowojski , could you have another look on this PR ? Now the implementation is changed to holding the upstream tasks. Also the first three commits is

[GitHub] [flink] flinkbot commented on pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

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

[GitHub] [flink] gaoyunhaii opened a new pull request #15055: [FLINK-21086][runtime][checkpoint] Support checkpoint alignment with finished input channels

gaoyunhaii opened a new pull request #15055: URL: https://github.com/apache/flink/pull/15055 ## What is the purpose of the change This PR makes `CheckpointBarrierHandler` support alignment after some input channels have received EndOfPartition. Based on the discussion under

[GitHub] [flink] flinkbot edited a comment on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

flinkbot edited a comment on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785717193 ## CI report: * c04248fcbfc45360e5e8111e35b24390471d5d72 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14878: [FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization

flinkbot edited a comment on pull request #14878: URL: https://github.com/apache/flink/pull/14878#issuecomment-773880848 ## CI report: * 7eed4a448147c00eb56b70e588eaa770a473996a UNKNOWN * 0656ccf0bc8833314a41d6fcf0f0227821f8f5af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and Node

flinkbot edited a comment on pull request #14791: URL: https://github.com/apache/flink/pull/14791#issuecomment-768926023 ## CI report: * f8a7a7bb160d9db1c23557eb2a112ed018b94d52 Azure:

[jira] [Commented] (FLINK-21519) SQLClientHBaseITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293454#comment-17293454 ] Dawid Wysakowicz commented on FLINK-21519: --

[jira] [Assigned] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-19682: -- Assignee: (was: Nicholas Jiang) > Actively timeout checkpoint barriers on the

[jira] [Comment Edited] (FLINK-19682) Actively timeout checkpoint barriers on the inputs

[ https://issues.apache.org/jira/browse/FLINK-19682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292033#comment-17292033 ] Piotr Nowojski edited comment on FLINK-19682 at 3/2/21, 7:17 AM: - Hey

[GitHub] [flink] flinkbot edited a comment on pull request #15005: [FLINK-21298][table] Support 'USE MODULES' syntax both in SQL parser, TableEnvironment and SQL CLI

flinkbot edited a comment on pull request #15005: URL: https://github.com/apache/flink/pull/15005#issuecomment-785063045 ## CI report: * 9c55937b18787dc4817c939be841554396cf8659 Azure:

[jira] [Updated] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21552: - Component/s: Runtime / Coordination > The managed memory was not released if exception was

[jira] [Updated] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21552: - Priority: Major (was: Critical) > The managed memory was not released if exception was thrown

[jira] [Assigned] (FLINK-21168) Add support for general python group window aggregate function in Physical Rule and Node

[ https://issues.apache.org/jira/browse/FLINK-21168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-21168: Assignee: Huang Xingbo > Add support for general python group window aggregate function

[jira] [Commented] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293422#comment-17293422 ] Xintong Song commented on FLINK-21552: -- BTW, I think this issue only affects when the job tries to

[GitHub] [flink] flinkbot edited a comment on pull request #15005: [FLINK-21298][table] Support 'USE MODULES' syntax both in SQL parser, TableEnvironment and SQL CLI

flinkbot edited a comment on pull request #15005: URL: https://github.com/apache/flink/pull/15005#issuecomment-785063045 ## CI report: * 9c55937b18787dc4817c939be841554396cf8659 Azure:

[GitHub] [flink] LadyForest commented on pull request #15005: [FLINK-21298][table] Support 'USE MODULES' syntax both in SQL parser, TableEnvironment and SQL CLI

LadyForest commented on pull request #15005: URL: https://github.com/apache/flink/pull/15005#issuecomment-788662635 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] rmetzger commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

rmetzger commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r585302773 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java ## @@ -1021,203 +220,20 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

flinkbot edited a comment on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-774606892 ## CI report: * 49853366d3df7cc034c975b3fde4aa6b71bb0d90 Azure:

[jira] [Commented] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293418#comment-17293418 ] Xintong Song commented on FLINK-21552: -- Thanks [~dian.fu], I think the problem in the following

[jira] [Updated] (FLINK-21135) Reactive Mode: Change Adaptive Scheduler to set infinite parallelism in JobGraph

[ https://issues.apache.org/jira/browse/FLINK-21135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21135: --- Fix Version/s: 1.13.0 > Reactive Mode: Change Adaptive Scheduler to set infinite

[jira] [Updated] (FLINK-21135) Reactive Mode: Change Adaptive Scheduler to set infinite parallelism in JobGraph

[ https://issues.apache.org/jira/browse/FLINK-21135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21135: --- Summary: Reactive Mode: Change Adaptive Scheduler to set infinite parallelism in JobGraph

[jira] [Updated] (FLINK-21202) Introduce TimeWindow and CountWindow in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-21202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-21202: - Description: Introduce TimeWindow, CountWindow and corresponding coders. (was: Now, when the

[jira] [Assigned] (FLINK-21202) Introduce TimeWindow and CountWindow in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-21202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-21202: Assignee: Huang Xingbo > Introduce TimeWindow and CountWindow in PyFlink >

[jira] [Resolved] (FLINK-20964) Introduce PythonStreamGroupWindowAggregateOperator

[ https://issues.apache.org/jira/browse/FLINK-20964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo resolved FLINK-20964. -- Resolution: Resolved Merged into master via 25664c66b8e1afc54a82066626dd12f988b6bd21 >

[jira] [Assigned] (FLINK-20964) Introduce PythonStreamGroupWindowAggregateOperator

[ https://issues.apache.org/jira/browse/FLINK-20964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-20964: Assignee: Huang Xingbo > Introduce PythonStreamGroupWindowAggregateOperator >

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21553: Description: See

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21553: Attachment: screenshot-1.png > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21553: Labels: test-stability (was: ) > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[jira] [Updated] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

[ https://issues.apache.org/jira/browse/FLINK-21553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21553: Priority: Critical (was: Major) > WindowDistinctAggregateITCase#testHopWindow_Cube is unstable >

[jira] [Created] (FLINK-21553) WindowDistinctAggregateITCase#testHopWindow_Cube is unstable

Jark Wu created FLINK-21553: --- Summary: WindowDistinctAggregateITCase#testHopWindow_Cube is unstable Key: FLINK-21553 URL: https://issues.apache.org/jira/browse/FLINK-21553 Project: Flink Issue

[jira] [Created] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

Dian Fu created FLINK-21552: --- Summary: The managed memory was not released if exception was thrown in createPythonExecutionEnvironment Key: FLINK-21552 URL: https://issues.apache.org/jira/browse/FLINK-21552

[jira] [Updated] (FLINK-21552) The managed memory was not released if exception was thrown in createPythonExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-21552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-21552: Fix Version/s: 1.13.0 > The managed memory was not released if exception was thrown in >

[GitHub] [flink] HuangXingBo closed pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

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

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

[ https://issues.apache.org/jira/browse/FLINK-21103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293379#comment-17293379 ] Guowei Ma commented on FLINK-21103: ---

[GitHub] [flink] crazyzhou commented on pull request #14890: [FLINK-21178][Runtime/Checkpointing] Task failure should trigger master hook's reset()

crazyzhou commented on pull request #14890: URL: https://github.com/apache/flink/pull/14890#issuecomment-788638526 > @crazyzhou Thanks for the patch. It looks that the unit test has format issue that failed the CI. Can you fix that. Otherwise the patch LGTM. @becketqin I have fixed

[jira] [Created] (FLINK-21551) FlinkKafkaProducerITCase.testHappyPath fail

Guowei Ma created FLINK-21551: - Summary: FlinkKafkaProducerITCase.testHappyPath fail Key: FLINK-21551 URL: https://issues.apache.org/jira/browse/FLINK-21551 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-21550) ZooKeeperHaServicesTest.testSimpleClose fail

[ https://issues.apache.org/jira/browse/FLINK-21550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21550: -- Description:

[jira] [Created] (FLINK-21550) ZooKeeperHaServicesTest.testSimpleClose fail

Guowei Ma created FLINK-21550: - Summary: ZooKeeperHaServicesTest.testSimpleClose fail Key: FLINK-21550 URL: https://issues.apache.org/jira/browse/FLINK-21550 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293373#comment-17293373 ] Guowei Ma commented on FLINK-17510: ---

[jira] [Commented] (FLINK-21475) StateWithExecutionGraph.suspend fails with IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-21475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293367#comment-17293367 ] Guowei Ma commented on FLINK-21475: ---

[jira] [Commented] (FLINK-21537) SavepointITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293365#comment-17293365 ] Guowei Ma commented on FLINK-21537: ---

[jira] [Commented] (FLINK-21428) AdaptiveSchedulerSlotSharingITCase.testSchedulingOfJobRequiringSlotSharing fail

[ https://issues.apache.org/jira/browse/FLINK-21428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293362#comment-17293362 ] Guowei Ma commented on FLINK-21428: ---

[GitHub] [flink] flinkbot edited a comment on pull request #15053: [hotfix][runtime] Add job ID to RuntimeContext

flinkbot edited a comment on pull request #15053: URL: https://github.com/apache/flink/pull/15053#issuecomment-788288713 ## CI report: * d8506749d4423f5683c7ee2b76ea505c4aa99c69 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

flinkbot edited a comment on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785717193 ## CI report: * 32fb1418983569f3e1b30f3a8109bc89c7738c32 Azure:

[GitHub] [flink-statefun] tzulitai closed pull request #200: [FLINK-21422][docs] Migrate docs to Hugo

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

[GitHub] [flink-statefun] tzulitai closed pull request #204: [FLINK-21530] Precompute TypeName's canonical representation

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

[GitHub] [flink] flinkbot edited a comment on pull request #15051: [FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializat

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

[GitHub] [flink] flinkbot edited a comment on pull request #15028: [FLINK-21115][python] Add AggregatingState and corresponding StateDescriptor for Python DataStream API

flinkbot edited a comment on pull request #15028: URL: https://github.com/apache/flink/pull/15028#issuecomment-786507942 ## CI report: * 5496089c7d3960826e2071a93a957c037eb05abc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15018: [FLINK-21460][table api] Use Configuration to create TableEnvironment

flinkbot edited a comment on pull request #15018: URL: https://github.com/apache/flink/pull/15018#issuecomment-785717193 ## CI report: * 32fb1418983569f3e1b30f3a8109bc89c7738c32 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and Node

flinkbot edited a comment on pull request #14791: URL: https://github.com/apache/flink/pull/14791#issuecomment-768926023 ## CI report: * 6812a3558513535d3f9adf2e2eca4c951b31a34c Azure:

[jira] [Updated] (FLINK-21515) SourceStreamTaskTest.testStopWithSavepointShouldNotInterruptTheSource is failing

[ https://issues.apache.org/jira/browse/FLINK-21515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-21515: -- Fix Version/s: (was: 1.12.2) 1.12.3 Change fix version from 1.12.2 to 1.12.3 since the

[GitHub] [flink] fsk119 commented on a change in pull request #14962: [FLINK-18789][sql-client] Use TableEnvironment#executeSql method to execute insert statement in sql client

fsk119 commented on a change in pull request #14962: URL: https://github.com/apache/flink/pull/14962#discussion_r585232054 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java ## @@ -751,17 +751,28 @@

[GitHub] [flink] fsk119 commented on a change in pull request #14962: [FLINK-18789][sql-client] Use TableEnvironment#executeSql method to execute insert statement in sql client

fsk119 commented on a change in pull request #14962: URL: https://github.com/apache/flink/pull/14962#discussion_r585232054 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java ## @@ -751,17 +751,28 @@

[GitHub] [flink] flinkbot edited a comment on pull request #15051: [FLINK-20379][connector/kafka] Update KafkaRecordDeserializationSchema to enable reuse of DeserializationSchema and KafkaDeserializat

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

[GitHub] [flink] flinkbot edited a comment on pull request #15028: [FLINK-21115][python] Add AggregatingState and corresponding StateDescriptor for Python DataStream API

flinkbot edited a comment on pull request #15028: URL: https://github.com/apache/flink/pull/15028#issuecomment-786507942 ## CI report: * 5496089c7d3960826e2071a93a957c037eb05abc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and Node

flinkbot edited a comment on pull request #14791: URL: https://github.com/apache/flink/pull/14791#issuecomment-768926023 ## CI report: * 6812a3558513535d3f9adf2e2eca4c951b31a34c Azure:

[jira] [Updated] (FLINK-21524) Improve the stability of scheduler benchmarks

[ https://issues.apache.org/jira/browse/FLINK-21524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-21524: Priority: Critical (was: Major) > Improve the stability of scheduler benchmarks >

[jira] [Assigned] (FLINK-21524) Improve the stability of scheduler benchmarks

[ https://issues.apache.org/jira/browse/FLINK-21524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-21524: --- Assignee: Zhilong Hong > Improve the stability of scheduler benchmarks >

[GitHub] [flink] flinkbot edited a comment on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

flinkbot edited a comment on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-787621304 ## CI report: * d7ed05fef321d57aeba59c33927db5021d3db845 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

flinkbot edited a comment on pull request #14816: URL: https://github.com/apache/flink/pull/14816#issuecomment-770164177 ## CI report: * 8e01d37ab94d0b54c3e0fb1bc4d643036145042d Azure:

[jira] [Closed] (FLINK-21509) "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time

[ https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21509. - Fix Version/s: 1.13.0 Resolution: Fixed > "w.start" returns "1970-01-01" when used with Pandas

[jira] [Commented] (FLINK-21509) "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time

[ https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293324#comment-17293324 ] Wei Zhong commented on FLINK-21509: --- Fixed via f00da5561075990ea200f168bcdd0fa5b084bb41 > "w.start"

[GitHub] [flink] WeiZhong94 merged pull request #15027: [FLINK-21509][python] Add 'withProcessingTime()' method call when creating proctime slide window assigner in 'StreamExecPythonGroupWindowAggrega

WeiZhong94 merged pull request #15027: URL: https://github.com/apache/flink/pull/15027 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] WeiZhong94 commented on pull request #15027: [FLINK-21509][python] Add 'withProcessingTime()' method call when creating proctime slide window assigner in 'StreamExecPythonGroupWindowA

WeiZhong94 commented on pull request #15027: URL: https://github.com/apache/flink/pull/15027#issuecomment-788549982 The e2e is timeout and is not related to this PR. Will merge this one first. This is an automated message

[GitHub] [flink] HuangXingBo commented on pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

HuangXingBo commented on pull request #14775: URL: https://github.com/apache/flink/pull/14775#issuecomment-788549281 The failed test has been reported in [FLINK-21147](https://issues.apache.org/jira/browse/FLINK-21147) which is not related to this PR

[jira] [Commented] (FLINK-21147) Resuming Savepoint (file, async, no parallelism change) fails with UnknownHostException

[ https://issues.apache.org/jira/browse/FLINK-21147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293319#comment-17293319 ] Huang Xingbo commented on FLINK-21147: --

[GitHub] [flink] xintongsong commented on a change in pull request #15047: [FLINK-21502][coordination] Reduce frequency of global re-allocate re…

xintongsong commented on a change in pull request #15047: URL: https://github.com/apache/flink/pull/15047#discussion_r585209847 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/AbstractFineGrainedSlotManagerITCase.java ## @@

[GitHub] [flink] flinkbot edited a comment on pull request #15048: [FLINK-21477][table-planner-blink] Lookup joins now deal with intermediate table scans containing just the table source correctly

flinkbot edited a comment on pull request #15048: URL: https://github.com/apache/flink/pull/15048#issuecomment-787621304 ## CI report: * d7ed05fef321d57aeba59c33927db5021d3db845 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14878: [FLINK-21245][table-planner-blink] Support StreamExecCalc json serialization/deserialization

flinkbot edited a comment on pull request #14878: URL: https://github.com/apache/flink/pull/14878#issuecomment-773880848 ## CI report: * 7eed4a448147c00eb56b70e588eaa770a473996a UNKNOWN * d87084638f2714de24bfc578c88f852eda0613ee Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14816: [FLINK-21202][python] Introduce TimeWindow and CountWindow in PyFlink

flinkbot edited a comment on pull request #14816: URL: https://github.com/apache/flink/pull/14816#issuecomment-770164177 ## CI report: * 8e01d37ab94d0b54c3e0fb1bc4d643036145042d Azure:

[jira] [Updated] (FLINK-21482) Support grouping set syntax for Window TVF based aggregation

[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21482: Parent: FLINK-19604 Issue Type: Sub-task (was: Improvement) > Support grouping set syntax for

[jira] [Updated] (FLINK-21253) Support grouping set syntax for GroupWindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-21253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21253: Parent: (was: FLINK-19604) Issue Type: New Feature (was: Sub-task) > Support grouping set

[jira] [Updated] (FLINK-21482) Support grouping set syntax for Window TVF based aggregation

[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21482: Summary: Support grouping set syntax for Window TVF based aggregation (was: Support grouping set syntax

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21482: Component/s: Table SQL / API > Support grouping set syntax for WindowAggregate >

[jira] [Updated] (FLINK-21482) Support grouping set syntax for WindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21482: Priority: Major (was: Minor) > Support grouping set syntax for WindowAggregate >

[jira] [Closed] (FLINK-21482) Support grouping set syntax for WindowAggregate

[ https://issues.apache.org/jira/browse/FLINK-21482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-21482. --- Fix Version/s: 1.13.0 Assignee: Andy Resolution: Fixed Fixed in master:

[GitHub] [flink] wuchong merged pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

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

[GitHub] [flink] wuchong commented on pull request #15003: [FLINK-21482][table-planner-blink] Support grouping set syntax for WindowAggregate

wuchong commented on pull request #15003: URL: https://github.com/apache/flink/pull/15003#issuecomment-788538991 The e2e is timeout and is not related to this PR. Will merge this one first. This is an automated message

[jira] [Commented] (FLINK-20254) HiveTableSourceITCase.testStreamPartitionReadByCreateTime times out

[ https://issues.apache.org/jira/browse/FLINK-20254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293308#comment-17293308 ] Jark Wu commented on FLINK-20254: -

[GitHub] [flink] HuangXingBo commented on a change in pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

HuangXingBo commented on a change in pull request #14775: URL: https://github.com/apache/flink/pull/14775#discussion_r569215043 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/PythonStreamGroupWindowAggregateOperator.java ##

[GitHub] [flink] flinkbot edited a comment on pull request #14791: [FLINK-21168][python][table-planner-blink] Add support for general python group window aggregate function in Physical Rule and Node

flinkbot edited a comment on pull request #14791: URL: https://github.com/apache/flink/pull/14791#issuecomment-768926023 ## CI report: * 6812a3558513535d3f9adf2e2eca4c951b31a34c Azure:

[GitHub] [flink-statefun] tzulitai commented on pull request #200: [FLINK-21422][docs] Migrate docs to Hugo

tzulitai commented on pull request #200: URL: https://github.com/apache/flink-statefun/pull/200#issuecomment-788531510 Looks good to merge! Will merge this and update the buildbot now. This is an automated message from the

[GitHub] [flink] WeiZhong94 commented on a change in pull request #14775: [FLINK-20964][python] Introduce PythonStreamGroupWindowAggregateOperator

WeiZhong94 commented on a change in pull request #14775: URL: https://github.com/apache/flink/pull/14775#discussion_r568385212 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/aggregate/PythonStreamGroupWindowAggregateOperator.java ##

[jira] [Closed] (FLINK-21180) Move the state module from 'pyflink.common' to 'pyflink.datastream'

[ https://issues.apache.org/jira/browse/FLINK-21180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21180. - Assignee: Wei Zhong Resolution: Fixed > Move the state module from 'pyflink.common' to

[jira] [Commented] (FLINK-21180) Move the state module from 'pyflink.common' to 'pyflink.datastream'

[ https://issues.apache.org/jira/browse/FLINK-21180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293302#comment-17293302 ] Wei Zhong commented on FLINK-21180: --- Merged via 6c998024e97d02a6a94c34c1e1fdd432d29aa122 > Move the

[jira] [Assigned] (FLINK-21501) Sync Chinese documentation with FLINK-21343

[ https://issues.apache.org/jira/browse/FLINK-21501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-21501: --- Assignee: zl (was: Zizhou L) > Sync Chinese documentation with FLINK-21343 >

[jira] [Assigned] (FLINK-21501) Sync Chinese documentation with FLINK-21343

[ https://issues.apache.org/jira/browse/FLINK-21501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-21501: --- Assignee: Zizhou L > Sync Chinese documentation with FLINK-21343 >

  1   2   3   4   >