[jira] [Commented] (FLINK-23678) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

2021-08-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397832#comment-17397832 ] Arvid Heise commented on FLINK-23678: - Ignoring test in ac42bb3d146 on master. >

[jira] [Commented] (FLINK-23678) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

2021-08-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397830#comment-17397830 ] Arvid Heise commented on FLINK-23678: - The new errors are related to FLINK-23408. We do not see a

[jira] [Updated] (FLINK-23678) KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails on azure

2021-08-11 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23678: Attachment: extracted.log > KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee fails

[GitHub] [flink] mans2singh commented on pull request #16639: [FLINK-23549][connector][kafka][docs] - Corrected syntax error in create table example

2021-08-11 Thread GitBox
mans2singh commented on pull request #16639: URL: https://github.com/apache/flink/pull/16639#issuecomment-897358660 Thanks @Airblader for your review. @tsreaper, can you please advice on this PR ? Thanks -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #16775: [FLINK-23716][docs-zh] Translate the 'Zipping Elements in a DataSet' page inito Chinese

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16775: URL: https://github.com/apache/flink/pull/16775#issuecomment-896508926 ## CI report: * 4d8ef90d7598c8b0e2b8d52d5ba78b7c8d54d3bb Azure:

[jira] [Updated] (FLINK-23616) Support to chain the Python DataStream operators as much as possible

