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

flinkbot commented on pull request #16419: URL: https://github.com/apache/flink/pull/16419#issuecomment-876183073 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] dawidwys commented on pull request #16415: [FLINK-23262][tests] Check watermark frequency instead of count

dawidwys commented on pull request #16415: URL: https://github.com/apache/flink/pull/16415#issuecomment-876182906 Which improvements do you refer to? -- 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

[jira] [Commented] (FLINK-23262) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377138#comment-17377138 ] Dawid Wysakowicz commented on FLINK-23262: -- https://dev.azure.com/apache-flink/

[jira] [Updated] (FLINK-23101) Flame Graphs initial view says it is 18800 days in the past

[ https://issues.apache.org/jira/browse/FLINK-23101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23101: --- Labels: pull-request-available usability (was: usability) > Flame Graphs initial view says

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

paul8263 opened a new pull request #16419: URL: https://github.com/apache/flink/pull/16419 …s in the past ## What is the purpose of the change Fixed flame graphs says it is 18800 days in the past when Flink returns an empty flame graph. ## Brief change log - fli

[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-08-14-50-12-559.png > ClassCastException during namespace serialization for chec

[GitHub] [flink] flinkbot edited a comment on pull request #16395: [FLINK-22662][yarn][test] Stabilize YARNHighAvailabilityITCase

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

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN * 4133ee287c23af5da472db1098c9d7ab51b8

[GitHub] [flink] Airblader removed a comment on pull request #16368: ignore

Airblader removed a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-874602370 @yanchenyun It seems you created a new PR for this. Can you maybe close this one? -- This is an automated message from the Apache Git Service. To respond to the mess

[jira] [Closed] (FLINK-22443) can not be execute an extreme long sql under batch mode

[ https://issues.apache.org/jira/browse/FLINK-22443?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22443. -- Resolution: Fixed Fixed on master edb3000a7e9 on release-1.13 8057026bb6a on release-1.12 4812

[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=17377117#comment-17377117 ] XiaYu commented on FLINK-14055: --- [~ZhenqiuHuang] ok，but how should we consider applicatio

[GitHub] [flink] Myasuka commented on a change in pull request #16404: [FLINK-23277][state/changelog] Store and recover TTL metadata using changelog

Myasuka commented on a change in pull request #16404: URL: https://github.com/apache/flink/pull/16404#discussion_r665907840 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -533

[GitHub] [flink] Myasuka commented on a change in pull request #16404: [FLINK-23277][state/changelog] Store and recover TTL metadata using changelog

Myasuka commented on a change in pull request #16404: URL: https://github.com/apache/flink/pull/16404#discussion_r665906792 ## File path: flink-state-backends/flink-statebackend-changelog/src/main/java/org/apache/flink/state/changelog/ChangelogKeyedStateBackend.java ## @@ -124

[GitHub] [flink] pnowojski closed pull request #16369: [FLINK-22443][streaming-java] Fix overflow in MultipleInputSelectionHandler

pnowojski closed pull request #16369: URL: https://github.com/apache/flink/pull/16369 -- 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-unsub

[GitHub] [flink] pnowojski commented on pull request #16369: [FLINK-22443][streaming-java] Fix overflow in MultipleInputSelectionHandler

pnowojski commented on pull request #16369: URL: https://github.com/apache/flink/pull/16369#issuecomment-876168477 Thanks merged -- 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 comm

[GitHub] [flink] pnowojski commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

pnowojski commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665900515 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -164,6 +168,27 @@ void addCreditOr

[jira] [Commented] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377109#comment-17377109 ] Stephan Pelikan commented on FLINK-21308: - Thank you! :) > Cancel "sendAfter" >

[GitHub] [flink] flinkbot edited a comment on pull request #16416: [FLINK-22657][Connectors/Hive] HiveParserDDLSemanticAnalyzer return operations directly

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

[GitHub] [flink] flinkbot edited a comment on pull request #16163: [FLINK-22994][Table SQL / Planner] improve the performace of invoking…

flinkbot edited a comment on pull request #16163: URL: https://github.com/apache/flink/pull/16163#issuecomment-861284972 ## CI report: * 00f7cd34fc503db8cc116dd201bcc7f54a4b6f20 UNKNOWN * da303c24e513b0678794526c6351003b6e76cb6d UNKNOWN * 4133ee287c23af5da472db1098c9d7ab51b8

[jira] [Closed] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-21308. --- Resolution: Fixed Thank you for the contribution [~igal]. Merged at flink-statefun/

[jira] [Updated] (FLINK-21308) Cancel "sendAfter"

[ https://issues.apache.org/jira/browse/FLINK-21308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-21308: Priority: Major (was: Minor) > Cancel "sendAfter" > -- > >

[GitHub] [flink-statefun] tzulitai closed pull request #241: [FLINK-21308] Support delayed message cancellation

tzulitai closed pull request #241: URL: https://github.com/apache/flink-statefun/pull/241 -- 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-u

[GitHub] [flink] pnowojski commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

pnowojski commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665895504 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionDirectTransferReader.java ## @@ -91,

[GitHub] [flink] fhan688 commented on pull request #15965: [FLINK-23298][datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

fhan688 commented on pull request #15965: URL: https://github.com/apache/flink/pull/15965#issuecomment-876153339 got it. thanks! @lirui-apache -- 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] AHeise commented on a change in pull request #15972: Add common source and operator metrics.

AHeise commented on a change in pull request #15972: URL: https://github.com/apache/flink/pull/15972#discussion_r665891888 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/groups/SourceMetricGroup.java ## @@ -0,0 +1,71 @@ +/* + * Licensed t

[jira] [Commented] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

[ https://issues.apache.org/jira/browse/FLINK-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377082#comment-17377082 ] Jiangjie Qin commented on FLINK-16634: -- [~liufangliang] Done. > The PartitionDisco

[jira] [Assigned] (FLINK-16634) The PartitionDiscoverer in FlinkKafkaConsumer should not use the user provided client.id.

[ https://issues.apache.org/jira/browse/FLINK-16634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-16634: Assignee: Fangliang Liu > The PartitionDiscoverer in FlinkKafkaConsumer should not use th

[GitHub] [flink] flinkbot edited a comment on pull request #16416: [FLINK-22657][Connectors/Hive] HiveParserDDLSemanticAnalyzer return operations directly

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

[GitHub] [flink] flinkbot edited a comment on pull request #16404: [FLINK-23277][state/changelog] Store and recover TTL metadata using changelog

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

[GitHub] [flink] lirui-apache commented on pull request #15965: [FLINK-23298][datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

lirui-apache commented on pull request #15965: URL: https://github.com/apache/flink/pull/15965#issuecomment-876147727 @fhan688 It has been merged in this commit: https://github.com/apache/flink/commit/e9cc49a31fc384bff1c84372788f14a173cd94b0 -- This is an automated message from the Apach

[GitHub] [flink] flinkbot edited a comment on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

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

[jira] [Comment Edited] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377059#comment-17377059 ] hehuiyuan edited comment on FLINK-23237 at 7/8/21, 5:47 AM:

[jira] [Comment Edited] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377059#comment-17377059 ] hehuiyuan edited comment on FLINK-23237 at 7/8/21, 5:46 AM:

[jira] [Comment Edited] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377059#comment-17377059 ] hehuiyuan edited comment on FLINK-23237 at 7/8/21, 5:35 AM:

[GitHub] [flink] LongWangXX commented on pull request #16417: FLINK-22969

LongWangXX commented on pull request #16417: URL: https://github.com/apache/flink/pull/16417#issuecomment-876141971 @luoyuxia Thank you for your review, thank you for your hard work. I'm very sorry, there are so many questions, let me fix it. -- This is an automated message from the Apac

[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=17377072#comment-17377072 ] Zhenqiu Huang commented on FLINK-14055: --- [~gelimusong] Please see the doc I shared

[jira] [Commented] (FLINK-23237) Add log to print data that failed to deserialize when ignore-parse-error=true

[ https://issues.apache.org/jira/browse/FLINK-23237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377059#comment-17377059 ] hehuiyuan commented on FLINK-23237: --- [~Aiden Gong] ， Additionally, add log (debug or e

[jira] [Assigned] (FLINK-23107) Separate deduplicate rank from rank functions

[ https://issues.apache.org/jira/browse/FLINK-23107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-23107: Assignee: Shuo Cheng > Separate deduplicate rank from rank functions > --

[jira] [Commented] (FLINK-23107) Separate deduplicate rank from rank functions

[ https://issues.apache.org/jira/browse/FLINK-23107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377058#comment-17377058 ] Jingsong Lee commented on FLINK-23107: -- [~icshuo] Thanks, assigned to you~ > Separ

[GitHub] [flink] flinkbot edited a comment on pull request #16415: [FLINK-23262][tests] Check watermark frequency instead of count

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

[GitHub] [flink-statefun] tzulitai commented on pull request #241: [FLINK-21308] Support delayed message cancellation

tzulitai commented on pull request #241: URL: https://github.com/apache/flink-statefun/pull/241#issuecomment-876126960 Thanks @igalshilman! Merging this! -- 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 t

[GitHub] [flink] fhan688 commented on pull request #15965: [FLINK-23298][datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

fhan688 commented on pull request #15965: URL: https://github.com/apache/flink/pull/15965#issuecomment-876126254 sorry, I wonder why this pr closed not merged... @lirui-apache -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #16403: [FLINK-23276][state/changelog] Fix missing delegation in getPartitionedState

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

[GitHub] [flink] flinkbot edited a comment on pull request #16418: [FLINK-23243][docs-zh]Translate "SELECT & WHERE clause" page into Chinese

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

[jira] [Updated] (FLINK-23304) More detail information in sql validate exception

[ https://issues.apache.org/jira/browse/FLINK-23304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] YING HOU updated FLINK-23304: - Description: Currently, When I was using a lot of the same udf in a sql, I can't locate where the semant

[jira] [Resolved] (FLINK-23178) Raise an error for writing stream data into partitioned hive tables without a partition committer

[ https://issues.apache.org/jira/browse/FLINK-23178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23178. Fix Version/s: 1.13.2 1.14.0 Resolution: Fixed Pushed to master: a94745ec85bf9e8

[GitHub] [flink] flinkbot commented on pull request #16418: [FLINK-23243][docs-zh]Translate "SELECT & WHERE clause" page into Chinese

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

[GitHub] [flink] flinkbot edited a comment on pull request #16417: FLINK-22969

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

[GitHub] [flink] flinkbot edited a comment on pull request #16395: [FLINK-22662][yarn][test] Stabilize YARNHighAvailabilityITCase

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

[jira] [Created] (FLINK-23304) More detail information in sql validate exception

YING HOU created FLINK-23304: Summary: More detail information in sql validate exception Key: FLINK-23304 URL: https://issues.apache.org/jira/browse/FLINK-23304 Project: Flink Issue Type: Improve

[GitHub] [flink] luoyuxia commented on a change in pull request #16417: FLINK-22969

luoyuxia commented on a change in pull request #16417: URL: https://github.com/apache/flink/pull/16417#discussion_r665846147 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java ## @

[GitHub] [flink] luoyuxia commented on a change in pull request #16417: FLINK-22969

luoyuxia commented on a change in pull request #16417: URL: https://github.com/apache/flink/pull/16417#discussion_r665844774 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KafkaTopicsDescriptor.java ## @

[jira] [Comment Edited] (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=17376986#comment-17376986 ] XiaYu edited comment on FLINK-14055 at 7/8/21, 3:37 AM: hi, ever

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

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

[jira] [Commented] (FLINK-23107) Separate deduplicate rank from rank functions

[ https://issues.apache.org/jira/browse/FLINK-23107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377003#comment-17377003 ] Shuo Cheng commented on FLINK-23107: cc [~lzljs3620320], I'll take this Jira. > Sep

[GitHub] [flink] edmondsky commented on pull request #16418: [FLINK-23243][docs-zh]Translate "SELECT & WHERE clause" page into Chinese

edmondsky commented on pull request #16418: URL: https://github.com/apache/flink/pull/16418#issuecomment-876092378 @95chenjz Ready to review -- 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 commented on pull request #16418: [FLINK-23243][docs-zh]Translate "SELECT & WHERE clause" page into Chinese

flinkbot commented on pull request #16418: URL: https://github.com/apache/flink/pull/16418#issuecomment-876091446 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] [Closed] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

[ https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liu closed FLINK-23300. --- Resolution: Duplicate > Job fails very slow because of no notifyAllocationFailure for > DeclarativeSlotManager > --

[jira] [Commented] (FLINK-23194) Cache and reuse the ContainerLaunchContext and accelarate the progress of createTaskExecutorLaunchContext on yarn

[ https://issues.apache.org/jira/browse/FLINK-23194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377001#comment-17377001 ] Yang Wang commented on FLINK-23194: --- AFAIK, except for the key tab and Kerberos file,

[jira] [Updated] (FLINK-23243) Translate "SELECT & WHERE clause" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23243: --- Labels: pull-request-available (was: ) > Translate "SELECT & WHERE clause" page into Chines

[GitHub] [flink] edmondsky opened a new pull request #16418: [FLINK-23243][docs-zh]Translate "SELECT & WHERE clause" page into Chinese

edmondsky opened a new pull request #16418: URL: https://github.com/apache/flink/pull/16418 ## What is the purpose of the change Translate "SELECT & WHERE clause" page into Chinese The page url is https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/table/s

[GitHub] [flink] lirui-apache closed pull request #16370: [FLINK-23178][hive] Raise an error for writing stream data into parti…

lirui-apache closed pull request #16370: URL: https://github.com/apache/flink/pull/16370 -- 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

[jira] [Commented] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned

[ https://issues.apache.org/jira/browse/FLINK-23268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376998#comment-17376998 ] Yun Tang commented on FLINK-23268: -- [~hapihu], already assigned this ticket to you. >

[jira] [Assigned] (FLINK-23268) [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed and 404 is returned

[ https://issues.apache.org/jira/browse/FLINK-23268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-23268: Assignee: wuguihu > [DOCS]The link on page docs/dev/table/sql/queries/match_recognize/ is failed

[jira] [Assigned] (FLINK-14193) Update Web UI for fine grained TM/Slot resources

[ https://issues.apache.org/jira/browse/FLINK-14193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-14193: Assignee: Junhan Yang > Update Web UI for fine grained TM/Slot resources > --

[GitHub] [flink] flinkbot commented on pull request #16417: FLINK-22969

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

[GitHub] [flink] flinkbot edited a comment on pull request #16395: [FLINK-22662][yarn][test] Stabilize YARNHighAvailabilityITCase

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

[GitHub] [flink] flinkbot edited a comment on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

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

[GitHub] [flink] Myasuka commented on pull request #16352: [FLINK-23102][runtime] Accessing FlameGraphs while not being enabled …

Myasuka commented on pull request #16352: URL: https://github.com/apache/flink/pull/16352#issuecomment-876087473 Do we consider FLINK-22527 to provide more friendly hint to tell users how to enable flame graph? -- This is an automated message from the Apache Git Service. To respond to th

[jira] [Closed] (FLINK-23222) Translate page 'Application Profiling & Debugging' of 'Operations/Debugging' into Chinese

[ https://issues.apache.org/jira/browse/FLINK-23222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23222. --- Fix Version/s: 1.14.0 Assignee: pierrexiong Resolution: Fixed Fixed in master: f0fdf875606ed

[GitHub] [flink] wuchong merged pull request #16359: [FLINK-23222]Translate page 'Application Profiling & Debugging' into Chinese

wuchong merged pull request #16359: URL: https://github.com/apache/flink/pull/16359 -- 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-unsubsc

[GitHub] [flink] wuchong commented on pull request #16359: [FLINK-23222]Translate page 'Application Profiling & Debugging' into Chinese

wuchong commented on pull request #16359: URL: https://github.com/apache/flink/pull/16359#issuecomment-876086560 Thanks @pierre94 for the great work and @RocMarshal for the reviewing. Merging... -- This is an automated message from the Apache Git Service. To respond to the message, p

[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=17376986#comment-17376986 ] XiaYu commented on FLINK-14055: --- hi, everyone, iam a little bit confused about your classl

[jira] [Commented] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

[ https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376985#comment-17376985 ] Liu commented on FLINK-23300: - Thanks, [~Thesharing]. I will focus on the issues you mention

[jira] [Resolved] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

[ https://issues.apache.org/jira/browse/FLINK-23298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li resolved FLINK-23298. Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: e9cc49a31fc384bff1c84372788f14a173cd94b0

[GitHub] [flink] lirui-apache closed pull request #15965: [FLINK-23298][datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

lirui-apache closed pull request #15965: URL: https://github.com/apache/flink/pull/15965 -- 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

[jira] [Commented] (FLINK-23169) Support user-level app staging directory when yarn.staging-directory is specified

[ https://issues.apache.org/jira/browse/FLINK-23169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376979#comment-17376979 ] Yang Wang commented on FLINK-23169: --- Thanks [~hackergin] for proposing this ticket. Le

[jira] [Resolved] (FLINK-21804) Create and wire changelog writer with backend

[ https://issues.apache.org/jira/browse/FLINK-21804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-21804. -- Resolution: Fixed > Create and wire changelog writer with backend > --

[jira] [Commented] (FLINK-21804) Create and wire changelog writer with backend

[ https://issues.apache.org/jira/browse/FLINK-21804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376978#comment-17376978 ] Yun Tang commented on FLINK-21804: -- Merged master: e1ea4d960b191565a191c74e455e324fbb52

[GitHub] [flink] Myasuka merged pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

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

[GitHub] [flink] flinkbot edited a comment on pull request #16416: [FLINK-22657][Connectors/Hive] HiveParserDDLSemanticAnalyzer return operations directly

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

[GitHub] [flink] flinkbot edited a comment on pull request #16349: [FLINK-23267][table-planner-blink] Enable Java code splitting for all generated classes

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

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376971#comment-17376971 ] longwang0616 commented on FLINK-22969: -- [~luoyuxia] Hello, I created a pull request

[jira] [Assigned] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

[ https://issues.apache.org/jira/browse/FLINK-23298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-23298: -- Assignee: fhan > [datagen] Normalize parameter names in RandomGeneratorVisitor and > SequenceGenerat

[GitHub] [flink] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665830690 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartitionDirectTransferReader.java ## @@ -91,10 +9

[GitHub] [flink] Zakelly commented on pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

Zakelly commented on pull request #16341: URL: https://github.com/apache/flink/pull/16341#issuecomment-876077629 Thanks a lot for your detailed review @rkhachatryan and @Myasuka -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] Myasuka commented on pull request #16341: [FLINK-21804][state/changelog] Create and wire changelog storage with state backend

Myasuka commented on pull request #16341: URL: https://github.com/apache/flink/pull/16341#issuecomment-876076918 Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

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

[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376969#comment-17376969 ] Xintong Song commented on FLINK-20329: -- 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=17376970#comment-17376970 ] Xintong Song commented on FLINK-20329: -- https://dev.azure.com/apache-flink/apache-f

[GitHub] [flink] flinkbot commented on pull request #16417: FLINK-22969

flinkbot commented on pull request #16417: URL: https://github.com/apache/flink/pull/16417#issuecomment-876076375 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] wsry commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r665829387 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -315,6 +326,17 @@ BufferAndBacklog

[jira] [Updated] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22969: --- Labels: pull-request-available starter (was: starter) > Validate the topic is not null or e

[GitHub] [flink] LongWangXX opened a new pull request #16417: FLINK-22969

LongWangXX opened a new pull request #16417: URL: https://github.com/apache/flink/pull/16417 ## What is the purpose of the change Fix FLINK-22969, verify that topic is not null and not an empty string when creating KafkaSourceFunction and KafkaSinkFunction。 ## Brief ch

[jira] [Commented] (FLINK-23300) Job fails very slow because of no notifyAllocationFailure for DeclarativeSlotManager

[ https://issues.apache.org/jira/browse/FLINK-23300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376966#comment-17376966 ] Zhilong Hong commented on FLINK-23300: -- I think FLINK-23202 and FLINK-23209 are wor

[GitHub] [flink] hehuiyuan removed a comment on pull request #15965: [FLINK-23298][datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

hehuiyuan removed a comment on pull request #15965: URL: https://github.com/apache/flink/pull/15965#issuecomment-876066968 Hi @luoyuxia here. -- 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] JingsongLi merged pull request #16411: [FLINK-23184][table-runtime-blink] Fix compile error in code generation of unary plus and minus

JingsongLi merged pull request #16411: URL: https://github.com/apache/flink/pull/16411 -- 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-unsu

[jira] [Commented] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

[ https://issues.apache.org/jira/browse/FLINK-23298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376955#comment-17376955 ] fhan commented on FLINK-23298: -- [~luoyuxia]  i has  done it, please review > [datagen] Nor

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376953#comment-17376953 ] longwang0616 commented on FLINK-22969: -- okay, thank you. > Validate the topic is n

[jira] [Commented] (FLINK-22969) Validate the topic is not null or empty string when create kafka source/sink function

[ https://issues.apache.org/jira/browse/FLINK-22969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17376952#comment-17376952 ] luoyuxia commented on FLINK-22969: -- [~longwang0616] Hi, thanks for your contribution,

[jira] [Updated] (FLINK-23298) [datagen] Normalize parameter names in RandomGeneratorVisitor and SequenceGeneratorVisitor

[ https://issues.apache.org/jira/browse/FLINK-23298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23298: --- Labels: pull-request-available (was: ) > [datagen] Normalize parameter names in RandomGener

  1   2   3   4   5   >