[jira] [Comment Edited] (FLINK-23181) Add support for multi hop window

[ https://issues.apache.org/jira/browse/FLINK-23181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381832#comment-17381832 ] Jingsong Lee edited comment on FLINK-23181 at 7/16/21, 6:53 AM: --

[jira] [Commented] (FLINK-23181) Add support for multi hop window

[ https://issues.apache.org/jira/browse/FLINK-23181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381832#comment-17381832 ] Jingsong Lee commented on FLINK-23181: -- {code:java} SELECT k, window_start, window_

[GitHub] [flink] flinkbot edited a comment on pull request #16503: [FLINK-20323][table/planner] CorrelateSortToRankRule supports dealing…

flinkbot edited a comment on pull request #16503: URL: https://github.com/apache/flink/pull/16503#issuecomment-880577837 ## CI report: * a5873dc703589bb70d506587f10023cec027661a 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 * 102e53e49c351090a45e3403ea3f4aef0480989f Azure: [CANCELED](https://dev.azure.com/apache-f

[jira] [Commented] (FLINK-23289) BinarySection should add null check in constructor method

[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381830#comment-17381830 ] Jingsong Lee commented on FLINK-23289: -- [~TsReaper] Assigned to u > BinarySection

[jira] [Assigned] (FLINK-23289) BinarySection should add null check in constructor method

[ https://issues.apache.org/jira/browse/FLINK-23289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-23289: Assignee: Caizhi Weng > BinarySection should add null check in constructor method > -

[GitHub] [flink] flinkbot edited a comment on pull request #15187: [FLINK-21771][metrics][tests] Replace StreamTaskTestHarness#TestTaskMetricGroup

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

[GitHub] [flink] flinkbot edited a comment on pull request #15186: [FLINK-21770][metrics] JobManagerMG#addJob accepts job ID and name

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

[jira] [Commented] (FLINK-23403) Decrease default values for heartbeat timeout and interval

[ https://issues.apache.org/jira/browse/FLINK-23403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381829#comment-17381829 ] Yang Wang commented on FLINK-23403: --- I am afraid the decrease of heartbeat timeout wil

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

[GitHub] [flink] flinkbot edited a comment on pull request #16508: [FLINK-23400][python] Support to decode a single record for the Python coder

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

[jira] [Assigned] (FLINK-21755) Remove flink-runtime dependency from metric reporters

[ https://issues.apache.org/jira/browse/FLINK-21755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-21755: - Assignee: Chesnay Schepler > Remove flink-runtime dependency from metric reporters > --

[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: * 48b01b6d373d251045dbd53f925360b02cf7b67f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Comment Edited] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381745#comment-17381745 ] Yun Tang edited comment on FLINK-23367 at 7/16/21, 6:15 AM:

[jira] [Assigned] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23367: Assignee: Yun Tang > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDelegateEmb

[jira] [Comment Edited] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381794#comment-17381794 ] loyi edited comment on FLINK-23190 at 7/16/21, 6:06 AM: [~trohrm

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381794#comment-17381794 ] loyi commented on FLINK-23190: -- [~trohrmann]  Thanks for your patience.  I have implement a

[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

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

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

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

[jira] [Created] (FLINK-23406) ClusterUncaughtExceptionHandlerITCase.testExitDueToUncaughtException fails on azure

Xintong Song created FLINK-23406: Summary: ClusterUncaughtExceptionHandlerITCase.testExitDueToUncaughtException fails on azure Key: FLINK-23406 URL: https://issues.apache.org/jira/browse/FLINK-23406

[jira] [Created] (FLINK-23405) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException

Xintong Song created FLINK-23405: Summary: FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails due to BindException Key: FLINK-23405 URL: https://issues.apache.org/jira/browse/FLINK-23405

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

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

[GitHub] [flink] flinkbot edited a comment on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

flinkbot edited a comment on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881087694 ## CI report: * e4f43924338b2bc62d3c5b2f4d669401d903e0ad UNKNOWN * 859524ef665256a4b91bb890970098a9c26d0ac0 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16512: [FLINK-23367][state] Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16508: [FLINK-23400][python] Support to decode a single record for the Python coder

flinkbot edited a comment on pull request #16508: URL: https://github.com/apache/flink/pull/16508#issuecomment-880663906 ## CI report: * caae4104947a5f1d96cde29593342d4188d6ad28 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: * 48b01b6d373d251045dbd53f925360b02cf7b67f Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Commented] (FLINK-14055) Add advanced function DDL syntax "USING JAR/FILE/ACHIVE"

[ https://issues.apache.org/jira/browse/FLINK-14055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381785#comment-17381785 ] frank wang commented on FLINK-14055: [~ZhenqiuHuang] what is problem? Is that the cl

[GitHub] [flink-benchmarks] pnowojski commented on a change in pull request #22: [FLINK-23392] Exclude startup/shutdown time from benchmarks

pnowojski commented on a change in pull request #22: URL: https://github.com/apache/flink-benchmarks/pull/22#discussion_r670976806 ## File path: src/main/java/org/apache/flink/benchmark/UnalignedCheckpointTimeBenchmark.java ## @@ -116,6 +116,7 @@ protected int getNumberOfSlots

[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_r670976534 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -600,8 +603,8 @@ result = orders.rename_columns(orders.b.alias('b2'), orders.c.alias('c2'))

[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_r670975043 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -221,23 +220,24 @@ result = orders.filter(orders.a.is_not_null & orders.b.is_not_null & orde

[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_r670974408 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -28,25 +28,24 @@ under the License. # Table API -The Table API is a unified, relational

[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_r670973997 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -28,25 +28,24 @@ under the License. # Table API -The Table API is a unified, relational

[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_r670973597 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -28,25 +28,24 @@ under the License. # Table API -The Table API is a unified, relational

[GitHub] [flink] flinkbot commented on pull request #16512: [FLINK-23367][state] Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16508: [FLINK-23400][python] Support to decode a single record for the Python coder

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

[GitHub] [flink] flinkbot edited a comment on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

flinkbot edited a comment on pull request #16487: URL: https://github.com/apache/flink/pull/16487#issuecomment-879414939 ## CI report: * f5feab6a08c85d077eaebecb6ee9ccae713b2518 Azure: [FAILURE](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 * 1615c6fb76a2dccd227bd33580728fd73d7be1b5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[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 * 1615c6fb76a2dccd227bd33580728fd73d7be1b5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #16512: [FLINK-23367][state] Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend

flinkbot commented on pull request #16512: URL: https://github.com/apache/flink/pull/16512#issuecomment-881171757 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-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23367: --- Labels: pull-request-available (was: ) > testKeyGroupedInternalPriorityQueue does not dispo

[GitHub] [flink] Myasuka opened a new pull request #16512: [FLINK-23367][state] Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend

Myasuka opened a new pull request #16512: URL: https://github.com/apache/flink/pull/16512 ## What is the purpose of the change Ensure InternalPriorityQueue#iterator could be closed for changelog state-backend ## Brief change log Make `StateChangeLoggingIterator.jav

[jira] [Commented] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381745#comment-17381745 ] Yun Tang commented on FLINK-23367: -- This failure is due to not close internal priority

[GitHub] [flink] flinkbot edited a comment on pull request #16511: [FLINK-22861][table-planner] Fix return value deduction of TIMESTAMPADD function

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

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23367: - Fix Version/s: 1.14.0 > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDelegateEmbedde

[jira] [Updated] (FLINK-23367) testKeyGroupedInternalPriorityQueue does not dispose ChangelogDelegateEmbeddedRocksDB properly, and fails the test

[ https://issues.apache.org/jira/browse/FLINK-23367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-23367: - Priority: Blocker (was: Major) > testKeyGroupedInternalPriorityQueue does not dispose > ChangelogDeleg

[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: * 353963054a79eafead0a07fa60c7a5ca9e4cde3c Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[GitHub] [flink] gaoyunhaii commented on pull request #16493: [FLINK-21246] Fail fast if a failure occurs when triggering a checkpoint on a Task

gaoyunhaii commented on pull request #16493: URL: https://github.com/apache/flink/pull/16493#issuecomment-881161579 Very thanks @dawidwys for the update! The PR LGTM and +1 to merge~ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[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-881161567 @zhuzhurk Thanks for deep review ~ I updated by your comments ~ please take a look when CI gives green ~~ -- This is an automated message from the Apache Git Service. To

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

jinxing64 removed a comment on pull request #16118: URL: https://github.com/apache/flink/pull/16118#issuecomment-880703440 wip -- 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 commen

[GitHub] [flink] flinkbot commented on pull request #16511: [FLINK-22861][table-planner] Fix return value deduction of TIMESTAMPADD function

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #16503: [FLINK-20323][table/planner] CorrelateSortToRankRule supports dealing…

flinkbot edited a comment on pull request #16503: URL: https://github.com/apache/flink/pull/16503#issuecomment-880577837 ## CI report: * a5873dc703589bb70d506587f10023cec027661a 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 * 1615c6fb76a2dccd227bd33580728fd73d7be1b5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Comment Edited] (FLINK-23404) function UNIX_TIMESTAMP's result incorrect when format is 'EEE MMM dd HH:mm:ss z yyyy'

[ https://issues.apache.org/jira/browse/FLINK-23404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381710#comment-17381710 ] Caizhi Weng edited comment on FLINK-23404 at 7/16/21, 3:42 AM: ---

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

[jira] [Commented] (FLINK-23404) function UNIX_TIMESTAMP's result incorrect when format is 'EEE MMM dd HH:mm:ss z yyyy'

[ https://issues.apache.org/jira/browse/FLINK-23404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381710#comment-17381710 ] Caizhi Weng commented on FLINK-23404: - [~alfred.zou] day name in week depends on you

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

jinxing64 commented on a change in pull request #16118: URL: https://github.com/apache/flink/pull/16118#discussion_r670467100 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTrackerImplTest.java ## @@ -240,54 +245,120 @

[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_r670404690 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -221,23 +220,24 @@ result = orders.filter(orders.a.is_not_null & orders.b.is_not_null &

[GitHub] [flink] flinkbot edited a comment on pull request #16503: [FLINK-20323][table/planner] CorrelateSortToRankRule supports dealing…

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

[GitHub] [flink] flinkbot commented on pull request #16511: [FLINK-22861][table-planner] Fix return value deduction of TIMESTAMPADD function

flinkbot commented on pull request #16511: URL: https://github.com/apache/flink/pull/16511#issuecomment-881147950 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 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: * 66c591777b1d8280c93f2f96a3e351a1ad063f58 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-22861) TIMESTAMPADD + timestamp_ltz type throws CodeGenException when comparing with timestamp type

[ https://issues.apache.org/jira/browse/FLINK-22861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22861: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > TIMESTAMPADD + time

[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 * 1615c6fb76a2dccd227bd33580728fd73d7be1b5 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] tsreaper opened a new pull request #16511: [FLINK-22861][table-planner] Fix return value deduction of TIMESTAMPADD function

tsreaper opened a new pull request #16511: URL: https://github.com/apache/flink/pull/16511 ## What is the purpose of the change Currently `TIMESTAMPADD(MINUTE, 10, CURRENT_TIMESTAMP)` will be deduced as `timestamp` type. However this should be `timestamp with local time zone` type.

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

[GitHub] [flink] cshuo commented on pull request #16503: [FLINK-20323][table/planner] CorrelateSortToRankRule supports dealing…

cshuo commented on pull request #16503: URL: https://github.com/apache/flink/pull/16503#issuecomment-881145648 @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 specific co

[jira] [Created] (FLINK-23404) function UNIX_TIMESTAMP's result incorrect when format is 'EEE MMM dd HH:mm:ss z yyyy'

alfred.zou created FLINK-23404: -- Summary: function UNIX_TIMESTAMP's result incorrect when format is 'EEE MMM dd HH:mm:ss z ' Key: FLINK-23404 URL: https://issues.apache.org/jira/browse/FLINK-23404 Pr

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

jinxing64 commented on a change in pull request #16118: URL: https://github.com/apache/flink/pull/16118#discussion_r670930512 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTrackerImplTest.java ## @@ -73,7 +77,7 @@ pri

[GitHub] [flink] zjffdu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

zjffdu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-881136755 @YikSanChan @dianfu Here's one zeppelin notebook which create conda env tar and zip file to use customized python env in yarn cluster. But it would be great if this PR can be me

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loyi updated FLINK-23190: - Attachment: image-2021-07-16-10-34-30-700.png > Make task-slot allocation much more evenly > ---

[GitHub] [flink] flinkbot edited a comment on pull request #16508: [FLINK-23400][python] Support to decode a single record for the Python coder

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

[GitHub] [flink-benchmarks] Myasuka merged pull request #24: [FLINK-23398] Exclude signature files from shaded benchmarks.jar

Myasuka merged pull request #24: URL: https://github.com/apache/flink-benchmarks/pull/24 -- 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-un

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

jinxing64 commented on a change in pull request #16118: URL: https://github.com/apache/flink/pull/16118#discussion_r670467100 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTrackerImplTest.java ## @@ -240,54 +245,120 @

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

jinxing64 commented on a change in pull request #16118: URL: https://github.com/apache/flink/pull/16118#discussion_r670393641 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/JobMasterPartitionTrackerImplTest.java ## @@ -110,7 +113,8 @@ p

[jira] [Issue Comment Deleted] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] loyi updated FLINK-23190: - Comment: was deleted (was: Job description: // flink run -yjm 2048 -ytm 2048 -ys 4 -ynm demo-job -m yarn-cluste

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17381661#comment-17381661 ] loyi commented on FLINK-23190: -- Job description: // flink run -yjm 2048 -ytm 2048 -ys 4 -y

[GitHub] [flink] dianfu commented on pull request #15813: [FLINK-22519][flink-python] support tar python archives

dianfu commented on pull request #15813: URL: https://github.com/apache/flink/pull/15813#issuecomment-881126116 @YikSanChan What's the status of this PR? I'm asking because we are approaching the feature freeze of 1.14 which is planned at the end of this month. It would be great to includ

[GitHub] [flink] flinkbot edited a comment on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

flinkbot edited a comment on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881087694 ## CI report: * e4f43924338b2bc62d3c5b2f4d669401d903e0ad UNKNOWN * 8d866984c1a9fec8a9a50727cd89b92540f30ebe Azure: [CANCELED](https://dev.azure.com/apache-f

[GitHub] [flink] flinkbot edited a comment on pull request #16508: [FLINK-23400][python] Support to decode a single record for the Python coder

flinkbot edited a comment on pull request #16508: URL: https://github.com/apache/flink/pull/16508#issuecomment-880663906 ## CI report: * 092155e117ba11e22a4f74057b68af2a8d4369ae 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_r670411693 ## File path: docs/content.zh/docs/dev/table/tableApi.md ## @@ -600,8 +603,8 @@ result = orders.rename_columns(orders.b.alias('b2'), orders.c.alias('c

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

[GitHub] [flink] cshuo commented on pull request #16503: [FLINK-20323][table/planner] CorrelateSortToRankRule supports dealing…

cshuo commented on pull request #16503: URL: https://github.com/apache/flink/pull/16503#issuecomment-881116815 @godfreyhe plz 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 URL above to go to the spec

[GitHub] [flink] flinkbot edited a comment on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

flinkbot edited a comment on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881087694 ## CI report: * e4f43924338b2bc62d3c5b2f4d669401d903e0ad UNKNOWN * 8d866984c1a9fec8a9a50727cd89b92540f30ebe Azure: [PENDING](https://dev.azure.com/apache-fl

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

[GitHub] [flink] wanglijie95 commented on pull request #16274: [FLINK-23093] Limit default io pool size to 8 for Mini Cluster.

wanglijie95 commented on pull request #16274: URL: https://github.com/apache/flink/pull/16274#issuecomment-88075 Thanks for your review @tillrohrmann . LGTM currently. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Assigned] (FLINK-23400) Support to decode a single record for the Python coder

[ https://issues.apache.org/jira/browse/FLINK-23400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-23400: --- Assignee: Dian Fu > Support to decode a single record for the Python coder > --

[jira] [Assigned] (FLINK-23401) Separate data and timer connection into different channel

[ https://issues.apache.org/jira/browse/FLINK-23401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-23401: --- Assignee: Dian Fu > Separate data and timer connection into different channel > ---

[GitHub] [flink] wanglijie95 commented on a change in pull request #16274: [FLINK-23093] Limit default io pool size to 8 for Mini Cluster.

wanglijie95 commented on a change in pull request #16274: URL: https://github.com/apache/flink/pull/16274#discussion_r670901232 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java ## @@ -686,6 +690,38 @@ public void initializeO

[GitHub] [flink] flinkbot edited a comment on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

flinkbot edited a comment on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881087694 ## CI report: * e4f43924338b2bc62d3c5b2f4d669401d903e0ad UNKNOWN * 8d866984c1a9fec8a9a50727cd89b92540f30ebe Azure: [PENDING](https://dev.azure.com/apache-fl

[GitHub] [flink] paul8263 commented on pull request #16419: [FLINK-23101][runtime] Flame Graphs initial view says it is 18800 day…

paul8263 commented on pull request #16419: URL: https://github.com/apache/flink/pull/16419#issuecomment-881097245 Pls consider my solution in FLINK-23102. If there is anything else for me to do, please comment below. Thanks. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

flinkbot edited a comment on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881087694 ## CI report: * e4f43924338b2bc62d3c5b2f4d669401d903e0ad UNKNOWN * 8d866984c1a9fec8a9a50727cd89b92540f30ebe UNKNOWN Bot commands The @flinkbo

[GitHub] [flink] flinkbot commented on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

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

[GitHub] [flink] flinkbot edited a comment on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

rkhachatryan commented on a change in pull request #16510: URL: https://github.com/apache/flink/pull/16510#discussion_r670871109 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/JobManagerTaskRestore.java ## @@ -58,4 +78,12 @@ public String toStrin

[GitHub] [flink] flinkbot edited a comment on pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

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

[GitHub] [flink] flinkbot commented on pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

flinkbot commented on pull request #16510: URL: https://github.com/apache/flink/pull/16510#issuecomment-881074703 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 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: * fc24d5211584f864103625ee6ea6e09233a9b971 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Updated] (FLINK-23342) State ownership: compute shared state on recovery

[ https://issues.apache.org/jira/browse/FLINK-23342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23342: --- Labels: pull-request-available (was: ) > State ownership: compute shared state on recovery

[GitHub] [flink] rkhachatryan opened a new pull request #16510: [FLINK-23342][state] State ownership: compute shared state on recovery

rkhachatryan opened a new pull request #16510: URL: https://github.com/apache/flink/pull/16510 ## What is the purpose of the change For the changelog state backend, state ownership model is changed from pure-JM to a mixed one, in which JM only owns the shared state (resulting fr

[GitHub] [flink] edu05 commented on a change in pull request #16487: [FLINK-22483][runtime][coordination] Recover checkpoints when JobMaster gains leadership

edu05 commented on a change in pull request #16487: URL: https://github.com/apache/flink/pull/16487#discussion_r670863608 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/SchedulerUtilsTest.java ## @@ -21,17 +21,30 @@ import org.apache.flink.api.co

  1   2   3   4   5   >