[GitHub] [flink] gaoyunhaii commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

gaoyunhaii commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066787 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066726 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066440 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wuchong commented on pull request #15285: [FLINK-21847][flink-sql-parser] Introduce DESC grammar in sql parser

wuchong commented on pull request #15285: URL: https://github.com/apache/flink/pull/15285#issuecomment-803253292 Could you add desc tests in `TableEnvironmentTest#testDescribeTableOrView` and `table.q`? -- This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598066194 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

gaoyunhaii commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598065309 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598065608 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598065049 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064923 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064490 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064437 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

gaoyunhaii commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064285 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598064204 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

gaoyunhaii commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063877 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063730 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063366 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598063014 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] gaoyunhaii commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

gaoyunhaii commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r597604195 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598062812 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,353 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598062094 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadIOExecutor.java ## @@ -0,0 +1,127 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598062016 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadIOExecutor.java ## @@ -0,0 +1,127 @@ +/* + * Licensed to the

[GitHub] [flink] wsry commented on a change in pull request #15199: [FLINK-20740][network] Introduce a separated buffer pool and a separated thread pool for sort-merge blocking shuffle

wsry commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r598061122 ## File path: flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java ## @@ -513,6 +513,30 @@

[jira] [Commented] (FLINK-21726) Fix checkpoint stuck