2021-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23616: Summary: Support to chain the Python DataStream operators as much as possible (was: Support to chain for

[jira] [Updated] (FLINK-23616) Support to chain for the Python operators as much as possible

2021-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23616: Fix Version/s: 1.14.0 > Support to chain for the Python operators as much as possible >

[jira] [Closed] (FLINK-23616) Support to chain for the Python operators as much as possible

2021-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23616. --- Resolution: Fixed Merged to master via 54beaafff580bb3a65ffe58796b2ca8306631079 > Support to chain for the

[jira] [Comment Edited] (FLINK-23616) Support to chain for the Python operators as much as possible

2021-08-11 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397823#comment-17397823 ] Dian Fu edited comment on FLINK-23616 at 8/12/21, 5:19 AM: --- Merged to master

[GitHub] [flink] dianfu closed pull request #16777: [FLINK-23616][python] Support to chain the Python DataStream operators as much as possible

2021-08-11 Thread GitBox
dianfu closed pull request #16777: URL: https://github.com/apache/flink/pull/16777 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #16777: [FLINK-23616][python] Support to chain the Python DataStream operators as much as possible

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16777: URL: https://github.com/apache/flink/pull/16777#issuecomment-896614619 ## CI report: * a3351fa3c0f680ef03c823d0d7117f52b4e1d5f2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16775: [FLINK-23716][docs-zh] Translate the 'Zipping Elements in a DataSet' page inito Chinese

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16775: URL: https://github.com/apache/flink/pull/16775#issuecomment-896508926 ## CI report: * 4d8ef90d7598c8b0e2b8d52d5ba78b7c8d54d3bb Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16787: URL: https://github.com/apache/flink/pull/16787#issuecomment-897334392 ## CI report: * 55e7f2a3969b219619d45de47ecd45f2ff8045b6 Azure:

[GitHub] [flink] RocMarshal commented on a change in pull request #16313: [FLINK-12403][doc-zh]Translate 'How to use logging' page into Chinese

2021-08-11 Thread GitBox
RocMarshal commented on a change in pull request #16313: URL: https://github.com/apache/flink/pull/16313#discussion_r687382349 ## File path: docs/content.zh/docs/deployment/advanced/logging.md ## @@ -27,86 +27,102 @@ under the License. # 如何使用日志记录 -Flink 中的日志记录是使用 slf4j

[jira] [Closed] (FLINK-23718) Manage StateFun Python SDK as a Maven module

2021-08-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-23718. --- Fix Version/s: statefun-3.1.0 Resolution: Fixed flink-statefun/master:

[GitHub] [flink-statefun] tzulitai closed pull request #256: [FLINK-20574] [core] Block first request to mitigate excessive IncompleteInvocationContext roundtrips in RequestReplyFunction

2021-08-11 Thread GitBox
tzulitai closed pull request #256: URL: https://github.com/apache/flink-statefun/pull/256 -- 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:

[jira] [Closed] (FLINK-23714) Expose both master and worker logs when using StatefulFunctionsAppContainers

2021-08-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-23714. --- Resolution: Fixed flink-statefun/master: 0cbb4075d8dd3cf169051c149e8707fd7ed99b35

[jira] [Closed] (FLINK-23717) Allow setting configs using plain strings in StatefulFunctionsAppContainers

2021-08-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai closed FLINK-23717. --- Fix Version/s: statefun-3.1.0 Resolution: Fixed flink-statefun/master:

[GitHub] [flink-statefun] tzulitai closed pull request #254: [e2e] Minor e2e utility improvements

2021-08-11 Thread GitBox
tzulitai closed pull request #254: URL: https://github.com/apache/flink-statefun/pull/254 -- 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:

[GitHub] [flink-statefun] tzulitai closed pull request #255: [FLINK-23718] [build, sdk] Manage Python SDK as a Maven module

2021-08-11 Thread GitBox
tzulitai closed pull request #255: URL: https://github.com/apache/flink-statefun/pull/255 -- 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:

[GitHub] [flink-statefun] tzulitai opened a new pull request #256: [FLINK-20574] [core] Block first request to mitigate excessive IncompleteInvocationContext roundtrips in RequestReplyFunction

2021-08-11 Thread GitBox
tzulitai opened a new pull request #256: URL: https://github.com/apache/flink-statefun/pull/256 For the first request, we block until response is received; for stateful applications, especially at restore time of a restored execution where there may be a large backlog of events and

[GitHub] [flink] wuchong commented on a change in pull request #16779: [FLINK-22673][docs] Add docs about JAR related commands and remove th…

2021-08-11 Thread GitBox
wuchong commented on a change in pull request #16779: URL: https://github.com/apache/flink/pull/16779#discussion_r687375789 ## File path: docs/content/docs/dev/table/sql/show.md ## @@ -498,4 +501,14 @@ Show all enabled module names with resolution order. **FULL** Show all

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

2021-08-11 Thread xuliantao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397814#comment-17397814 ] xuliantao commented on FLINK-12122: --- [~trohrmann] Hi, thanks for your reply. I understand the reason

[jira] [Closed] (FLINK-23645) Sqlclient doesn't response CTRL-C correctly before Executor ResultView opening.

2021-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23645. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: c54084a8bb124fb88b0effee4d01f4a1ceb02f17 >

[jira] [Commented] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

2021-08-11 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397807#comment-17397807 ] Yingjie Cao commented on FLINK-23724: -  [~pnowojski] [~akalashnikov], do you have time to take a

[GitHub] [flink] flinkbot commented on pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

2021-08-11 Thread GitBox
flinkbot commented on pull request #16787: URL: https://github.com/apache/flink/pull/16787#issuecomment-897334392 ## CI report: * 55e7f2a3969b219619d45de47ecd45f2ff8045b6 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] wuchong merged pull request #16743: [FLINK-23645][Table SQL / Client] Fix SqlClient doesn't response correctly to Signal.INT

2021-08-11 Thread GitBox
wuchong merged pull request #16743: URL: https://github.com/apache/flink/pull/16743 -- 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:

[GitHub] [flink] flinkbot edited a comment on pull request #16746: [FLINK-22452][docs] list the configuration methods of FlinkKafkaProducer and add ProducerFencedException in Troubleshooting

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16746: URL: https://github.com/apache/flink/pull/16746#issuecomment-894638219 ## CI report: * d8cb176025fbc672c7df26647a5cedcf119765dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * 7343f8b1adde98e86eba0f3bcbc647df92f82223 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * 7b77e253865d75fe6e013e2ceef3dd851c10 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16522: [FLINK-11634][docs] Translate "State Backends" page into Chinese

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16522: URL: https://github.com/apache/flink/pull/16522#issuecomment-881941941 ## CI report: * d6a6def0fdafcbd4b8fda2bce37821b129cf6011 UNKNOWN * 90461b1e0ad45cdf4f8908edd26627192bbd139a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16467: [FLINK-23309][python] Optimize the finish bundle logic in PyFlink

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16467: URL: https://github.com/apache/flink/pull/16467#issuecomment-878120698 ## CI report: * 76064d25e35a22383d86db691bec3a2f3c89374f Azure:

[jira] [Updated] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

2021-08-11 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-23724: Affects Version/s: 1.13.2 > Network buffer leak when ResultPartition is released (failover) >

[jira] [Updated] (FLINK-23724) Network buffer leak when ResultPartition is released (failover)

2021-08-11 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-23724: Fix Version/s: 1.13.3 > Network buffer leak when ResultPartition is released (failover) >

[jira] [Updated] (FLINK-23733) sdsd

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23733: - Fix Version/s: (was: 1.15.0) > sdsd > > > Key: FLINK-23733 >

[jira] [Updated] (FLINK-23666) Flaky test: SQLClientSchemaRegistryITCase.testWriting

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23666: - Fix Version/s: (was: 1.15.0) (was: 1.14.0) > Flaky test:

[jira] [Comment Edited] (FLINK-22198) KafkaTableITCase hang.

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397795#comment-17397795 ] Xintong Song edited comment on FLINK-22198 at 8/12/21, 3:51 AM:

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397795#comment-17397795 ] Xintong Song commented on FLINK-22198: -- [~renqs], [~amonbeckler] Could you help look into this? It

[GitHub] [flink] RocMarshal commented on pull request #16775: [FLINK-23716][docs-zh] Translate the 'Zipping Elements in a DataSet' page inito Chinese

2021-08-11 Thread GitBox
RocMarshal commented on pull request #16775: URL: https://github.com/apache/flink/pull/16775#issuecomment-897327070 @wuchong Updated based on your suggestions. Thank you very much. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] lirui-apache commented on a change in pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

2021-08-11 Thread GitBox
lirui-apache commented on a change in pull request #16430: URL: https://github.com/apache/flink/pull/16430#discussion_r687362164 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java ## @@ -133,66 +123,22 @@

[GitHub] [flink] lirui-apache commented on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-11 Thread GitBox
lirui-apache commented on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-897325502 It seems strange to me that we need to set owner differently depending on whether kerberose is enabled. This is not how Hive sets the owner, and can be confusing to users.

[GitHub] [flink] flinkbot commented on pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

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

[GitHub] [flink] luoyuxia commented on a change in pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

2021-08-11 Thread GitBox
luoyuxia commented on a change in pull request #16430: URL: https://github.com/apache/flink/pull/16430#discussion_r687358172 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java ## @@ -133,66 +123,22 @@ public

[jira] [Updated] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese

2021-08-11 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18080: --- Labels: auto-unassigned pull-request-available (was: auto-unassigned) > Translate the

[GitHub] [flink] hapihu opened a new pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

2021-08-11 Thread GitBox
hapihu opened a new pull request #16787: URL: https://github.com/apache/flink/pull/16787 https://ci.apache.org/projects/flink/flink-docs-master/zh/docs/deployment/security/security-kerberos/ Translate "security-kerberos" page into Chinese -- This is an automated message from the

[GitHub] [flink] flinkbot edited a comment on pull request #16746: [FLINK-22452][docs] list the configuration methods of FlinkKafkaProducer and add ProducerFencedException in Troubleshooting

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16746: URL: https://github.com/apache/flink/pull/16746#issuecomment-894638219 ## CI report: * d8cb176025fbc672c7df26647a5cedcf119765dd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * 7343f8b1adde98e86eba0f3bcbc647df92f82223 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16687: URL: https://github.com/apache/flink/pull/16687#issuecomment-891705871 ## CI report: * 7b77e253865d75fe6e013e2ceef3dd851c10 Azure:

[GitHub] [flink] lirui-apache commented on pull request #16745: [FLINK-22246]when use HiveCatalog create table , can't set Table owne…

2021-08-11 Thread GitBox
lirui-apache commented on pull request #16745: URL: https://github.com/apache/flink/pull/16745#issuecomment-897322459 > > > > wouldn't that trigger the issue first before you can create any tables? > > > > > > > > > no, HMS allows requests to get all information, and HMS does

[GitHub] [flink] flinkbot edited a comment on pull request #16467: [FLINK-23309][python] Optimize the finish bundle logic in PyFlink

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16467: URL: https://github.com/apache/flink/pull/16467#issuecomment-878120698 ## CI report: * 76064d25e35a22383d86db691bec3a2f3c89374f Azure:

[jira] [Commented] (FLINK-23713) SavepointITCase.testStopWithSavepointWithDrainGlobalFailoverIfSavepointAborted failed with "Stop with savepoint operation could not be completed"

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397787#comment-17397787 ] Xintong Song commented on FLINK-23713: --

[jira] [Commented] (FLINK-23351) FileReadingWatermarkITCase.testWatermarkEmissionWithChaining fails due to "too few watermarks emitted" on azure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397786#comment-17397786 ] Xintong Song commented on FLINK-23351: --

[jira] [Closed] (FLINK-23733) sdsd

2021-08-11 Thread kaohaonan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaohaonan closed FLINK-23733. - Resolution: Fixed > sdsd > > > Key: FLINK-23733 > URL:

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22198: - Affects Version/s: 1.14.0 > KafkaTableITCase hang. > -- > >

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22198: - Fix Version/s: 1.14.0 > KafkaTableITCase hang. > -- > >

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397785#comment-17397785 ] Xintong Song commented on FLINK-22198: --

[jira] [Created] (FLINK-23733) sdsd

2021-08-11 Thread kaohaonan (Jira)
kaohaonan created FLINK-23733: - Summary: sdsd Key: FLINK-23733 URL: https://issues.apache.org/jira/browse/FLINK-23733 Project: Flink Issue Type: Improvement Affects Versions: 1.14.0

[jira] [Updated] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-23047: - Affects Version/s: 1.13.2 > CassandraConnectorITCase.testCassandraBatchTupleFormat fails on

[jira] [Commented] (FLINK-23047) CassandraConnectorITCase.testCassandraBatchTupleFormat fails on azure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397783#comment-17397783 ] Xintong Song commented on FLINK-23047: --

[jira] [Commented] (FLINK-22932) RocksDBStateBackendWindowITCase fails with savepoint timeout

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397781#comment-17397781 ] Xintong Song commented on FLINK-22932: --

[jira] [Updated] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20558: - Labels: test-stability testability (was: auto-deprioritized-major test-stability testability)

[jira] [Commented] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397780#comment-17397780 ] Xintong Song commented on FLINK-20558: --

[jira] [Updated] (FLINK-20558) ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific test failure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20558: - Priority: Major (was: Minor) > ParquetAvroStreamingFileSinkITCase.testWriteParquetAvroSpecific

[GitHub] [flink] ChangjiGuo edited a comment on pull request #14376: [FLINK-18202][PB format] New Format of protobuf

2021-08-11 Thread GitBox
ChangjiGuo edited a comment on pull request #14376: URL: https://github.com/apache/flink/pull/14376#issuecomment-895924402 Hi, @maosuhan thanks a lot for your work. I found a bug with this pr. proto shcema: `map pv_raw_features = 5;` generated code: ```java Object

[jira] [Commented] (FLINK-23493) python tests hang on Azure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397779#comment-17397779 ] Xintong Song commented on FLINK-23493: --

[GitHub] [flink] lirui-apache commented on a change in pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

2021-08-11 Thread GitBox
lirui-apache commented on a change in pull request #16430: URL: https://github.com/apache/flink/pull/16430#discussion_r687337673 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java ## @@ -133,66 +123,22 @@

[jira] [Updated] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-22869: - Affects Version/s: 1.13.2 > SQLClientSchemaRegistryITCase timeouts on azure >

[jira] [Commented] (FLINK-22869) SQLClientSchemaRegistryITCase timeouts on azure

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397776#comment-17397776 ] Xintong Song commented on FLINK-22869: --

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397773#comment-17397773 ] Xintong Song commented on FLINK-22198: --

[GitHub] [flink] flinkbot edited a comment on pull request #16777: [FLINK-23616][python] Support to chain the Python DataStream operators as much as possible

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16777: URL: https://github.com/apache/flink/pull/16777#issuecomment-896614619 ## CI report: * d466870051d68f13029d119e1d2ae8e36fb5efcd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #16603: [FLINK-23111][runtime-web] Bump angular's and ng-zorro's version to 12

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16603: URL: https://github.com/apache/flink/pull/16603#issuecomment-887338670 ## CI report: * 2d804307c02b930091d03f45b6285546214e3f89 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16522: [FLINK-11634][docs] Translate "State Backends" page into Chinese

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16522: URL: https://github.com/apache/flink/pull/16522#issuecomment-881941941 ## CI report: * 477a6d6915b2c8f228463ce81ecc53335585cdb5 Azure:

[jira] [Assigned] (FLINK-20574) Throttle number of remote invocation requests on startup or restores with large backlogs

2021-08-11 Thread Tzu-Li (Gordon) Tai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-20574: --- Assignee: Tzu-Li (Gordon) Tai > Throttle number of remote invocation

[GitHub] [flink] HuangXingBo commented on a change in pull request #16467: [FLINK-23309][python] Optimize the finish bundle logic in PyFlink

2021-08-11 Thread GitBox
HuangXingBo commented on a change in pull request #16467: URL: https://github.com/apache/flink/pull/16467#discussion_r687329191 ## File path: flink-python/pyflink/fn_execution/stream_fast.pyx ## @@ -94,6 +100,21 @@ cdef class OutputStream: self.buffer_size = 1024

[GitHub] [flink] Thesharing commented on a change in pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

2021-08-11 Thread GitBox
Thesharing commented on a change in pull request #16687: URL: https://github.com/apache/flink/pull/16687#discussion_r687326019 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -94,12 +97,33 @@

[GitHub] [flink] Thesharing commented on a change in pull request #16687: [FLINK-22767][coordination] Optimize the initialization of LocalInputPreferredSlotSharingStrategy

2021-08-11 Thread GitBox
Thesharing commented on a change in pull request #16687: URL: https://github.com/apache/flink/pull/16687#discussion_r687326019 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java ## @@ -94,12 +97,33 @@

[jira] [Commented] (FLINK-23731) Streaming File Sink s3 end-to-end test fail due to timeout

2021-08-11 Thread xingyuan cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397760#comment-17397760 ] xingyuan cheng commented on FLINK-23731: > Streaming File Sink s3 end-to-end test fail due to

[jira] [Created] (FLINK-23732) StatefulJobSavepointMigrationITCase.testRestoreSavepoint fails due to LoggerInitializationException

2021-08-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23732: Summary: StatefulJobSavepointMigrationITCase.testRestoreSavepoint fails due to LoggerInitializationException Key: FLINK-23732 URL:

[jira] [Closed] (FLINK-23731) Streaming File Sink s3 end-to-end test fail due to timeout

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song closed FLINK-23731. Resolution: Duplicate > Streaming File Sink s3 end-to-end test fail due to timeout >

[GitHub] [flink] flinkbot edited a comment on pull request #16777: [FLINK-23616][python] Support to chain the Python DataStream operators as much as possible

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16777: URL: https://github.com/apache/flink/pull/16777#issuecomment-896614619 ## CI report: * d466870051d68f13029d119e1d2ae8e36fb5efcd Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16776: [FLINK-16201][table] Support JSON_VALUE

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16776: URL: https://github.com/apache/flink/pull/16776#issuecomment-896566536 ## CI report: * b1b84c88e39ca2e07f7de8dd4734ddb65d373f18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16770: [FLINK-23652][datastream] FLIP-179: Add common connector metrics

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16770: URL: https://github.com/apache/flink/pull/16770#issuecomment-896050027 ## CI report: * ce61eedf5930a24fff2feeb5881c910253b8de3b UNKNOWN * 1924e887787a072b5db1c759424fdd9552885660 UNKNOWN *

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-20928: - Labels: test-stability (was: auto-deprioritized-critical stale-critical test-stability) >

[GitHub] [flink] flinkbot edited a comment on pull request #16603: [FLINK-23111][runtime-web] Bump angular's and ng-zorro's version to 12

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16603: URL: https://github.com/apache/flink/pull/16603#issuecomment-887338670 ## CI report: * 2d804307c02b930091d03f45b6285546214e3f89 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16522: [FLINK-11634][docs] Translate "State Backends" page into Chinese

2021-08-11 Thread GitBox
flinkbot edited a comment on pull request #16522: URL: https://github.com/apache/flink/pull/16522#issuecomment-881941941 ## CI report: * 477a6d6915b2c8f228463ce81ecc53335585cdb5 Azure:

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

2021-08-11 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397755#comment-17397755 ] Xintong Song commented on FLINK-20928: --

[GitHub] [flink] wuchong commented on a change in pull request #16775: [FLINK-23716][docs-zh] Translate the 'Zipping Elements in a DataSet' page inito Chinese

2021-08-11 Thread GitBox
wuchong commented on a change in pull request #16775: URL: https://github.com/apache/flink/pull/16775#discussion_r687321032 ## File path: docs/content.zh/docs/dev/dataset/zip_elements_guide.md ## @@ -80,15 +85,17 @@ env.execute() {{< /tab >}} {{< /tabs >}} -may yield the

[jira] [Closed] (FLINK-23685) Translate "Java Lambda Expressions" page into Chinese

2021-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23685. --- Fix Version/s: 1.14.0 Resolution: Fixed Fixed in master: 887444f4c12ac6b0239362781a3acfacb7fb6df8 >

[GitHub] [flink] wuchong merged pull request #16753: [FLINK-23685][docs-zh] Translate "Java Lambda Expressions" page into …

2021-08-11 Thread GitBox
wuchong merged pull request #16753: URL: https://github.com/apache/flink/pull/16753 -- 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:

[GitHub] [flink] wuchong commented on pull request #16753: [FLINK-23685][docs-zh] Translate "Java Lambda Expressions" page into …

2021-08-11 Thread GitBox
wuchong commented on pull request #16753: URL: https://github.com/apache/flink/pull/16753#issuecomment-897298190 Thanks for the reviewing @RocMarshal and contribution @hapihu . Merging... -- This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Closed] (FLINK-23475) Handle BroadcastState with finished operators

2021-08-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei closed FLINK-23475. Fix Version/s: 1.14.0 Resolution: Fixed merged commit 

[jira] [Comment Edited] (FLINK-23475) Handle BroadcastState with finished operators

2021-08-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397751#comment-17397751 ] Yuan Mei edited comment on FLINK-23475 at 8/12/21, 2:25 AM: merged commit 

[jira] [Commented] (FLINK-23475) Handle BroadcastState with finished operators

2021-08-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397749#comment-17397749 ] Yuan Mei commented on FLINK-23475: -- merged commit 

[jira] [Issue Comment Deleted] (FLINK-23475) Handle BroadcastState with finished operators

2021-08-11 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yuan Mei updated FLINK-23475: - Comment: was deleted (was: merged commit 

[GitHub] [flink] luoyuxia commented on a change in pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

2021-08-11 Thread GitBox
luoyuxia commented on a change in pull request #16430: URL: https://github.com/apache/flink/pull/16430#discussion_r687316685 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java ## @@ -133,66 +123,22 @@ public

[jira] [Created] (FLINK-23731) Streaming File Sink s3 end-to-end test fail due to timeout

2021-08-11 Thread Xintong Song (Jira)
Xintong Song created FLINK-23731: Summary: Streaming File Sink s3 end-to-end test fail due to timeout Key: FLINK-23731 URL: https://issues.apache.org/jira/browse/FLINK-23731 Project: Flink

[jira] [Closed] (FLINK-23729) sql-client.sh fails on Git Bash for Windows, MinGW & MSYS2

2021-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-23729. --- Resolution: Invalid > sql-client.sh fails on Git Bash for Windows, MinGW & MSYS2 >

[jira] [Commented] (FLINK-23729) sql-client.sh fails on Git Bash for Windows, MinGW & MSYS2

2021-08-11 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17397748#comment-17397748 ] Jark Wu commented on FLINK-23729: - Flink only supports run on all UNIX-like environments, e.g. Linux,

[GitHub] [flink] luoyuxia commented on a change in pull request #16430: [FLINK-23032][hive] Refactor HiveSource to make it usable in data str…

2021-08-11 Thread GitBox
luoyuxia commented on a change in pull request #16430: URL: https://github.com/apache/flink/pull/16430#discussion_r687316685 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java ## @@ -133,66 +123,22 @@ public

  1   2   3   4   5   6   >