[jira] [Assigned] (FLINK-3370) Add an aligned version of the window operator

[ https://issues.apache.org/jira/browse/FLINK-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-3370: --- Assignee: (was: Stephan Ewen) > Add an aligned version of the window operator >

[jira] [Closed] (FLINK-3370) Add an aligned version of the window operator

[ https://issues.apache.org/jira/browse/FLINK-3370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3370. --- Resolution: Abandoned > Add an aligned version of the window operator >

[jira] [Closed] (FLINK-1101) Make memory management adaptive

[ https://issues.apache.org/jira/browse/FLINK-1101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1101. --- Resolution: Won't Fix A different solution has been implemented in the meantime. Instead of making

[jira] [Closed] (FLINK-1272) Add a "reduceWithKey" function

[ https://issues.apache.org/jira/browse/FLINK-1272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1272. --- Resolution: Abandoned Closing due to long inactivity. > Add a "reduceWithKey" function >

[GitHub] [flink-statefun] birbilis opened a new pull request #226: Update java.md

birbilis opened a new pull request #226: URL: https://github.com/apache/flink-statefun/pull/226 Changed Python mention to Java, probably left-over from python doc -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-1269) Easy way to "group count" dataset

[ https://issues.apache.org/jira/browse/FLINK-1269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1269. --- Resolution: Abandoned Closing this as abandoned due to long inactivity. > Easy way to "group count"

[GitHub] [flink] flinkbot edited a comment on pull request #15652: [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle

flinkbot edited a comment on pull request #15652: URL: https://github.com/apache/flink/pull/15652#issuecomment-821782680 ## CI report: * 38caca4f7b38bbc5811cd9ba5e890243e1709ce8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15483: [FLINK-22092][hive] Ignore static conf file URLs in HiveConf

flinkbot edited a comment on pull request #15483: URL: https://github.com/apache/flink/pull/15483#issuecomment-812520117 ## CI report: * d635372648a9d043a3526d7122eae3099d7f0ede Azure:

[jira] [Closed] (FLINK-2646) User functions should be able to differentiate between successful close and erroneous close

[ https://issues.apache.org/jira/browse/FLINK-2646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-2646. --- Resolution: Staged Closing this issue, as this has been inactive for long and there needs to be

[GitHub] [flink] flinkbot edited a comment on pull request #15483: [FLINK-22092][hive] Ignore static conf file URLs in HiveConf

flinkbot edited a comment on pull request #15483: URL: https://github.com/apache/flink/pull/15483#issuecomment-812520117 ## CI report: * d635372648a9d043a3526d7122eae3099d7f0ede Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15653: [FLINK-22329] Inject current ugi credentials into jobconf when getting file split in hive connector

flinkbot edited a comment on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-821801891 ## CI report: * 41dbfa9649149d9616337cccf4fc8f6c6f59a9c5 Azure:

[GitHub] [flink] zuston commented on pull request #15653: [FLINK-22329] Inject current ugi credentials into jobconf when getting file split in hive connector

zuston commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-821802718 Do you have time to review it? @wuchong @lirui-apache . Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22329: - Description: Related Flink code:

[jira] [Updated] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22329: - Description: Related Flink code:

[GitHub] [flink] flinkbot commented on pull request #15653: [FLINK-22329] Inject current ugi credentials into jobconf when getting file split in hive connector

flinkbot commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-821801891 ## CI report: * 41dbfa9649149d9616337cccf4fc8f6c6f59a9c5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] curcur commented on pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

curcur commented on pull request #15636: URL: https://github.com/apache/flink/pull/15636#issuecomment-821800955 Hey, @rkhachatryan , I've done with the review. 1. Overall the logic is pretty clear, please refer to a few of my comments. 2. The exactly-once end2end test is too

[GitHub] [flink] flinkbot commented on pull request #15653: [FLINK-22329] Inject current ugi credentials into jobconf when getting file split in hive connector

flinkbot commented on pull request #15653: URL: https://github.com/apache/flink/pull/15653#issuecomment-821800733 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] curcur commented on a change in pull request #15636: [FLINK-22239][jdbc] Support exactly-once (sink) for PgSql and MySql

curcur commented on a change in pull request #15636: URL: https://github.com/apache/flink/pull/15636#discussion_r615231118 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacadePoolingImpl.java ## @@ -0,0 +1,183 @@ +/* +

[jira] [Commented] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324223#comment-17324223 ] Junfan Zhang commented on FLINK-22329: -- [~jark] Cloud you assign this task to me. Thanks > Missing

[jira] [Comment Edited] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324223#comment-17324223 ] Junfan Zhang edited comment on FLINK-22329 at 4/17/21, 10:11 AM: -

[jira] [Updated] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22329: --- Labels: pull-request-available (was: ) > Missing crendentials in jobconf causes repeated

[GitHub] [flink] zuston opened a new pull request #15653: [FLINK-22329] Inject current ugi credentials into jobconf when getting file split in hive connector

zuston opened a new pull request #15653: URL: https://github.com/apache/flink/pull/15653 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them on

[jira] [Updated] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasource

[ https://issues.apache.org/jira/browse/FLINK-22329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-22329: - Summary: Missing crendentials in jobconf causes repeated authentication in Hive datasource

[jira] [Created] (FLINK-22329) Missing crendentials in jobconf causes repeated authentication in Hive datasources

Junfan Zhang created FLINK-22329: Summary: Missing crendentials in jobconf causes repeated authentication in Hive datasources Key: FLINK-22329 URL: https://issues.apache.org/jira/browse/FLINK-22329

[jira] [Comment Edited] (FLINK-22294) Hive reading fail when getting file numbers on different filesystem nameservices

[ https://issues.apache.org/jira/browse/FLINK-22294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322117#comment-17322117 ] Junfan Zhang edited comment on FLINK-22294 at 4/17/21, 10:03 AM: - Could

[GitHub] [flink] flinkbot edited a comment on pull request #15569: [FLINK-21247][table] Fix problem in MapDataSerializer#copy when there…

flinkbot edited a comment on pull request #15569: URL: https://github.com/apache/flink/pull/15569#issuecomment-817675895 ## CI report: * c62a25d1ffa4f2f6f76be2b11b77d9c3126d50c4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15651: [FLINK-22307][network] Increase the data writing cache size of sort-merge blocking shuffle

flinkbot edited a comment on pull request #15651: URL: https://github.com/apache/flink/pull/15651#issuecomment-821767454 ## CI report: * 3d65a719c16d9aaf8a44f843e2e21d1719947559 UNKNOWN * c840d852f79ed239c164c4809f36529bed7ffe5d Azure:

[jira] [Closed] (FLINK-22325) Channel state iterator is accessed concurrently without proper synchronization

[ https://issues.apache.org/jira/browse/FLINK-22325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-22325. - Fix Version/s: (was: 1.12.3) Resolution: Invalid Closing as invalid (as

[jira] [Updated] (FLINK-22325) Channel state iterator is accessed concurrently without proper synchronization

[ https://issues.apache.org/jira/browse/FLINK-22325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-22325: -- Affects Version/s: (was: 1.12.2) > Channel state iterator is accessed

[GitHub] [flink] rkhachatryan closed pull request #15646: [FLINK-22325][runtime] Synchronize access to iterator when writing channel state

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

[jira] [Resolved] (FLINK-22117) Not print stack trace for checkpoint trigger failure if not all tasks are started.

[ https://issues.apache.org/jira/browse/FLINK-22117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-22117. --- Fix Version/s: 1.13.0 Assignee: Yun Gao Resolution: Fixed Merged

[GitHub] [flink] rkhachatryan commented on pull request #15643: [FLINK-22117] Reduce the logs if not all tasks are RUNNING when checkpointing

rkhachatryan commented on pull request #15643: URL: https://github.com/apache/flink/pull/15643#issuecomment-821792260 Thanks for updating the PR @gaoyunhaii! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] rkhachatryan merged pull request #15643: [FLINK-22117] Reduce the logs if not all tasks are RUNNING when checkpointing

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

[jira] [Comment Edited] (FLINK-22311) Flink JDBC XA connector need to set maxRetries to 0 to properly working

[ https://issues.apache.org/jira/browse/FLINK-22311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324171#comment-17324171 ] Maciej Bryński edited comment on FLINK-22311 at 4/17/21, 8:34 AM: -- This

[jira] [Commented] (FLINK-22141) Manually test exactly-once JDBC sink

[ https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324199#comment-17324199 ] Maciej Bryński commented on FLINK-22141: [~ym] No problem at all. We have this code integrated

[GitHub] [flink] flinkbot edited a comment on pull request #15652: [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle

flinkbot edited a comment on pull request #15652: URL: https://github.com/apache/flink/pull/15652#issuecomment-821782680 ## CI report: * 38caca4f7b38bbc5811cd9ba5e890243e1709ce8 Azure:

[GitHub] [flink] flinkbot commented on pull request #15652: [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle

flinkbot commented on pull request #15652: URL: https://github.com/apache/flink/pull/15652#issuecomment-821782680 ## CI report: * 38caca4f7b38bbc5811cd9ba5e890243e1709ce8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-13247) Implement external shuffle service for YARN

[ https://issues.apache.org/jira/browse/FLINK-13247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324189#comment-17324189 ] Jiayi Liao commented on FLINK-13247: Actually we've already implemented Yarn shuffle service in our

[GitHub] [flink] flinkbot commented on pull request #15652: [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle

flinkbot commented on pull request #15652: URL: https://github.com/apache/flink/pull/15652#issuecomment-821780333 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

[jira] [Updated] (FLINK-22305) Improve log messages of sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22305: --- Labels: pull-request-available (was: ) > Improve log messages of sort-merge blocking

[GitHub] [flink] wsry opened a new pull request #15652: [FLINK-22305][network] Improve log messages of sort-merge blocking shuffle

wsry opened a new pull request #15652: URL: https://github.com/apache/flink/pull/15652 ## What is the purpose of the change Improve log messages of sort-merge blocking shuffle. ## Brief change log - Improve log messages of sort-merge blocking shuffle.

[jira] [Updated] (FLINK-22328) Failed to send data to Kafka: Producer attempted an operation with an old epoch

[ https://issues.apache.org/jira/browse/FLINK-22328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 孙峰 updated FLINK-22328: --- Environment: kafka 3.0.0 Flink 1.11.1 was:kafka 3.0.0 Labels: Transactional kafka (was: ) > Failed

[jira] [Created] (FLINK-22328) Failed to send data to Kafka: Producer attempted an operation with an old epoch

孙峰 created FLINK-22328: -- Summary: Failed to send data to Kafka: Producer attempted an operation with an old epoch Key: FLINK-22328 URL: https://issues.apache.org/jira/browse/FLINK-22328 Project: Flink

[jira] [Updated] (FLINK-22305) Improve log messages of sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22305: Summary: Improve log messages of sort-merge blocking shuffle (was: Improve log message of

[jira] [Updated] (FLINK-22305) Improve log message of sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22305: Summary: Improve log message of sort-merge blocking shuffle (was: Increase the default value of

[jira] [Commented] (FLINK-22305) Increase the default value of taskmanager.network.sort-shuffle.min-buffers

[ https://issues.apache.org/jira/browse/FLINK-22305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324181#comment-17324181 ] Yingjie Cao commented on FLINK-22305: - After some tests, I find that increasing this default value

[GitHub] [flink] flinkbot edited a comment on pull request #15651: [FLINK-22307][network] Increase the data writing cache size of sort-merge blocking shuffle

flinkbot edited a comment on pull request #15651: URL: https://github.com/apache/flink/pull/15651#issuecomment-821767454 ## CI report: * 3d65a719c16d9aaf8a44f843e2e21d1719947559 UNKNOWN * c840d852f79ed239c164c4809f36529bed7ffe5d Azure:

<    1   2