[ https://issues.apache.org/jira/browse/FLINK-21726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305300#comment-17305300 ] Yun Tang commented on FLINK-21726: -- [~trohrmann] sorry for late reply as apache Jira failed to send any

[GitHub] [flink] flinkbot edited a comment on pull request #15295: [FLINK-21885] [documentation] Fixed Minor Typo in JDBC Batch Execution Criteria

flinkbot edited a comment on pull request #15295: URL: https://github.com/apache/flink/pull/15295#issuecomment-803149898 ## CI report: * 49a3b4d311d6d537841b034aeb55dbc13d0011b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15284: [FLINK-21869][table-planner-blink] Support StreamExecTemporalSort json serialization/deserialization

flinkbot edited a comment on pull request #15284: URL: https://github.com/apache/flink/pull/15284#issuecomment-802759741 ## CI report: * 62b5b42a2e46ae8563bd90bbbe0a4cb4bf2f9805 Azure:

[GitHub] [flink] wuchong closed pull request #15255: [FLINK-21466][table] Add SQL Client default mode value embedded

wuchong closed pull request #15255: URL: https://github.com/apache/flink/pull/15255 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[jira] [Closed] (FLINK-21466) Make "embedded" parameter optional when start sql-client.sh

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

[GitHub] [flink] flinkbot edited a comment on pull request #15284: [FLINK-21869][table-planner-blink] Support StreamExecTemporalSort json serialization/deserialization

flinkbot edited a comment on pull request #15284: URL: https://github.com/apache/flink/pull/15284#issuecomment-802759741 ## CI report: * 62b5b42a2e46ae8563bd90bbbe0a4cb4bf2f9805 Azure:

[jira] [Commented] (FLINK-21640) Job fails to be submitted in tenant scenario

[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305293#comment-17305293 ] Bo Cui commented on FLINK-21640: [~rmetzger] can u review and merge the PR? > Job fails to be submitted

[jira] [Issue Comment Deleted] (FLINK-21640) Job fails to be submitted in tenant scenario

[ https://issues.apache.org/jira/browse/FLINK-21640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Cui updated FLINK-21640: --- Comment: was deleted (was: [~knaufk] hi，can u rerun PR ci for me? because in my pc, all tests are ok) >

[GitHub] [flink] wuchong commented on pull request #15255: [FLINK-21466][table] Add SQL Client default mode value embedded

wuchong commented on pull request #15255: URL: https://github.com/apache/flink/pull/15255#issuecomment-803235462 Merging... -- 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.

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

cuibo01 removed a comment on pull request #15115: URL: https://github.com/apache/flink/pull/15115#issuecomment-797203314 in my pc， they were successful  -- This is an

[jira] [Closed] (FLINK-21816) Support StreamExecMatch json ser/de

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

[GitHub] [flink] godfreyhe closed pull request #15272: [FLINK-21816][table-planner-blink] Suport json ser/de for StreamExecMatch

godfreyhe closed pull request #15272: URL: https://github.com/apache/flink/pull/15272 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] zuston commented on a change in pull request #15131: [FLINK-21700][yarn]Allow to disable fetching Hadoop delegation token on Yarn

zuston commented on a change in pull request #15131: URL: https://github.com/apache/flink/pull/15131#discussion_r598042163 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java ## @@ -344,6 +344,13 @@

[jira] [Closed] (FLINK-21602) Creation of ExecutionGraph happens in main thread

[ https://issues.apache.org/jira/browse/FLINK-21602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-21602. - Resolution: Fixed Fixed via bc0f2c698b c4545e06a5 8b5e172118 2f4813d77a c7a4203b43 ce55b21d53

[GitHub] [flink] tillrohrmann closed pull request #15251: [FLINK-21602] Make ExecutionGraph creation asynchronous in the AdaptiveScheduler

tillrohrmann closed pull request #15251: URL: https://github.com/apache/flink/pull/15251 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15251: [FLINK-21602] Make ExecutionGraph creation asynchronous in the AdaptiveScheduler

flinkbot edited a comment on pull request #15251: URL: https://github.com/apache/flink/pull/15251#issuecomment-801034655 ## CI report: * c139b92469406395fb73133a5d364197c775db53 UNKNOWN * 2c5e3e6a74f78156daa40158ea34fa83d7f7507b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15295: [FLINK-21885] [documentation] Fixed Minor Typo in JDBC Batch Execution Criteria

flinkbot edited a comment on pull request #15295: URL: https://github.com/apache/flink/pull/15295#issuecomment-803149898 ## CI report: * 49a3b4d311d6d537841b034aeb55dbc13d0011b1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15255: [FLINK-21466][table] Add SQL Client default mode value embedded

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

[jira] [Commented] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305213#comment-17305213 ] Austin Cawley-Edwards commented on FLINK-21844: --- Does this mean a user must configure

[GitHub] [flink] flinkbot commented on pull request #15295: [FLINK-21885] [documentation] Fixed Minor Typo in JDBC Batch Execution Criteria

flinkbot commented on pull request #15295: URL: https://github.com/apache/flink/pull/15295#issuecomment-803149898 ## CI report: * 49a3b4d311d6d537841b034aeb55dbc13d0011b1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Resolved] (FLINK-21875) GSRKinesisPubsubClient is not compiling in IntelliJ

[ https://issues.apache.org/jira/browse/FLINK-21875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-21875. --- Resolution: Fixed > GSRKinesisPubsubClient is not compiling in IntelliJ >

[GitHub] [flink] dannycranmer merged pull request #15290: [FLINK-21875][hotfix] Fix compilation error in IntelliJ for GSR test

dannycranmer merged pull request #15290: URL: https://github.com/apache/flink/pull/15290 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service,

[GitHub] [flink] flinkbot commented on pull request #15295: [FLINK-21885] [documentation] Fixed Minor Typo in JDBC Batch Execution Criteria

flinkbot commented on pull request #15295: URL: https://github.com/apache/flink/pull/15295#issuecomment-803144925 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-21885) Minor Typo Fix in JDBC Connector Documentation

[ https://issues.apache.org/jira/browse/FLINK-21885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21885: --- Labels: pull-request-available (was: ) > Minor Typo Fix in JDBC Connector Documentation >

[GitHub] [flink] rionmonster opened a new pull request #15295: [FLINK-21885] [documentation] Fixed Minor Typo in JDBC Batch Execution Criteria

rionmonster opened a new pull request #15295: URL: https://github.com/apache/flink/pull/15295 ## Contribution Checklist ## 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

[GitHub] [flink] flinkbot edited a comment on pull request #15291: [FLINK-19607][table-runtime-blink] Implement streaming window TopN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

flinkbot edited a comment on pull request #15097: URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662 ## CI report: * a3b522f30f4d14a0085ae101c579e4779cbea740 Azure:

[jira] [Created] (FLINK-21885) Minor Typo Fix in JDBC Connector Documentation

Rion Williams created FLINK-21885: - Summary: Minor Typo Fix in JDBC Connector Documentation Key: FLINK-21885 URL: https://issues.apache.org/jira/browse/FLINK-21885 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #15290: [FLINK-21875][hotfix] Fix compilation error in IntelliJ for GSR test

flinkbot edited a comment on pull request #15290: URL: https://github.com/apache/flink/pull/15290#issuecomment-802870157 ## CI report: * 0b9951558f600d9f5c5d75dbdb7be0e25bb6a879 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15284: [FLINK-21869][table-planner-blink] Support StreamExecTemporalSort json serialization/deserialization

flinkbot edited a comment on pull request #15284: URL: https://github.com/apache/flink/pull/15284#issuecomment-802759741 ## CI report: * 62b5b42a2e46ae8563bd90bbbe0a4cb4bf2f9805 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15253: [FLINK-21808][hive] Support DQL/DML in HiveParser

flinkbot edited a comment on pull request #15253: URL: https://github.com/apache/flink/pull/15253#issuecomment-801069817 ## CI report: * ec83cc270a636e01c8a79d98b3b24287ca94ac17 Azure:

[GitHub] [flink] bytesandwich commented on a change in pull request #15049: [FLINK-21190][runtime-web] Expose exception history

bytesandwich commented on a change in pull request #15049: URL: https://github.com/apache/flink/pull/15049#discussion_r597950834 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/SerializableAccessExecutionGraph.java ## @@ -0,0 +1,27 @@ +/* + *

[GitHub] [flink] flinkbot edited a comment on pull request #15294: [POC][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot edited a comment on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803058203 ## CI report: * 560cd2c04d7c7c34eef08ceedb28c7526f826081 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15251: [FLINK-21602] Make ExecutionGraph creation asynchronous in the AdaptiveScheduler

flinkbot edited a comment on pull request #15251: URL: https://github.com/apache/flink/pull/15251#issuecomment-801034655 ## CI report: * c139b92469406395fb73133a5d364197c775db53 UNKNOWN * 7611fe80ef64ab5192e5317140b54bc42ea26433 Azure:

[GitHub] [flink] flinkbot commented on pull request #15294: [POC][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot commented on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803058203 ## CI report: * 560cd2c04d7c7c34eef08ceedb28c7526f826081 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15286: [FLINK-17707][k8s] Support configuring replicas of JobManager deployment when HA enabled

flinkbot edited a comment on pull request #15286: URL: https://github.com/apache/flink/pull/15286#issuecomment-802797427 ## CI report: * 519d96d5ddc563c22a19a6222fa2242cca01f24f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15287: [FLINK-21831][state][changelog] Add missing delegation of KeyGroupedInternalPriorityQueue

flinkbot edited a comment on pull request #15287: URL: https://github.com/apache/flink/pull/15287#issuecomment-802817754 ## CI report: * 0b8432eac9da8ad15e07bfe8d18d422cd726a467 Azure:

[jira] [Updated] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21884: --- Description: In Flink 1.13 (and older versions), TaskManager failures stall the processing

[jira] [Updated] (FLINK-21884) Reduce TaskManager failure detection time

[ https://issues.apache.org/jira/browse/FLINK-21884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-21884: --- Description: In Flink 1.13 (and older versions), TaskManager failures stall the processing

[jira] [Created] (FLINK-21884) Reduce TaskManager failure detection time

Robert Metzger created FLINK-21884: -- Summary: Reduce TaskManager failure detection time Key: FLINK-21884 URL: https://issues.apache.org/jira/browse/FLINK-21884 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #15288: [FLINK-21874][coordination] Ignore outdated slot allocation confirmations

flinkbot edited a comment on pull request #15288: URL: https://github.com/apache/flink/pull/15288#issuecomment-802817863 ## CI report: * 670448a172e317fa702faeceb5840dd5108b990e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

flinkbot edited a comment on pull request #15221: URL: https://github.com/apache/flink/pull/15221#issuecomment-799620682 ## CI report: * 47a54bcefdc0b43e459c2b523bb6e268968156ec Azure:

[GitHub] [flink] flinkbot commented on pull request #15294: [POC][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

flinkbot commented on pull request #15294: URL: https://github.com/apache/flink/pull/15294#issuecomment-803047996 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] AHeise opened a new pull request #15294: [POC][streaming] Omit pointwise connections from checkpointing in unaligned checkpoints.

AHeise opened a new pull request #15294: URL: https://github.com/apache/flink/pull/15294 ## 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] [Created] (FLINK-21883) Introduce cooldown period into adaptive scheduler

Robert Metzger created FLINK-21883: -- Summary: Introduce cooldown period into adaptive scheduler Key: FLINK-21883 URL: https://issues.apache.org/jira/browse/FLINK-21883 Project: Flink Issue

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

flinkbot edited a comment on pull request #15206: URL: https://github.com/apache/flink/pull/15206#issuecomment-798969998 ## CI report: * a80d78f1dfe51b986de1e76302dfcda0ceb403f9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15251: [FLINK-21602] Make ExecutionGraph creation asynchronous in the AdaptiveScheduler

flinkbot edited a comment on pull request #15251: URL: https://github.com/apache/flink/pull/15251#issuecomment-801034655 ## CI report: * 18076d2113c8639b640fba6369d10a0993c81143 Azure:

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

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * daaafe6b7f398f863b36b09a0b681b9c80a17d60 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15292: [DOC]fix hive dim doc replace o to order

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

[GitHub] [flink] flinkbot edited a comment on pull request #15255: [FLINK-21466][table] Add SQL Client default mode value embedded

flinkbot edited a comment on pull request #15255: URL: https://github.com/apache/flink/pull/15255#issuecomment-801213454 ## CI report: * 29e293bf86909abefc536ba679977c358ada106c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15207: [FLINK-21650] Skip KGs not belonging to this backend on restore (instead of failing)

flinkbot edited a comment on pull request #15207: URL: https://github.com/apache/flink/pull/15207#issuecomment-798972797 ## CI report: * 64bdd07ba6f7a80a352b04c6fd8741f3d04ecec1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14948: [FLINK-21333][coordination] Add StopWithSavepoint state to declarative scheduler

flinkbot edited a comment on pull request #14948: URL: https://github.com/apache/flink/pull/14948#issuecomment-779946654 ## CI report: * 097472900d4be5c87466bf7678aa506f6fd5d463 UNKNOWN * cd53481ec9b55a82ba3357109729305d062a6b97 Azure:

[jira] [Updated] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-21844: -- Description: I believe we should not automatically change the maxParallelism

[GitHub] [flink] flinkbot edited a comment on pull request #15255: [FLINK-21466][table] Add SQL Client default mode value embedded

flinkbot edited a comment on pull request #15255: URL: https://github.com/apache/flink/pull/15255#issuecomment-801213454 ## CI report: * 29e293bf86909abefc536ba679977c358ada106c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15251: [FLINK-21602] Make ExecutionGraph creation asynchronous in the AdaptiveScheduler

flinkbot edited a comment on pull request #15251: URL: https://github.com/apache/flink/pull/15251#issuecomment-801034655 ## CI report: * 18076d2113c8639b640fba6369d10a0993c81143 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

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

[GitHub] [flink] flinkbot edited a comment on pull request #15293: [FLINK-21814] [Exception] Add the error info of the Exception

flinkbot edited a comment on pull request #15293: URL: https://github.com/apache/flink/pull/15293#issuecomment-802897040 ## CI report: * de5d205a7612eed50341c53aa82ac13e890206a2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15291: [FLINK-19607][table-runtime-blink] Implement streaming window TopN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #15221: [FLINK-17012][streaming] 'RUNNING' state split into 'RUNNING' and 'RE…

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

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

flinkbot edited a comment on pull request #15097: URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662 ## CI report: * 0b21a13558fa9c2e9bb66137dfab9919e980f89f Azure:

[jira] [Commented] (FLINK-10672) Task stuck while writing output to flink

[ https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305035#comment-17305035 ] Kyle Weaver commented on FLINK-10672: - I tried upgrading to Flink 1.12.1 and this problem no longer

[GitHub] [flink] flinkbot edited a comment on pull request #15284: [FLINK-21869][table-planner-blink] Support StreamExecTemporalSort json serialization/deserialization

flinkbot edited a comment on pull request #15284: URL: https://github.com/apache/flink/pull/15284#issuecomment-802759741 ## CI report: * 60296191dbf6f79566a7671e4525a45a86141011 Azure:

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15152: [FLINK-20625][pubsub,e2e] Add Google Cloud Pub/Sub source connector in accordance with FLIP-27

flinkbot edited a comment on pull request #15152: URL: https://github.com/apache/flink/pull/15152#issuecomment-796646752 ## CI report: * cc5f788c74c24467fd25b907888afbf448992749 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

flinkbot edited a comment on pull request #15097: URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662 ## CI report: * 0b21a13558fa9c2e9bb66137dfab9919e980f89f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15285: [FLINK-21847][flink-sql-parser] Introduce DESC grammar in sql parser

flinkbot edited a comment on pull request #15285: URL: https://github.com/apache/flink/pull/15285#issuecomment-802759840 ## CI report: * d7865d94cd80e126bc0c2e69036ac43e5da0a729 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15097: [FLINK-21506] [mesos] Option for mesos task user

flinkbot edited a comment on pull request #15097: URL: https://github.com/apache/flink/pull/15097#issuecomment-791407662 ## CI report: * 0b21a13558fa9c2e9bb66137dfab9919e980f89f Azure:

[jira] [Assigned] (FLINK-21844) Do not auto-configure maxParallelism when setting "scheduler-mode: reactive"

[ https://issues.apache.org/jira/browse/FLINK-21844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards reassigned FLINK-21844: - Assignee: Austin Cawley-Edwards > Do not auto-configure maxParallelism

[GitHub] [flink-statefun-playground] igalshilman opened a new pull request #5: [21882] Add Python greeter example

igalshilman opened a new pull request #5: URL: https://github.com/apache/flink-statefun-playground/pull/5 copied from the `README.md`: # The Greeter Example This is a simple example of a stateful functions application implemented in `Python`. In this example, we

[jira] [Created] (FLINK-21882) Create a Python based greeter example

Igal Shilman created FLINK-21882: Summary: Create a Python based greeter example Key: FLINK-21882 URL: https://issues.apache.org/jira/browse/FLINK-21882 Project: Flink Issue Type: Task

[GitHub] [flink] flinkbot edited a comment on pull request #15255: [FLINK-21466][table] Add SQL Client default mode value embedded

flinkbot edited a comment on pull request #15255: URL: https://github.com/apache/flink/pull/15255#issuecomment-801213454 ## CI report: * 29e293bf86909abefc536ba679977c358ada106c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15291: [FLINK-19607][table-runtime-blink] Implement streaming window TopN operator

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

[GitHub] [flink] flinkbot edited a comment on pull request #15133: [FLINK-21621] [table-planner] Support TIMESTAMP_LTZ arithmetic

flinkbot edited a comment on pull request #15133: URL: https://github.com/apache/flink/pull/15133#issuecomment-795031750 ## CI report: * b632dd2590c925fde69788f1599ea2ba720faed1 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15140: [FLINK-20628][connectors/rabbitmq2] RabbitMQ connector using new connector API

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

[jira] [Closed] (FLINK-21785) Support StreamExecCorrelate json serde

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

  1   2   3   4   5   6   >