[jira] [Commented] (FLINK-21986) taskmanager native memory not release timely after restart

[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309212#comment-17309212 ] Yun Tang commented on FLINK-21986: -- Hi [~Feifan Wang], Flink community has ever come ac

[GitHub] [flink] zhuxiaoshang opened a new pull request #15383: [FLINK-21702][sql-client]Support option `sql-client.verbose` to print the exception stack

zhuxiaoshang opened a new pull request #15383: URL: https://github.com/apache/flink/pull/15383 … the exception stack ## What is the purpose of the change Support option `sql-client.verbose` to print the exception stack ## Brief change log *(for example:)*

[jira] [Updated] (FLINK-21989) Add a SupportsSourceWatermark ability interface

[ https://issues.apache.org/jira/browse/FLINK-21989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21989: - Description: FLINK-21899 added a dedicated function that can be used in watermark definitions.

[jira] [Created] (FLINK-21989) Add a SupportsSourceWatermark ability interface

Timo Walther created FLINK-21989: Summary: Add a SupportsSourceWatermark ability interface Key: FLINK-21989 URL: https://issues.apache.org/jira/browse/FLINK-21989 Project: Flink Issue Type: S

[jira] [Updated] (FLINK-18712) Flink RocksDB statebackend memory leak issue

[ https://issues.apache.org/jira/browse/FLINK-18712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-18712: - Attachment: flink-demo-master.tgz > Flink RocksDB statebackend memory leak issue >

[jira] [Updated] (FLINK-21989) Add a SupportsSourceWatermark ability interface

[ https://issues.apache.org/jira/browse/FLINK-21989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-21989: - Description: FLINK-21899 added a dedicated function that can be used in watermark definitions.

[jira] [Commented] (FLINK-21931) Watermark documentation needs to be fixed

[ https://issues.apache.org/jira/browse/FLINK-21931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309208#comment-17309208 ] Jark Wu commented on FLINK-21931: - IIUC, pipeline.auto-watermak-interval = 0 just disabl

[jira] [Commented] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309206#comment-17309206 ] zhuxiaoshang commented on FLINK-21702: -- [~jark]，yes i'm working on this issue > Su

[GitHub] [flink] flinkbot commented on pull request #15382: [FLINK-21915] Optimize Execution#finishPartitionsAndUpdateConsumers

flinkbot commented on pull request #15382: URL: https://github.com/apache/flink/pull/15382#issuecomment-807982016 ## CI report: * 0e09d893fa2373a2d81c88efa4221928029b32e3 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation

flinkbot edited a comment on pull request #15362: URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140 ## CI report: * e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] flinkbot edited a comment on pull request #15366: [FLINK-12828][sql-client] Support -f option with a sql script as input

flinkbot edited a comment on pull request #15366: URL: https://github.com/apache/flink/pull/15366#issuecomment-806388017 ## CI report: * d879f73ab948f4782455d18442095b360c7b8fbc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[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: * 0bad34b18eb4df5a424936adf386caaf8c9d5fb2 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21702) Support option `sql-client.verbose` to print the exception stack

[ https://issues.apache.org/jira/browse/FLINK-21702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309204#comment-17309204 ] Jark Wu commented on FLINK-21702: - Hi [~ZhuShang], FLINK-21462 has been resolved. Do you

[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: * 98c5f207e1d006b91be50df6ce1b3e8f45fc795b UNKNOWN * 3b6c434b676ee0d1aaad00e8ba1fa03c1ddc7f33 UNKNOWN * 0d6ada9ddd0847e4306de24b6466bf17581a

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

leonardBang commented on pull request #15303: URL: https://github.com/apache/flink/pull/15303#issuecomment-807981314 The [failed test](https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=15498&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=62110053-334f-5295-a0ab-80dd

[jira] [Commented] (FLINK-21699) SecurityUtils JaasModule make JVM dirty

[ https://issues.apache.org/jira/browse/FLINK-21699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309203#comment-17309203 ] tonychan commented on FLINK-21699: -- yes ， i see the uninstall  method  in SecurityUtils

[GitHub] [flink] KurtYoung commented on a change in pull request #15356: [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format

KurtYoung commented on a change in pull request #15356: URL: https://github.com/apache/flink/pull/15356#discussion_r602048462 ## File path: flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowSerializationSchema.java ## @@ -319,7 +323,12 @@ private static

[GitHub] [flink] zoucao commented on pull request #15267: [Flink-21738][table]use cache in module to reduce unnecessary method calls

zoucao commented on pull request #15267: URL: https://github.com/apache/flink/pull/15267#issuecomment-807976784 cc @wuchong, please have a look, if have a time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] flinkbot commented on pull request #15382: [FLINK-21915] Optimize Execution#finishPartitionsAndUpdateConsumers

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

[jira] [Updated] (FLINK-21915) Optimize Execution#finishPartitionsAndUpdateConsumers

[ https://issues.apache.org/jira/browse/FLINK-21915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21915: --- Labels: pull-request-available (was: ) > Optimize Execution#finishPartitionsAndUpdateConsum

[GitHub] [flink] hehuiyuan removed a comment on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

hehuiyuan removed a comment on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-806950041 @flinkbot re-run -- 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 s

[GitHub] [flink] Thesharing opened a new pull request #15382: [FLINK-21915] Optimize Execution#finishPartitionsAndUpdateConsumers

Thesharing opened a new pull request #15382: URL: https://github.com/apache/flink/pull/15382 ## What is the purpose of the change *Based on the scheduler benchmark PartitionReleaseInBatchJobBenchmark introduced in FLINK-20612, we find that there's another procedure that has O(N^2) c

[GitHub] [flink] hehuiyuan removed a comment on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

hehuiyuan removed a comment on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-807836449 @flinkbot re-run. -- 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 th

[GitHub] [flink] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation

flinkbot edited a comment on pull request #15362: URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140 ## CI report: * e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] leonardBang commented on pull request #15356: [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format

leonardBang commented on pull request #15356: URL: https://github.com/apache/flink/pull/15356#issuecomment-807967437 The failed test is not related to this PR, it caused by download dependency error and reported in https://issues.apache.org/jira/browse/FLINK-19705 -- This is an automated

[jira] [Commented] (FLINK-19705) Avro Confluent Schema Registry nightly end-to-end test: curl: (56) Recv failure: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309189#comment-17309189 ] Leonard Xu commented on FLINK-19705: another instance https://dev.azure.com/apache-

[GitHub] [flink] hehuiyuan commented on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

hehuiyuan commented on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-807961043 Hi @lirui-apache , is there anything to modify? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Commented] (FLINK-21880) UnalignedCheckpointRescaleITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309184#comment-17309184 ] Guowei Ma commented on FLINK-21880: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309182#comment-17309182 ] Guowei Ma commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309183#comment-17309183 ] Guowei Ma commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot edited a comment on pull request #15274: [FLINK-21829][Hive Connect]Fix to throw exception when custom hadoop conf path does not exist

flinkbot edited a comment on pull request #15274: URL: https://github.com/apache/flink/pull/15274#issuecomment-802519234 ## CI report: * 1fde497519066265b822d4f549ed1a2c4b7eab85 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-21828) Add an AWS-λ example to stateful-playground

[ https://issues.apache.org/jira/browse/FLINK-21828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21828: --- Labels: pull-request-available (was: ) > Add an AWS-λ example to stateful-playground >

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309181#comment-17309181 ] Guowei Ma commented on FLINK-18356: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink-statefun-playground] tzulitai opened a new pull request #10: [FLINK-21828] Add a tutorial for AWS Lambda function deployments

tzulitai opened a new pull request #10: URL: https://github.com/apache/flink-statefun-playground/pull/10 A code-snippet style kind of tutorial for serving StateFun functions using AWS Lambda + AWS API Gateway. The tutorial is NOT intended for: - Showing the overall architecture of

[GitHub] [flink] flinkbot edited a comment on pull request #15381: [hotfix] remove redundant config#setCheckpointStorage.

flinkbot edited a comment on pull request #15381: URL: https://github.com/apache/flink/pull/15381#issuecomment-807938151 ## CI report: * bff9265a6472c2c6f22dc051d127d66250b9529d Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 9221c14030c5b5bdc6863c843617e414c9e007a1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

wangyang0918 edited a comment on pull request #15286: URL: https://github.com/apache/flink/pull/15286#issuecomment-807936115 @xintongsong Thanks for your comments. Even though the standby only stops the terminated pod currently, but it is not a by-design behavior. The standby ResourceManag

[GitHub] [flink] flinkbot edited a comment on pull request #15380: [FLINK-21929][statebackend][tests] Ensure to dispose keyed state backend to avoid core dump

flinkbot edited a comment on pull request #15380: URL: https://github.com/apache/flink/pull/15380#issuecomment-807932205 ## CI report: * 70111230d77afbddae61716a0bf8a3d3dd1df2d2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15381: [hotfix] remove redundant config#setCheckpointStorage.

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

[GitHub] [flink] flinkbot edited a comment on pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

flinkbot edited a comment on pull request #15379: URL: https://github.com/apache/flink/pull/15379#issuecomment-807932155 ## CI report: * 71ed4cfa0e1cad0b5b6ccb4f4395eca4a9e5a412 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15356: [FLINK-21947][csv] Support TIMESTAMP_LTZ type in CSV format

flinkbot edited a comment on pull request #15356: URL: https://github.com/apache/flink/pull/15356#issuecomment-805653657 ## CI report: * 6e7b8098b8e373ee264e9d84f88a9673ccad93ac Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 9221c14030c5b5bdc6863c843617e414c9e007a1 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-17707) Support configuring replica of Deployment based HA setups

[ https://issues.apache.org/jira/browse/FLINK-17707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-17707: -- Fix Version/s: (was: 1.13.0) 1.14.0 > Support configuring replica of Deployment

[GitHub] [flink] wangyang0918 commented on pull request #15286: [FLINK-17707][k8s] Support configuring replicas of JobManager deployment when HA enabled

wangyang0918 commented on pull request #15286: URL: https://github.com/apache/flink/pull/15286#issuecomment-807936115 @xintongsong Thanks for your comments. Even though the standby only stop the terminated pod currently, but it is not a by-design behavior. The standby ResourceManagers shou

[jira] [Commented] (FLINK-20928) KafkaSourceReaderTest.testOffsetCommitOnCheckpointComplete:189->pollUntil:270 » Timeout

[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309163#comment-17309163 ] Guowei Ma commented on FLINK-20928: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309162#comment-17309162 ] Guowei Ma commented on FLINK-20329: --- https://dev.azure.com/apache-flink/apache-flink/_

[GitHub] [flink] flinkbot commented on pull request #15380: [FLINK-21929][statebackend][tests] Ensure to dispose keyed state backend to avoid core dump

flinkbot commented on pull request #15380: URL: https://github.com/apache/flink/pull/15380#issuecomment-807932205 ## CI report: * 70111230d77afbddae61716a0bf8a3d3dd1df2d2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot commented on pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

flinkbot commented on pull request #15379: URL: https://github.com/apache/flink/pull/15379#issuecomment-807932155 ## CI report: * 71ed4cfa0e1cad0b5b6ccb4f4395eca4a9e5a412 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] flinkbot edited a comment on pull request #15378: [FLINK-19646][python] Introduce StreamExecutionEnvironment.from_source to support FLIP-27 source in Python DataStream API

flinkbot edited a comment on pull request #15378: URL: https://github.com/apache/flink/pull/15378#issuecomment-807926906 ## CI report: * b0eba4eb93330cf1342fac5bd6ad0fdc2280c9c2 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15374: [FLINK-21978][table-planner] Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

flinkbot edited a comment on pull request #15374: URL: https://github.com/apache/flink/pull/15374#issuecomment-807049695 ## CI report: * fdd603989b2627f6744bdc585cf76dd813c05d81 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xintongsong commented on pull request #15286: [FLINK-17707][k8s] Support configuring replicas of JobManager deployment when HA enabled

xintongsong commented on pull request #15286: URL: https://github.com/apache/flink/pull/15286#issuecomment-807931142 Thanks for preparing the PR, @wangyang0918. I'm afraid we are not ready for this feature ATM. As FLINK-21667 reveals, currently a standby RM can perform modifying acti

[GitHub] [flink] flinkbot commented on pull request #15381: [hotfix] remove redundant config#setCheckpointStorage.

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

[GitHub] [flink] est08zw opened a new pull request #15381: [hotfix] remove redundant config#setCheckpointStorage.

est08zw opened a new pull request #15381: URL: https://github.com/apache/flink/pull/15381 ## What is the purpose of the change remove redundant config#setCheckpointStorage. ## Brief change log - remove redundant config#setCheckpointStorage. ## Verifying th

[jira] [Updated] (FLINK-21667) Standby RM might remove resources from Kubernetes

[ https://issues.apache.org/jira/browse/FLINK-21667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-21667: - Fix Version/s: (was: 1.12.3) (was: 1.13.0) 1.14.0

[jira] [Commented] (FLINK-16404) Avoid caching buffers for blocked input channels before barrier alignment

[ https://issues.apache.org/jira/browse/FLINK-16404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309158#comment-17309158 ] jinghaihang commented on FLINK-16404: - Hi,Zhijiang，I encountered a problem： With th

[jira] [Updated] (FLINK-21929) flink-statebackend-rocksdb crashes with Error occurred in starting fork

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

[GitHub] [flink] flinkbot commented on pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

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

[GitHub] [flink] flinkbot commented on pull request #15380: [FLINK-21929][statebackend][tests] Ensure to dispose keyed state backend to avoid core dump

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

[GitHub] [flink] flinkbot commented on pull request #15378: [FLINK-19646][python] Introduce StreamExecutionEnvironment.from_source to support FLIP-27 source in Python DataStream API

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

[GitHub] [flink] flinkbot edited a comment on pull request #15374: [FLINK-21978][table-planner] Disable cast conversion between Numeric type and TIMESTAMP_LTZ type

flinkbot edited a comment on pull request #15374: URL: https://github.com/apache/flink/pull/15374#issuecomment-807049695 ## CI report: * fdd603989b2627f6744bdc585cf76dd813c05d81 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * c9206c42c7aa2aeeac5d09d885ab9e64c312ea0f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15314: [FLINK-21332][runtime] Optimize releasing result partitions in RegionPartitionReleaseStrategy

flinkbot edited a comment on pull request #15314: URL: https://github.com/apache/flink/pull/15314#issuecomment-803903444 ## CI report: * d69e745e1e5a11209d8eacc00281df878915e0b9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

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

flinkbot edited a comment on pull request #15161: URL: https://github.com/apache/flink/pull/15161#issuecomment-797177953 ## CI report: * d3f59e302b9860d49ce79252aeb8bd1decaeeabf UNKNOWN * 6fc6cc9a2e6c26e9e8fa62b481237231394078eb Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] Myasuka opened a new pull request #15380: [Flink-21929][statebackend][tests] Ensure to dispose keyed state backend to avoid core dump

Myasuka opened a new pull request #15380: URL: https://github.com/apache/flink/pull/15380 ## What is the purpose of the change This change includes two commits: `[FLINK-21929][rocksdb][tests] Ensure to dispose state backend in StateBackendTestBase#testKeyGroupedInternalPriorityQue

[jira] [Updated] (FLINK-21986) taskmanager native memory not release timely after restart

[ https://issues.apache.org/jira/browse/FLINK-21986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-21986: Description: I run a regular join job with flink_1.12.1 , and find taskmanager native memory not

[jira] [Closed] (FLINK-21987) testRequestKvStateOfWrongJob failed

[ https://issues.apache.org/jira/browse/FLINK-21987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-21987. - Fix Version/s: 1.13.0 Resolution: Duplicate > testRequestKvStateOfWrongJob failed > -

[jira] [Comment Edited] (FLINK-21954) Test failures occur due to the test not waiting for the ExecutionGraph to be created

[ https://issues.apache.org/jira/browse/FLINK-21954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309154#comment-17309154 ] Guowei Ma edited comment on FLINK-21954 at 3/26/21, 4:18 AM: -

[jira] [Updated] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

[ https://issues.apache.org/jira/browse/FLINK-21984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-21984: --- Labels: pull-request-available (was: ) > Change precision argument from optional to require

[GitHub] [flink] leonardBang opened a new pull request #15379: [FLINK-21984][table-planner] Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

leonardBang opened a new pull request #15379: URL: https://github.com/apache/flink/pull/15379 ## What is the purpose of the change * This pull request change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision) ## Brief change log - change

[jira] [Closed] (FLINK-21988) testRequestKvStateWithIrrelevantRegistration fail

[ https://issues.apache.org/jira/browse/FLINK-21988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma closed FLINK-21988. - Fix Version/s: 1.13.0 Resolution: Duplicate > testRequestKvStateWithIrrelevantRegistration fail >

[jira] [Comment Edited] (FLINK-21954) Test failures occur due to the test not waiting for the ExecutionGraph to be created

[ https://issues.apache.org/jira/browse/FLINK-21954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309154#comment-17309154 ] Guowei Ma edited comment on FLINK-21954 at 3/26/21, 4:16 AM: -

[jira] [Commented] (FLINK-21954) Test failures occur due to the test not waiting for the ExecutionGraph to be created

[ https://issues.apache.org/jira/browse/FLINK-21954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309154#comment-17309154 ] Guowei Ma commented on FLINK-21954: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Created] (FLINK-21988) testRequestKvStateWithIrrelevantRegistration fail

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

[jira] [Created] (FLINK-21987) testRequestKvStateOfWrongJob failed

Guowei Ma created FLINK-21987: - Summary: testRequestKvStateOfWrongJob failed Key: FLINK-21987 URL: https://issues.apache.org/jira/browse/FLINK-21987 Project: Flink Issue Type: Bug Compo

[jira] [Updated] (FLINK-21974) Support to match quoted values for 'SET key=val' statement

[ https://issues.apache.org/jira/browse/FLINK-21974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21974: Summary: Support to match quoted values for 'SET key=val' statement (was: Enable to match pattern `SET ke

[jira] [Closed] (FLINK-21974) Enable to match pattern `SET key= 'test val'` in SetOperationParseStrategy

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

[jira] [Updated] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-21859: Affects Version/s: 1.12.0 > Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c4

[GitHub] [flink] wuchong closed pull request #15372: [FLINK-21974][table-api] Enable to match pattern `SET key= 'test val'…

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

[jira] [Updated] (FLINK-21859) Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c419297d active"

[ https://issues.apache.org/jira/browse/FLINK-21859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-21859: Fix Version/s: 1.13.0 > Batch job fails due to "Could not mark slot 61a637e3977c58a0e6b73533c41929

[jira] [Commented] (FLINK-21963) ReactiveModelITCase.testScaleDownOnTaskManagerLoss failed

[ https://issues.apache.org/jira/browse/FLINK-21963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309146#comment-17309146 ] Guowei Ma commented on FLINK-21963: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Assigned] (FLINK-21985) Support Explain Query/Modifcation syntax in Calcite Parser

[ https://issues.apache.org/jira/browse/FLINK-21985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21985: --- Assignee: WeiNan Zhao > Support Explain Query/Modifcation syntax in Calcite Parser > --

[jira] [Created] (FLINK-21986) taskmanager native memory not release timely after restart

Feifan Wang created FLINK-21986: --- Summary: taskmanager native memory not release timely after restart Key: FLINK-21986 URL: https://issues.apache.org/jira/browse/FLINK-21986 Project: Flink Issu

[GitHub] [flink] flinkbot commented on pull request #15378: [FLINK-19646][python] Introduce StreamExecutionEnvironment.from_source to support FLIP-27 source in Python DataStream API

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

[jira] [Assigned] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19646: --- Assignee: Dian Fu > StreamExecutionEnvironment support new Source interface based on FLIP-27 >

[jira] [Updated] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19646: Fix Version/s: 1.13.0 > StreamExecutionEnvironment support new Source interface based on FLIP-27 > ---

[jira] [Commented] (FLINK-21853) Running HA per-job cluster (rocks, non-incremental) end-to-end test could not finished in 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-21853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309144#comment-17309144 ] Guowei Ma commented on FLINK-21853: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Updated] (FLINK-21853) Running HA per-job cluster (rocks, non-incremental) end-to-end test could not finished in 900 seconds

[ https://issues.apache.org/jira/browse/FLINK-21853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-21853: -- Affects Version/s: 1.13.0 > Running HA per-job cluster (rocks, non-incremental) end-to-end test could

[GitHub] [flink] wangyang0918 commented on pull request #15286: [FLINK-17707][k8s] Support configuring replicas of JobManager deployment when HA enabled

wangyang0918 commented on pull request #15286: URL: https://github.com/apache/flink/pull/15286#issuecomment-807917892 cc @xintongsong Could you please have a look? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[jira] [Updated] (FLINK-19646) StreamExecutionEnvironment support new Source interface based on FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-19646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19646: --- Labels: pull-request-available (was: ) > StreamExecutionEnvironment support new Source inte

[GitHub] [flink] dianfu opened a new pull request #15378: [FLINK-19646][python] Introduce StreamExecutionEnvironment.from_source to support FLIP-27 source in Python DataStream API

dianfu opened a new pull request #15378: URL: https://github.com/apache/flink/pull/15378 ## What is the purpose of the change *This pull request introduce StreamExecutionEnvironment.from_source to support FLIP-27 source in Python DataStream API* ## Verifying this chang

[GitHub] [flink] flinkbot edited a comment on pull request #15377: [hotfix][formats] Fix exception message

flinkbot edited a comment on pull request #15377: URL: https://github.com/apache/flink/pull/15377#issuecomment-807910235 ## CI report: * 2b7bb78d19695eaec50e0d26ec1a45f1e453de2f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15362: [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation

flinkbot edited a comment on pull request #15362: URL: https://github.com/apache/flink/pull/15362#issuecomment-805817140 ## CI report: * Unknown: [CANCELED](TBD) * e456383b0cafdeb67e8f37785783b3b35a6eaf47 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620

[GitHub] [flink] flinkbot edited a comment on pull request #15317: [FLINK-20562][SQL-Client][Table-Api] Improvements,Support ExplainDetail…

flinkbot edited a comment on pull request #15317: URL: https://github.com/apache/flink/pull/15317#issuecomment-803958506 ## CI report: * 237b5abd3985fa2b33f96bed39576d2435570f0f Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #15314: [FLINK-21332][runtime] Optimize releasing result partitions in RegionPartitionReleaseStrategy

flinkbot edited a comment on pull request #15314: URL: https://github.com/apache/flink/pull/15314#issuecomment-803903444 ## CI report: * d69e745e1e5a11209d8eacc00281df878915e0b9 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Commented] (FLINK-21985) Support Explain Query/Modifcation syntax in Calcite Parser

[ https://issues.apache.org/jira/browse/FLINK-21985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309141#comment-17309141 ] WeiNan Zhao commented on FLINK-21985: - hello,please assign this issue to me,thank yo

[jira] [Created] (FLINK-21985) Support Explain Query/Modifcation syntax in Calcite Parser

Shengkai Fang created FLINK-21985: - Summary: Support Explain Query/Modifcation syntax in Calcite Parser Key: FLINK-21985 URL: https://issues.apache.org/jira/browse/FLINK-21985 Project: Flink

[GitHub] [flink] Thesharing commented on pull request #15314: [FLINK-21332][runtime] Optimize releasing result partitions in RegionPartitionReleaseStrategy

Thesharing commented on pull request #15314: URL: https://github.com/apache/flink/pull/15314#issuecomment-807912254 > I would suggest to introduce the assumption that one `IntermediateResultPartition` can have one only `ConsumerVertexGroup`(indicating that one `IntermediateDataSet` can hav

[jira] [Commented] (FLINK-21063) ElasticsearchSinkITCase fails while setting up ES cluster

[ https://issues.apache.org/jira/browse/FLINK-21063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309137#comment-17309137 ] Guowei Ma commented on FLINK-21063: --- just for report https://dev.azure.com/apache-flin

[jira] [Assigned] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

[ https://issues.apache.org/jira/browse/FLINK-21984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-21984: --- Assignee: Leonard Xu > Change precision argument from optional to required in > TO_TIMESTAMP_LTZ(n

[jira] [Updated] (FLINK-21984) Change precision argument from optional to required in TO_TIMESTAMP_LTZ(numeric, precision)

[ https://issues.apache.org/jira/browse/FLINK-21984?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-21984: Fix Version/s: 1.13.0 > Change precision argument from optional to required in > TO_TIMESTAMP_LTZ(numeric

  1   2   3   4   5   6   >