[GitHub] [flink] wangyang0918 commented on pull request #15248: [FLINK-21382][doc] Update documentation for standalone Flink on Kubernetes with standby JobManagers

wangyang0918 commented on pull request #15248: URL: https://github.com/apache/flink/pull/15248#issuecomment-804637452 @tillrohrmann Thanks for your review. Comments addressed. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] xintongsong commented on a change in pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

xintongsong commented on a change in pull request #15273: URL: https://github.com/apache/flink/pull/15273#discussion_r599286677 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java ## @@ -346,9 +346,6 @@ private MemorySegment

[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

flinkbot edited a comment on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-798900245 ## CI report: * 33f5e95ff1020b26c602c44537f30cc890c07363 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] kezhuw commented on pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

kezhuw commented on pull request #15273: URL: https://github.com/apache/flink/pull/15273#issuecomment-804631257 @tillrohrmann @xintongsong Hi all, I have done my round. Could you please take another look @tillrohrmann ? -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] kezhuw commented on a change in pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

kezhuw commented on a change in pull request #15273: URL: https://github.com/apache/flink/pull/15273#discussion_r599278435 ## File path: flink-core/src/test/java/org/apache/flink/core/memory/OffHeapUnsafeMemorySegmentTest.java ## @@ -58,4 +61,31 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #15325: [FLINK-21892][doc] Add documentation for the DESC statement syntax

flinkbot edited a comment on pull request #15325: URL: https://github.com/apache/flink/pull/15325#issuecomment-804069174 ## CI report: * c1ada244e40d521def1e2a27fe166e74de9e6a71 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15310: [FLINK-21330] Optimize the initialization of PipelinedRegionSchedulingStrategy

flinkbot edited a comment on pull request #15310: URL: https://github.com/apache/flink/pull/15310#issuecomment-803836704 ## CI report: * 6a135eef1fd9441748be8446fad28ef2eec23a95 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] kezhuw commented on a change in pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

kezhuw commented on a change in pull request #15273: URL: https://github.com/apache/flink/pull/15273#discussion_r599277345 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java ## @@ -346,9 +346,6 @@ private MemorySegment

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

wsry commented on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-804620175 @zhuzhurk Thanks for the review and comments, I have updated the PR. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot edited a comment on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

flinkbot edited a comment on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804610022 ## CI report: * fe8a261ff73f5e252902403d8d7c3e396420d6db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

flinkbot edited a comment on pull request #15336: URL: https://github.com/apache/flink/pull/15336#issuecomment-804609978 ## CI report: * 295036f53219c05b7ed3b662a95034dddb56f3b7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15310: [FLINK-21330] Optimize the initialization of PipelinedRegionSchedulingStrategy

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

[GitHub] [flink] flinkbot edited a comment on pull request #15228: [Flink-21910][resourcemanager] fix the check that whether JobLeaderIdService has been stated

flinkbot edited a comment on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-82897 ## CI report: * af9cc6e8c7cd7f07a695eb3c6232f314676b6e21 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-21685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306771#comment-17306771 ] Yang Wang commented on FLINK-21685: --- I have tested in a real K8s cluster and having the following

[jira] [Closed] (FLINK-21838) Retranslate "JDBC SQL Connector" page into Chinese

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

[GitHub] [flink] wuchong merged pull request #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

wuchong merged pull request #15254: URL: https://github.com/apache/flink/pull/15254 -- 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-18384) Translate "Elasticsearch SQL Connector" page into Chinese

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

[GitHub] [flink] wuchong merged pull request #15235: [FLINK-18384][docs] translate "Elasticsearch SQL Connector" page into Chinese

wuchong merged pull request #15235: URL: https://github.com/apache/flink/pull/15235 -- 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 #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

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

[GitHub] [flink] flinkbot commented on pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

flinkbot commented on pull request #15336: URL: https://github.com/apache/flink/pull/15336#issuecomment-804609978 ## CI report: * 295036f53219c05b7ed3b662a95034dddb56f3b7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Closed] (FLINK-21899) Introduce SOURCE_WATERMARK built-infunction to preserve watermark from source

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

[GitHub] [flink] flinkbot edited a comment on pull request #15334: [FLINK-21550][tests] Harden ZooKeeperHaServicesTest.testSimpleClose

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

[GitHub] [flink] flinkbot edited a comment on pull request #15318: [FLINK-21868][table-planner-blink]Support StreamExecLookupJoin json serialization/deserialization

flinkbot edited a comment on pull request #15318: URL: https://github.com/apache/flink/pull/15318#issuecomment-803958618 ## CI report: * 9864ccf9c46fc65d6957bcd1f29dad41496020e2 Azure:

[GitHub] [flink] wuchong merged pull request #15326: [FLINK-21899][table] Introduce SOURCE_WATERMARK built-in function to preserve watermark from source

wuchong merged pull request #15326: URL: https://github.com/apache/flink/pull/15326 -- 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 #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

flinkbot edited a comment on pull request #15254: URL: https://github.com/apache/flink/pull/15254#issuecomment-801102929 ## CI report: * 0050ab69f4302a2aac2de255f0f6d45213aacbfa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15228: [Flink-21910][resourcemanager] fix the check that whether JobLeaderIdService has been stated

flinkbot edited a comment on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-82897 ## CI report: * af9cc6e8c7cd7f07a695eb3c6232f314676b6e21 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15148: [FLINK-21731] Add benchmarks for DefaultScheduler#startScheduling

flinkbot edited a comment on pull request #15148: URL: https://github.com/apache/flink/pull/15148#issuecomment-796572621 ## CI report: * 25e912512943d29b15c8fa5a22adc5cf0e2294a1 Azure:

[jira] [Commented] (FLINK-19863) SQLClientHBaseITCase.testHBase failed with "java.io.IOException: Process failed due to timeout"

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

[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_r599258765 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/BatchShuffleReadBufferPool.java ## @@ -0,0 +1,275 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot commented on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

flinkbot commented on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804604377 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] flinkbot commented on pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

flinkbot commented on pull request #15336: URL: https://github.com/apache/flink/pull/15336#issuecomment-804604391 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] flinkbot edited a comment on pull request #15318: [FLINK-21868][table-planner-blink]Support StreamExecLookupJoin json serialization/deserialization

flinkbot edited a comment on pull request #15318: URL: https://github.com/apache/flink/pull/15318#issuecomment-803958618 ## CI report: * 9864ccf9c46fc65d6957bcd1f29dad41496020e2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15325: [FLINK-21892][doc] Add documentation for the DESC statement syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #15303: [FLINK-21713][table-api/table-planner] Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

flinkbot edited a comment on pull request #15303: URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784 ## CI report: * 94d1d572dbae58380df4f2d3385be984ef866165 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15235: [FLINK-18384][docs] translate "Elasticsearch SQL Connector" page into Chinese

flinkbot edited a comment on pull request #15235: URL: https://github.com/apache/flink/pull/15235#issuecomment-800130428 ## CI report: * ecc8a9a3399fdbcdd8b2797d8c11413c8dd705c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15148: [FLINK-21731] Add benchmarks for DefaultScheduler#startScheduling

flinkbot edited a comment on pull request #15148: URL: https://github.com/apache/flink/pull/15148#issuecomment-796572621 ## CI report: * 25e912512943d29b15c8fa5a22adc5cf0e2294a1 Azure:

[jira] [Updated] (FLINK-21920) Optimize DefaultScheduler#allocateSlots

[ https://issues.apache.org/jira/browse/FLINK-21920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhilong Hong updated FLINK-21920: - Description: Based on the scheduler benchmark introduced in FLINK-21731, we find that there

[jira] [Commented] (FLINK-21898) JobRetrievalITCase crash

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

[jira] [Commented] (FLINK-21745) JobMasterTest.testReconnectionAfterDisconnect hangs on azure

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

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

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

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

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

[GitHub] [flink] Thesharing commented on pull request #15148: [FLINK-21731] Add benchmarks for DefaultScheduler#startScheduling

Thesharing commented on pull request #15148: URL: https://github.com/apache/flink/pull/15148#issuecomment-804601511 @flinkbot run azure -- 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

[jira] [Commented] (FLINK-21745) JobMasterTest.testReconnectionAfterDisconnect hangs on azure

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

[GitHub] [flink] dianfu commented on pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

dianfu commented on pull request #15337: URL: https://github.com/apache/flink/pull/15337#issuecomment-804601164 cc @xintongsong -- 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

[jira] [Commented] (FLINK-21916) Allow OPERATOR and PYTHON ManagedMemoryUseCase to be used in the same operator

[ https://issues.apache.org/jira/browse/FLINK-21916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306748#comment-17306748 ] Dian Fu commented on FLINK-21916: - Thanks [~xintongsong] for the suggestion. It makes sense to me. Have

[jira] [Created] (FLINK-21920) Optimize DefaultScheduler#allocateSlots

Zhilong Hong created FLINK-21920: Summary: Optimize DefaultScheduler#allocateSlots Key: FLINK-21920 URL: https://issues.apache.org/jira/browse/FLINK-21920 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-21916) Allow OPERATOR and PYTHON ManagedMemoryUseCase to be used in the same operator

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

[GitHub] [flink] dianfu opened a new pull request #15337: [FLINK-21916] Allows multiple kinds of ManagedMemoryUseCase for the same operator

dianfu opened a new pull request #15337: URL: https://github.com/apache/flink/pull/15337 ## What is the purpose of the change *This pull request relaxes the restriction that multiple ManagedMemoryUseCase could no be used for the same operator, e.g. PYTHON and OPERATOR.* ##

[GitHub] [flink] zhuzhurk 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

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

[jira] [Commented] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306733#comment-17306733 ] Yingjie Cao commented on FLINK-20547: - [~pnowojski] I have opened a PR for this issue, could you

[GitHub] [flink] zhuzhurk 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

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

[jira] [Updated] (FLINK-20547) Batch job fails due to the exception in network stack

[ https://issues.apache.org/jira/browse/FLINK-20547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20547: --- Labels: pull-request-available test-stability (was: test-stability) > Batch job fails due

[GitHub] [flink] zhuzhurk 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

zhuzhurk commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599253364 ## 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 opened a new pull request #15336: [FLINK-20547][network] Fix inconsistent availability issue of LocalBufferPool

wsry opened a new pull request #15336: URL: https://github.com/apache/flink/pull/15336 ## What is the purpose of the change LocalBufferPool#checkAvailability may return wrong availability state of LocalBufferPool which may lead to the set of inconsistent availability state when

[GitHub] [flink] zhuzhurk 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

zhuzhurk commented on a change in pull request #15199: URL: https://github.com/apache/flink/pull/15199#discussion_r599248454 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionBuilder.java ## @@ -50,6 +52,12 @@

[GitHub] [flink] jiamo commented on pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

jiamo commented on pull request #14737: URL: https://github.com/apache/flink/pull/14737#issuecomment-804592812 My use-case: use flink-sql to read data from EMR managed hive (while the table content was s3 files and partition by day) -- This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on pull request #15325: [FLINK-21892][doc] Add documentation for the DESC statement syntax

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

[GitHub] [flink] flinkbot edited a comment on pull request #15335: [FLINK-21918][python] Add execution.runtime-mode setter in StreamExecutionEnvironment

flinkbot edited a comment on pull request #15335: URL: https://github.com/apache/flink/pull/15335#issuecomment-804539658 ## CI report: * 0897dd10b1cd025e2bd5445205d28214762c532f UNKNOWN * df9bffe66ce538cd63ccdd820f8fdc648318c6bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15303: [FLINK-21713][table-api/table-planner] Correct function CURRENT_TIMESTAMP/CURRENT_TIME/CURRENT_DATE/NOW/LOCALTIME/LOCALTIMESTAMP

flinkbot edited a comment on pull request #15303: URL: https://github.com/apache/flink/pull/15303#issuecomment-803399784 ## CI report: * 94d1d572dbae58380df4f2d3385be984ef866165 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15228: [Flink-21910][resourcemanager] fix the check that whether JobLeaderIdService has been stated

flinkbot edited a comment on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-82897 ## CI report: * af9cc6e8c7cd7f07a695eb3c6232f314676b6e21 Azure:

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

fsk119 commented on pull request #15332: URL: https://github.com/apache/flink/pull/15332#issuecomment-804567283 The title is a little strange? What about `Extend the "RESET" syntax in the SQL Client` or `Support "RESET key" statement in the SQL Client`? -- This is an automated message

[jira] [Closed] (FLINK-21919) JsonPlanTestBase should extends AbstractTestBase

[ https://issues.apache.org/jira/browse/FLINK-21919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-21919. Resolution: Invalid Already fixed. > JsonPlanTestBase should extends AbstractTestBase >

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #15335: [FLINK-21918][python] Add execution.runtime-mode setter in StreamExecutionEnvironment

flinkbot edited a comment on pull request #15335: URL: https://github.com/apache/flink/pull/15335#issuecomment-804539658 ## CI report: * 0897dd10b1cd025e2bd5445205d28214762c532f UNKNOWN * df9bffe66ce538cd63ccdd820f8fdc648318c6bb UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #15235: [FLINK-18384][docs] translate "Elasticsearch SQL Connector" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

flinkbot edited a comment on pull request #15254: URL: https://github.com/apache/flink/pull/15254#issuecomment-801102929 ## CI report: * 812416474a3730a7b54c33ad4ae399915df9777f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15228: [Flink-21910][resourcemanager] fix the check that whether JobLeaderIdService has been stated

flinkbot edited a comment on pull request #15228: URL: https://github.com/apache/flink/pull/15228#issuecomment-82897 ## CI report: * a43fac04009d1f872bc2bf68e1fd742bd005d4e8 Azure:

[jira] [Created] (FLINK-21919) JsonPlanTestBase should extends AbstractTestBase

Jingsong Lee created FLINK-21919: Summary: JsonPlanTestBase should extends AbstractTestBase Key: FLINK-21919 URL: https://issues.apache.org/jira/browse/FLINK-21919 Project: Flink Issue Type:

[GitHub] [flink] xinggit commented on pull request #15320: [FLINK-21903][docs-zh] Translate "Importing Flink into an IDE" page into Chinese

xinggit commented on pull request #15320: URL: https://github.com/apache/flink/pull/15320#issuecomment-804541399 cc @wuchong. could you help to review this? thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

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

[ https://issues.apache.org/jira/browse/FLINK-21918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21918: --- Labels: pull-request-available (was: ) > Add execution.runtime-mode setter in

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

flinkbot commented on pull request #15335: URL: https://github.com/apache/flink/pull/15335#issuecomment-804539658 ## CI report: * 0897dd10b1cd025e2bd5445205d28214762c532f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

flinkbot edited a comment on pull request #15254: URL: https://github.com/apache/flink/pull/15254#issuecomment-801102929 ## CI report: * 812416474a3730a7b54c33ad4ae399915df9777f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15235: [FLINK-18384][docs] translate "Elasticsearch SQL Connector" page into Chinese

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

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

flinkbot commented on pull request #15335: URL: https://github.com/apache/flink/pull/15335#issuecomment-804536016 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-20280) Support batch mode for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-20280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-20280: --- Labels: pull-request-available (was: ) > Support batch mode for Python DataStream API >

[GitHub] [flink] dianfu opened a new pull request #15335: [FLINK-20280][python] Add execution.runtime-mode setter in StreamExecutionEnvironment

dianfu opened a new pull request #15335: URL: https://github.com/apache/flink/pull/15335 ## What is the purpose of the change *This pull request adds execution.runtime-mode setter in StreamExecutionEnvironment.* ## Brief change log - *Introduce set_runtime_mode in

[jira] [Commented] (FLINK-21916) Allow OPERATOR and PYTHON ManagedMemoryUseCase to be used in the same operator

[ https://issues.apache.org/jira/browse/FLINK-21916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306696#comment-17306696 ] Xintong Song commented on FLINK-21916: -- {{ManagedMemoryUseCase}} are not intended to be exclusive

[jira] [Updated] (FLINK-21917) Add back missing zh docs

[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21917: Component/s: Table SQL / Ecosystem > Add back missing zh docs > > >

[jira] [Assigned] (FLINK-21917) Add back missing zh docs

[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21917: --- Assignee: jjiey > Add back missing zh docs > > > Key:

[GitHub] [flink] leonardBang commented on a change in pull request #15326: [FLINK-21899][table] Introduce SOURCE_WATERMARK built-in function to preserve watermark from source

leonardBang commented on a change in pull request #15326: URL: https://github.com/apache/flink/pull/15326#discussion_r599196385 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/stream/sql/TableSourceITCase.scala ## @@

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

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305961#comment-17305961 ] Qingsheng Ren edited comment on FLINK-21817 at 3/23/21, 2:07 AM: - Thanks

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

HuangXingBo commented on a change in pull request #15212: URL: https://github.com/apache/flink/pull/15212#discussion_r599193955 ## File path: flink-python/pyflink/fn_execution/operations.py ## @@ -406,6 +420,121 @@ def create_process_function(self, user_defined_aggs,

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

HuangXingBo commented on a change in pull request #15212: URL: https://github.com/apache/flink/pull/15212#discussion_r599193893 ## File path: flink-python/pyflink/fn_execution/coder_impl_fast.pyx ## @@ -107,8 +118,11 @@ cdef class

[jira] [Updated] (FLINK-21917) Add back missing zh docs

[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21917: --- Description: We lost some Chinese doc pages when migrate  doc website from Jekyll to Hugo in

[GitHub] [flink] jjiey commented on pull request #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

jjiey commented on pull request #15254: URL: https://github.com/apache/flink/pull/15254#issuecomment-804526509 > > @leonardBang please open ticket if you find missing pages > > I created https://issues.apache.org/jira/browse/FLINK-21917, @jjiey Do you want to work for this?

[jira] [Updated] (FLINK-21917) Add back missing zh docs

[ https://issues.apache.org/jira/browse/FLINK-21917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-21917: --- Description: We lost some Chinese doc pages when migrate from legacy doc website to current one in

[GitHub] [flink] xintongsong commented on a change in pull request #15273: [FLINK-21800][core] Guard MemorySegment against concurrent frees.

xintongsong commented on a change in pull request #15273: URL: https://github.com/apache/flink/pull/15273#discussion_r599192586 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java ## @@ -346,9 +346,6 @@ private MemorySegment

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

Dian Fu created FLINK-21918: --- Summary: Add execution.runtime-mode setter in StreamExecutionEnvironment Key: FLINK-21918 URL: https://issues.apache.org/jira/browse/FLINK-21918 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #15311: [FLINK-21189][runtime] Added support for concurrently caught exceptions to exception history

flinkbot edited a comment on pull request #15311: URL: https://github.com/apache/flink/pull/15311#issuecomment-803836803 ## CI report: * 0923b251ee47a8c70606e1c841a5cebbc229deb9 Azure:

[GitHub] [flink] leonardBang commented on pull request #15254: [FLINK-21838][docs] retranslate "JDBC SQL Connector" page into Chinese

leonardBang commented on pull request #15254: URL: https://github.com/apache/flink/pull/15254#issuecomment-804521916 > @leonardBang please open ticket if you find missing pages I created https://issues.apache.org/jira/browse/FLINK-21917, @jjiey Do you want to work for this? --

[jira] [Created] (FLINK-21917) Add back missing zh docs

Leonard Xu created FLINK-21917: -- Summary: Add back missing zh docs Key: FLINK-21917 URL: https://issues.apache.org/jira/browse/FLINK-21917 Project: Flink Issue Type: Bug Components:

[GitHub] [flink] Sunt-ing removed a comment on pull request #14976: [hotfix][docs] Typo in Chinese doc dev/execution/parallel.md

Sunt-ing removed a comment on pull request #14976: URL: https://github.com/apache/flink/pull/14976#issuecomment-792673752 @wuchong Hello, could you please review this simple PR? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

[GitHub] [flink] Sunt-ing removed a comment on pull request #14984: [FLINK-21438][doc] Broken links in content.zh/docs/concepts/flink-architecture.md

Sunt-ing removed a comment on pull request #14984: URL: https://github.com/apache/flink/pull/14984#issuecomment-792682851 @wuchong Could you help review this PR when you are free? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] Sunt-ing removed a comment on pull request #15111: [hotfix][javadoc] fix typos: paralelism->parallelism

Sunt-ing removed a comment on pull request #15111: URL: https://github.com/apache/flink/pull/15111#issuecomment-792672980 @zentol Hello, could you please review this simple PR? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message, please log on

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

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306669#comment-17306669 ] Jiangjie Qin commented on FLINK-21817: -- I think solution 1 and 2 [~renqs] mentioned do not conflict

[GitHub] [flink] flinkbot edited a comment on pull request #15333: Allow users to use fractional values for memory params

flinkbot edited a comment on pull request #15333: URL: https://github.com/apache/flink/pull/15333#issuecomment-804341952 ## CI report: * a4dc48c1a3ad8b6700132cfc455b4a2c1306fea8 UNKNOWN * 324b2fa7744cafdf5fc44aafe44a4105ed4f8a18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15313: [FLINK-19682] PoC for reworking the active time out alignment for checkpoints

flinkbot edited a comment on pull request #15313: URL: https://github.com/apache/flink/pull/15313#issuecomment-803870812 ## CI report: * ed604fbcd0cd08ff52cf4c1ca8311084b854c9a9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15311: [FLINK-21189][runtime] Added support for concurrently caught exceptions to exception history

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

  1   2   3   4   5   6   >