[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

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

[GitHub] [flink] flinkbot commented on pull request #16531: [FLINK-23204] Provide StateBackends access to MailboxExecutor

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

[GitHub] [flink] flinkbot edited a comment on pull request #16273: [FLINK-18464][Runtime] when namespaceSerializer is different, forbid getPartitionedState from different namespace

flinkbot edited a comment on pull request #16273: URL: https://github.com/apache/flink/pull/16273#issuecomment-867425757 ## CI report: * b5a9fc5356693337ef457f67773451117c04a0fd UNKNOWN * a696658cbb24431b39b4aec27a709a2a3cca2c5e Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15703: [FLINK-22275][table] Support random past for timestamp types in datagen connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

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

[jira] [Updated] (FLINK-2491) Support Checkpoints After Tasks Finished

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-2491: Labels: (was: auto-deprioritized-critical) > Support Checkpoints After Tasks Finished > -

[jira] [Closed] (FLINK-21084) Allows tasks to report finish state

[ https://issues.apache.org/jira/browse/FLINK-21084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-21084. Resolution: Implemented Implemented in d9cc268be61c1789e5cb32d0897d962721be9c01..c46b2034

[jira] [Closed] (FLINK-23037) Document limitations of UC

[ https://issues.apache.org/jira/browse/FLINK-23037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-23037. Resolution: Implemented Implemented in 685e093e74b91c7656225c2e2f2dd53e85e92505 > Documen

[jira] [Assigned] (FLINK-22926) IDLE FLIP-27 source should go ACTIVE when registering a new split

[ https://issues.apache.org/jira/browse/FLINK-22926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-22926: Assignee: (was: Dawid Wysakowicz) > IDLE FLIP-27 source should go ACTIVE when

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guxiang updated FLINK-18464: Attachment: image-2021-07-19-14-47-34-111.png > ClassCastException during namespace serialization for chec

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guxiang updated FLINK-18464: Attachment: image-2021-07-19-14-46-21-682.png > ClassCastException during namespace serialization for chec

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guxiang updated FLINK-18464: Attachment: image-2021-07-19-14-44-59-511.png > ClassCastException during namespace serialization for chec

[GitHub] [flink] dawidwys closed pull request #16238: [FLINK-21084][runtime][checkpoint] Allows tasks to report finished snapshot if finished on restore

dawidwys closed pull request #16238: URL: https://github.com/apache/flink/pull/16238 -- 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. To unsubscribe, e-mail: issues-unsubs

[jira] [Created] (FLINK-23422) window function not support in window agg function

silence created FLINK-23422: --- Summary: window function not support in window agg function Key: FLINK-23422 URL: https://issues.apache.org/jira/browse/FLINK-23422 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-18464) ClassCastException during namespace serialization for checkpoint (Heap and RocksDB)

[ https://issues.apache.org/jira/browse/FLINK-18464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] guxiang updated FLINK-18464: Attachment: image-2021-07-19-14-40-17-398.png > ClassCastException during namespace serialization for chec

[jira] [Commented] (FLINK-23419) CheckpointBarrierTrackerTest.testNextFirstCheckpointBarrierOvertakesCancellationBarrier fails on Azure

[ https://issues.apache.org/jira/browse/FLINK-23419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383040#comment-17383040 ] Anton Kalashnikov commented on FLINK-23419: --- [~dwysakowicz], let's maybe just

[GitHub] [flink] zentol commented on pull request #16275: [FLINK-20518][rest] Add decoding characters for MessageQueryParameter

zentol commented on pull request #16275: URL: https://github.com/apache/flink/pull/16275#issuecomment-882280863 > We are like #13514? Handle special characters single quotes. I don't understand what you are asking/suggesting, please elaborate. -- This is an automated message fro

[jira] [Updated] (FLINK-22275) Datagen add a max lag option for a series of timestamp-related types

[ https://issues.apache.org/jira/browse/FLINK-22275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yi Tang updated FLINK-22275: Fix Version/s: 1.14.0 > Datagen add a max lag option for a series of timestamp-related types > ---

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #15304: [FLINK-20731][connector] Introduce Pulsar Source

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

[GitHub] [flink] flinkbot commented on pull request #16531: [FLINK-23204] Provide StateBackends access to MailboxExecutor

flinkbot commented on pull request #16531: URL: https://github.com/apache/flink/pull/16531#issuecomment-882267546 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] curcur closed pull request #16504: [FLINK-23204] Provide StateBackends access to MailboxExecutor

curcur closed pull request #16504: URL: https://github.com/apache/flink/pull/16504 -- 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. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] curcur opened a new pull request #16531: [FLINK-23204] Provide StateBackends access to MailboxExecutor

curcur opened a new pull request #16531: URL: https://github.com/apache/flink/pull/16531 ## What is the purpose of the change This PR provides access to mailbox executor from KeyedStateBackend There are several places in ChangelogStateBackend that need execute actions from the

[GitHub] [flink] flinkbot edited a comment on pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

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

[GitHub] [flink] flinkbot edited a comment on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16525: [hotfix][table-api] Fix typo from Comparision to Comparison

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

[GitHub] [flink] flinkbot edited a comment on pull request #16496: [FLINK-23363][table-code-splitter] Java code splitter now supports functions with return statements

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

[GitHub] [flink] dianfu commented on a change in pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

dianfu commented on a change in pull request #16516: URL: https://github.com/apache/flink/pull/16516#discussion_r671985396 ## File path: flink-python/pyflink/table/schema.py ## @@ -0,0 +1,265 @@ + +

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17383004#comment-17383004 ] Jingsong Lee commented on FLINK-23420: -- [~jark] Thanks for the reminding about stat

[GitHub] [flink] flinkbot edited a comment on pull request #16525: [hotfix][table-api] Fix typo from Comparision to Comparison

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

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

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

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

[GitHub] [flink] yiduwangkai closed pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

yiduwangkai closed pull request #16517: URL: https://github.com/apache/flink/pull/16517 -- 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. To unsubscribe, e-mail: issues-uns

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #16020: [FLINK-21911][table-api] Add built-in greatest/least functions support #15821

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

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382986#comment-17382986 ] Jark Wu commented on FLINK-23420: - [~lzljs3620320], usually, it's the responsibility of

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23420: - Priority: Critical (was: Major) > sql stream mode lag function java.lang.NullPointerException >

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-23420: - Component/s: (was: Table SQL / API) Table SQL / Runtime > sql stream mode l

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

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

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382976#comment-17382976 ] Jingsong Lee commented on FLINK-23420: -- LinkedListSerializer is OK, the problem is

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

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

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

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

[jira] [Assigned] (FLINK-22672) Some enhancements for pluggable shuffle service framework

[ https://issues.apache.org/jira/browse/FLINK-22672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-22672: --- Assignee: Jin Xing > Some enhancements for pluggable shuffle service framework > --

[GitHub] [flink] flinkbot commented on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

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

[GitHub] [flink] flinkbot edited a comment on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

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

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

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

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiechenling updated FLINK-23420: Description: flink 1.13.1  BlinkPlanner  StreamingMode  EXACTLY_ONCE log {code:java} 2021-07-15 2

[GitHub] [flink] jinxing64 commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

jinxing64 commented on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-882204044 Thanks for 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 speci

[jira] [Assigned] (FLINK-23413) Port RelTimeIndicatorConverter from SCALA to JAVA

[ https://issues.apache.org/jira/browse/FLINK-23413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-23413: -- Assignee: JING ZHANG > Port RelTimeIndicatorConverter from SCALA to JAVA > --

[GitHub] [flink] Tartarus0zm commented on pull request #16275: [FLINK-20518][rest] Add decoding characters for MessageQueryParameter

Tartarus0zm commented on pull request #16275: URL: https://github.com/apache/flink/pull/16275#issuecomment-882203724 > > Earlier you said that the requests are encoded 3 times; The UI does it once (does it?), and the RM does it (I assume) once. Any idea where the third one comes from? >

[GitHub] [flink] Myasuka commented on a change in pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

Myasuka commented on a change in pull request #16447: URL: https://github.com/apache/flink/pull/16447#discussion_r671960538 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.html ## @@ -193,15 +193,74 @@ {{ check

[GitHub] [flink] beyond1920 commented on pull request #16520: [FLINK-23413][table] Port RelTimeIndicatorConverter from SCALA to JAVA.

beyond1920 commented on pull request #16520: URL: https://github.com/apache/flink/pull/16520#issuecomment-882200385 @godfreyhe @twalthr Please have a look at the pr when you have time. -- This is an automated message from the Apache Git Service. To respond to the message, please log on t

[jira] [Commented] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382967#comment-17382967 ] Jark Wu commented on FLINK-23420: - It seems you hard-code to use the internal {{LinkedLi

[GitHub] [flink] beyond1920 commented on pull request #16521: [FLINK-22715][runtime] Implement streaming window assigner tablefunction operator.

beyond1920 commented on pull request #16521: URL: https://github.com/apache/flink/pull/16521#issuecomment-882199668 @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 specif

[jira] [Closed] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-22676. --- Resolution: Done Done via 62a342b647fc1eac7f87769be92fda798649d6d4 > The partition tracker should support r

[GitHub] [flink] zhuzhurk closed pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

zhuzhurk closed pull request #16118: URL: https://github.com/apache/flink/pull/16118 -- 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. To unsubscribe, e-mail: issues-unsubs

[GitHub] [flink] flinkbot edited a comment on pull request #16516: [FLINK-23115][python] Expose new APIs about TableDescriptor in PyFlink

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

[GitHub] [flink] RocMarshal commented on a change in pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

RocMarshal commented on a change in pull request #16316: URL: https://github.com/apache/flink/pull/16316#discussion_r671269448 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -1016,8 +1018,8 @@ result = joined_table.select(joined_table.a, joined_table.b, joined_

[GitHub] [flink] flinkbot commented on pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

flinkbot commented on pull request #16530: URL: https://github.com/apache/flink/pull/16530#issuecomment-882191516 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-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

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

[GitHub] [flink] KarmaGYZ opened a new pull request #16530: [FLINK-23409][runtime] Add logs for FineGrainedSlotManager#checkResou…

KarmaGYZ opened a new pull request #16530: URL: https://github.com/apache/flink/pull/16530 …rceRequirements ## 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 avoi

[jira] [Updated] (FLINK-23421) Unify the space handling in RowData CSV parser

[ https://issues.apache.org/jira/browse/FLINK-23421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23421: Component/s: Formats (JSON, Avro, Parquet, ORC, SequenceFile) > Unify the space handling in RowData CSV pa

[jira] [Created] (FLINK-23421) Unify the space handling in RowData CSV parser

Dian Fu created FLINK-23421: --- Summary: Unify the space handling in RowData CSV parser Key: FLINK-23421 URL: https://issues.apache.org/jira/browse/FLINK-23421 Project: Flink Issue Type: Bug

[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=17382960#comment-17382960 ] Xintong Song commented on FLINK-20928: -- https://dev.azure.com/apache-flink/apache-f

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

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

[GitHub] [flink] yljee commented on a change in pull request #16316: [FLINK-16090] Translate "Table API" page of "Table API & SQL" into Chinese

yljee commented on a change in pull request #16316: URL: https://github.com/apache/flink/pull/16316#discussion_r671948261 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -728,16 +730,16 @@ result = orders.over_window(Over.partition_by(orders.a).order_by(orders.r

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiechenling updated FLINK-23420: Description: flink 1.13.1  BlinkPlanner  StreamingMode  EXACTLY_ONCE log {code:java} 2021-07-15 2

[jira] [Created] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

xiechenling created FLINK-23420: --- Summary: sql stream mode lag function java.lang.NullPointerException Key: FLINK-23420 URL: https://issues.apache.org/jira/browse/FLINK-23420 Project: Flink Is

[jira] [Assigned] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-23409: Assignee: Yangze Guo > CrossITCase fails with "NoResourceAvailableException: Slot request

[jira] [Commented] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382958#comment-17382958 ] Xintong Song commented on FLINK-23409: -- This indeed looks like a problem of fine gr

[jira] [Commented] (FLINK-23409) CrossITCase fails with "NoResourceAvailableException: Slot request bulk is not fulfillable! Could not allocate the required slot within slot request timeout"

[ https://issues.apache.org/jira/browse/FLINK-23409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382956#comment-17382956 ] Yangze Guo commented on FLINK-23409: One possible cause is that something went wrong

[GitHub] [flink] jinxing64 commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

jinxing64 commented on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-882183134 Thanks @zhuzhurk for rebasing ~ please ping me to rebase for convenience next time :) -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] leonardBang commented on a change in pull request #16519: [FLINK-23412][table][docs] - Description improvement of dynamic table sink and full stack example

leonardBang commented on a change in pull request #16519: URL: https://github.com/apache/flink/pull/16519#discussion_r671943009 ## File path: docs/content.zh/docs/dev/table/sourcesSinks.md ## @@ -334,8 +334,8 @@ a reference implementation. In particular, it shows how to - cre

[GitHub] [flink] fsk119 commented on pull request #16517: [FLINK-13400]Remove Hive and Hadoop dependencies from SQL Client

fsk119 commented on pull request #16517: URL: https://github.com/apache/flink/pull/16517#issuecomment-882176845 Hi, @yiduwangkai. Could you rebase your working branch to the master? There are some irrelevant commits. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] RollsBean commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

RollsBean commented on a change in pull request #16478: URL: https://github.com/apache/flink/pull/16478#discussion_r671934533 ## File path: docs/content.zh/docs/concepts/stateful-stream-processing.md ## @@ -24,342 +24,227 @@ under the License. # 有状态流处理 -## What is State? +

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

[GitHub] [flink] flinkbot edited a comment on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

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

[GitHub] [flink] flinkbot edited a comment on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

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

[jira] [Commented] (FLINK-22545) JVM crashes when runing OperatorEventSendingCheckpointITCase.testOperatorEventAckLost

[ https://issues.apache.org/jira/browse/FLINK-22545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382917#comment-17382917 ] Stephan Ewen commented on FLINK-22545: -- The stack trace looks like the executor is

[GitHub] [flink] flinkbot commented on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

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

[GitHub] [flink] flinkbot commented on pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

flinkbot commented on pull request #16529: URL: https://github.com/apache/flink/pull/16529#issuecomment-882118591 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] mans2singh opened a new pull request #16529: [hotfix][docs][hive] - Minor update to temporal join section

mans2singh opened a new pull request #16529: URL: https://github.com/apache/flink/pull/16529 ## What is the purpose of the change * Update to temporal join section docs for hive connector ## Brief change log * Update to temporal join section docs for hive connector

[GitHub] [flink] flinkbot edited a comment on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * bff840a95e38a1b9e24025d5eb2f4b5b5d83b5c2 UNKNOWN * 8885f7b99030d44186d1a0062b38e5e8a8bfa631 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * ebec5a2750a5fd510b80ae80e7a9869133f7

[GitHub] [flink] hackergin commented on a change in pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

hackergin commented on a change in pull request #16478: URL: https://github.com/apache/flink/pull/16478#discussion_r670706854 ## File path: docs/content.zh/docs/concepts/stateful-stream-processing.md ## @@ -24,342 +24,227 @@ under the License. # 有状态流处理 -## What is State? +

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * bff840a95e38a1b9e24025d5eb2f4b5b5d83b5c2 UNKNOWN * d09945fdf6f4292d87ce867b9b9832e2a71457bd Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

flinkbot edited a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-857430432 ## CI report: * bff840a95e38a1b9e24025d5eb2f4b5b5d83b5c2 UNKNOWN * d09945fdf6f4292d87ce867b9b9832e2a71457bd Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * a91bdb33636f0abd32265a60b5cf7171c4a3

[GitHub] [flink] flinkbot commented on pull request #16528: [FLINK-21367][connectors/jdbc] Support Object Reuse in JDBC sink

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

[GitHub] [flink] flinkbot edited a comment on pull request #15501: [FLINK-22054][k8s] Using a shared watcher for ConfigMap watching

flinkbot edited a comment on pull request #15501: URL: https://github.com/apache/flink/pull/15501#issuecomment-814722337 ## CI report: * 4d82d3eea5137b32bd38dbaa3340af62906e3cd5 UNKNOWN * 65fc2e6abd18a5b5087e1e318a491202ded69940 UNKNOWN * a91bdb33636f0abd32265a60b5cf7171c4a3

[GitHub] [flink] zhuzhurk commented on pull request #16118: [FLINK-22676][coordination] The partition tracker stops tracking internal partitions when TM disconnects

zhuzhurk commented on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-882084717 Rebased onto latest master because the PR base was a bit too old. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Commented] (FLINK-23136) Make `addSource` method with specific boundedness in `StreamExecutionEnvironment` public

[ https://issues.apache.org/jira/browse/FLINK-23136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17382861#comment-17382861 ] Eduardo Winpenny Tejedor commented on FLINK-23136: -- This one seems pret

[jira] [Updated] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22676: Affects Version/s: (was: 1.4) 1.14.0 > The partition tracker should support rem

[jira] [Updated] (FLINK-22676) The partition tracker should support remote shuffle properly

[ https://issues.apache.org/jira/browse/FLINK-22676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-22676: Fix Version/s: 1.14.0 > The partition tracker should support remote shuffle properly > ---

  1   2   >