[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-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 shuffl

[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 pro

[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&focusedCommentId=17324189#comment-17324189 ] Jiayi Liao commented on FLINK-13247: Actually we've already implemented Yarn shuffle

[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 r

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

[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&focusedCommentId=17324199#comment-17324199 ] Maciej Bryński commented on FLINK-22141: [~ym] No problem at all. We have this

[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&focusedCommentId=17324171#comment-17324171 ] Maciej Bryński edited comment on FLINK-22311 at 4/17/21, 8:34 AM:

[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, p

[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 abo

[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 int

[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, p

[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 concurrently

[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 there

[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: [SUCCESS](https://dev.azure.com/apache-fl

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

[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&focusedCommentId=17322117#comment-17322117 ] Junfan Zhang edited comment on FLINK-22294 at 4/17/21, 10:03 AM: -

[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 Pr

[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 (was

[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 ] ASF GitHub Bot updated FLINK-22329: --- Labels: pull-request-available (was: ) > Missing crendentials in jobconf causes repeated au

[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&focusedCommentId=17324223#comment-17324223 ] Junfan Zhang edited comment on FLINK-22329 at 4/17/21, 10:11 AM: -

[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&focusedCommentId=17324223#comment-17324223 ] Junfan Zhang commented on FLINK-22329: -- [~jark] Cloud you assign this task to me. T

[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 @@ +/* + *

[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 pro

[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 simple

[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 r

[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: [https://github.com/apache/flink/blob/577113f0c339df844f2cc32b

[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: [https://github.com/apache/flink/blob/577113f0c339df844f2cc32b

[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 an

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

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

[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 solu

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

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

[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-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 UR

[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 > ---

[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 t

[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] [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] [Updated] (FLINK-19499) Expose Metric Groups to Split Assigners

[ https://issues.apache.org/jira/browse/FLINK-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19499: - Labels: (was: stale-assigned) > Expose Metric Groups to Split Assigners >

[jira] [Assigned] (FLINK-19499) Expose Metric Groups to Split Assigners

[ https://issues.apache.org/jira/browse/FLINK-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-19499: Assignee: (was: Stephan Ewen) > Expose Metric Groups to Split Assigners > ---

[jira] [Assigned] (FLINK-19441) Performance regression on 24.09.2020

[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-19441: Assignee: (was: Stephan Ewen) > Performance regression on 24.09.2020 > --

[jira] [Updated] (FLINK-19441) Performance regression on 24.09.2020

[ https://issues.apache.org/jira/browse/FLINK-19441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19441: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Performance regre

[GitHub] [flink-statefun] birbilis opened a new pull request #227: Update java.md - fixed code typo

birbilis opened a new pull request #227: URL: https://github.com/apache/flink-statefun/pull/227 fixed code snippet typo -- 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

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

birbilis opened a new pull request #228: URL: https://github.com/apache/flink-statefun/pull/228 typo in json declaration -- 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. Fo

[jira] [Closed] (FLINK-3389) Add Pre-defined Options settings for RocksDB State backend

[ https://issues.apache.org/jira/browse/FLINK-3389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3389. --- Resolution: Done > Add Pre-defined Options settings for RocksDB State backend > -

[jira] [Assigned] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-9043: --- Assignee: (was: Sihua Zhou) > Introduce a friendly way to resume the job from externaliz

[jira] [Updated] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-9043: Labels: pull-request-available (was: pull-request-available stale-assigned) > Introduce a friendly

[GitHub] [flink-statefun] birbilis commented on pull request #226: Update java.md

birbilis commented on pull request #226: URL: https://github.com/apache/flink-statefun/pull/226#issuecomment-821814553 not sure what the second change at the "keep learning" shown in the diff is about, used GitHub's online editor for the patch -- This is an automated message from the Apa

[GitHub] [flink-statefun] birbilis commented on pull request #227: Update java.md - fixed code typo

birbilis commented on pull request #227: URL: https://github.com/apache/flink-statefun/pull/227#issuecomment-821814574 not sure what the second change at the "keep learning" shown in the diff is about, used GitHub's online editor for the patch -- This is an automated message from the Apa

[GitHub] [flink-statefun] birbilis commented on pull request #228: Update java.md

birbilis commented on pull request #228: URL: https://github.com/apache/flink-statefun/pull/228#issuecomment-821814585 not sure what the second change at the "keep learning" shown in the diff is about, used GitHub's online editor for the patch -- This is an automated message from the Apa

[GitHub] [flink-statefun] birbilis commented on pull request #224: [hotfix][docs] Fix typos in java.md

birbilis commented on pull request #224: URL: https://github.com/apache/flink-statefun/pull/224#issuecomment-821814838 seems I suggested the same fix here - https://github.com/apache/flink-statefun/pull/227 - for the 2nd typo, closing mine -- This is an automated message from the Apache

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324255#comment-17324255 ] Stephan Ewen commented on FLINK-9043: - I think this might be a good one to revisit no

[GitHub] [flink-statefun] birbilis closed pull request #227: Update java.md - fixed code typo

birbilis closed pull request #227: URL: https://github.com/apache/flink-statefun/pull/227 -- 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,

[GitHub] [flink-statefun] birbilis commented on pull request #227: Update java.md - fixed code typo

birbilis commented on pull request #227: URL: https://github.com/apache/flink-statefun/pull/227#issuecomment-821814938 already proposed by other, see mention above -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[jira] [Closed] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4374. --- Resolution: Abandoned Closing as abandoned, due to long inactivity. > GroupReduce Broken for null Da

[jira] [Updated] (FLINK-1778) Improve normalized keys in composite key case

[ https://issues.apache.org/jira/browse/FLINK-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-1778: Labels: (was: stale-assigned) > Improve normalized keys in composite key case > -

[jira] [Assigned] (FLINK-1778) Improve normalized keys in composite key case

[ https://issues.apache.org/jira/browse/FLINK-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-1778: --- Assignee: (was: Stephan Ewen) > Improve normalized keys in composite key case >

[jira] [Closed] (FLINK-1778) Improve normalized keys in composite key case

[ https://issues.apache.org/jira/browse/FLINK-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-1778. --- Resolution: Abandoned Closing as abandoned. We rely less on normalized keys now during sorting, but

[jira] [Assigned] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-3387: --- Assignee: (was: Subhobrata Dey) > Replace all ByteArrayOutputStream and DataOutputStream

[jira] [Updated] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-3387: Labels: (was: stale-assigned) > Replace all ByteArrayOutputStream and DataOutputStream use in Sta

[jira] [Closed] (FLINK-3387) Replace all ByteArrayOutputStream and DataOutputStream use in State Backends by DataOutputSerializer

[ https://issues.apache.org/jira/browse/FLINK-3387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-3387. --- Resolution: Abandoned Closing as abandoned due to inactivity. > Replace all ByteArrayOutputStream an

[GitHub] [flink] wuchong commented on a change in pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

wuchong commented on a change in pull request #15559: URL: https://github.com/apache/flink/pull/15559#discussion_r615256245 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/calcite/rel/logical/LogicalTableScan.java ## @@ -0,0 +1,135 @@ +/* + * Licen

[GitHub] [flink] flinkbot edited a comment on pull request #15534: [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

flinkbot edited a comment on pull request #15534: URL: https://github.com/apache/flink/pull/15534#issuecomment-816392253 ## CI report: * f0f37cfe199dc670e8908b05a7df7ace8c2ecfd4 UNKNOWN * 8a566552f9d186ed1736686f60f13f943dc70838 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] brandonJY opened a new pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

brandonJY opened a new pull request #15654: URL: https://github.com/apache/flink/pull/15654 ## What is the purpose of the change - Bump junit from 4.12 to 4.13.1 due to GHSA-269g-pwp5-87pp https://github.com/advisories/GHSA-269g-pwp5-87pp - Bump log4j.v

[jira] [Created] (FLINK-22330) Bumps checkstyle, junit, log4j version for security

Brandon Jiang created FLINK-22330: - Summary: Bumps checkstyle, junit, log4j version for security Key: FLINK-22330 URL: https://issues.apache.org/jira/browse/FLINK-22330 Project: Flink Issue T

[GitHub] [flink] flinkbot commented on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

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

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] flinkbot edited a comment on pull request #15534: [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

flinkbot edited a comment on pull request #15534: URL: https://github.com/apache/flink/pull/15534#issuecomment-816392253 ## CI report: * f0f37cfe199dc670e8908b05a7df7ace8c2ecfd4 UNKNOWN * 8a566552f9d186ed1736686f60f13f943dc70838 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] wuchong commented on a change in pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

wuchong commented on a change in pull request #13011: URL: https://github.com/apache/flink/pull/13011#discussion_r465552827 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/constraints/UniqueConstraint.java ## @@ -75,21 +76,26 @@ public Con

[jira] [Closed] (FLINK-22314) AggRecordsCombiner should combine buffered records first instead of accumulate on state directly

[ https://issues.apache.org/jira/browse/FLINK-22314?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-22314. --- Resolution: Invalid > AggRecordsCombiner should combine buffered records first instead of > accumulate on s

[GitHub] [flink] flinkbot edited a comment on pull request #15653: [FLINK-22329][hive] 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: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot commented on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

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

[GitHub] [flink] AHeise commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

AHeise commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r615264959 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed to

[GitHub] [flink] AHeise commented on a change in pull request #15631: [FLINK-20103][tests] Add UnalignedCheckpointsStressITCase

AHeise commented on a change in pull request #15631: URL: https://github.com/apache/flink/pull/15631#discussion_r615265639 ## File path: flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointStressITCase.java ## @@ -0,0 +1,553 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] flinkbot edited a comment on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

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

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

[GitHub] [flink] fsk119 commented on a change in pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

fsk119 commented on a change in pull request #15585: URL: https://github.com/apache/flink/pull/15585#discussion_r615272815 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/exception/SqlParseException.java ## @@ -0,0 +1,32 @@ +/* + * Licens

[GitHub] [flink] fsk119 commented on pull request #15585: [FLINK-22065] [sql-client]Beautify the parse error exception

fsk119 commented on pull request #15585: URL: https://github.com/apache/flink/pull/15585#issuecomment-821850442 There are check style errors. Use `mvn com.diffplug.spotless:spotless-maven-plugin:apply` to fix these. -- This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot edited a comment on pull request #15534: [FLINK-22104][sql-client] Fix unstable SqlClientTest.testExecuteSqlFile

flinkbot edited a comment on pull request #15534: URL: https://github.com/apache/flink/pull/15534#issuecomment-816392253 ## CI report: * f0f37cfe199dc670e8908b05a7df7ace8c2ecfd4 UNKNOWN * 556c5fe14574005af9f6937c6ab4e1a5dc888d29 Azure: [SUCCESS](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-22331) CLI Frontend (RestClient) doesn't work on Apple M1

Robert Metzger created FLINK-22331: -- Summary: CLI Frontend (RestClient) doesn't work on Apple M1 Key: FLINK-22331 URL: https://issues.apache.org/jira/browse/FLINK-22331 Project: Flink Issue

[jira] [Commented] (FLINK-7883) Make savepoints atomic with respect to state and side effects

[ https://issues.apache.org/jira/browse/FLINK-7883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324335#comment-17324335 ] Olivier NOUGUIER commented on FLINK-7883: - Any update ?   > Make savepoints ato

[GitHub] [flink] flinkbot edited a comment on pull request #15121: The method $(String) is undefined for the type TableExample

flinkbot edited a comment on pull request #15121: URL: https://github.com/apache/flink/pull/15121#issuecomment-793480240 ## CI report: * cf26ce895a7956d258acc073817f578558e78227 UNKNOWN * 709c4110370b845f42d916a06e56c6026cf2fac8 UNKNOWN * 4ea99332e1997eebca1f3f0a9d9229b8265f

[GitHub] [flink] flinkbot edited a comment on pull request #15574: [hotfix][docs] Removed reference to fold in window function

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

[GitHub] [flink] flinkbot edited a comment on pull request #15574: [hotfix][docs] Removed reference to fold in window function

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

[GitHub] [flink] flinkbot edited a comment on pull request #15574: [hotfix][docs] Removed reference to fold in window function

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

[GitHub] [flink] brandonJY commented on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

brandonJY commented on pull request #15654: URL: https://github.com/apache/flink/pull/15654#issuecomment-821911588 @flinkbot run travis -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specif

[GitHub] [flink] brandonJY commented on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

brandonJY commented on pull request #15654: URL: https://github.com/apache/flink/pull/15654#issuecomment-821911681 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specifi

[GitHub] [flink] flinkbot edited a comment on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

flinkbot edited a comment on pull request #15654: URL: https://github.com/apache/flink/pull/15654#issuecomment-821836292 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run travis`

[GitHub] [flink] flinkbot edited a comment on pull request #15654: [FLINK-22141] Bumps checkstyle, junit, log4j version for security

flinkbot edited a comment on pull request #15654: URL: https://github.com/apache/flink/pull/15654#issuecomment-821836292 ## CI report: Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run travis` re-run the last Travis build - `

[GitHub] [flink] link3280 commented on a change in pull request #13377: [FLINK-18592] bugfix for StreamingFileSink

link3280 commented on a change in pull request #13377: URL: https://github.com/apache/flink/pull/13377#discussion_r615326763 ## File path: flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java ## @@ -360,4 +36

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

guoweiM commented on a change in pull request #15652: URL: https://github.com/apache/flink/pull/15652#discussion_r615328699 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -160,18 +160,12 @@ public voi

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

wsry commented on a change in pull request #15652: URL: https://github.com/apache/flink/pull/15652#discussion_r615329427 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -160,18 +160,12 @@ public void s

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324387#comment-17324387 ] Guowei Ma commented on FLINK-17510: --- https://dev.azure.com/apache-flink/apache-flink/_

[jira] [Comment Edited] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324387#comment-17324387 ] Guowei Ma edited comment on FLINK-17510 at 4/18/21, 2:22 AM: -

[jira] [Updated] (FLINK-22307) Increase the default value of data writing cache size for sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22307: Summary: Increase the default value of data writing cache size for sort-merge blocking shuffle (w

[jira] [Updated] (FLINK-22307) Increase the default value of data writing cache size (not configurable) for sort-merge blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-22307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-22307: Summary: Increase the default value of data writing cache size (not configurable) for sort-merge b

  1   2   >