[GitHub] [flink] flinkbot edited a comment on pull request #15004: [FLINK-21253][table-planner-blink] Support grouping set syntax for GroupWindowAggregate

flinkbot edited a comment on pull request #15004: URL: https://github.com/apache/flink/pull/15004#issuecomment-785052726 ## CI report: * 3af09855fc47130d93b11e6d6ba1c3dedb6574a5 Azure:

[jira] [Closed] (FLINK-21627) When you insert multiple inserts with statementSet, you modify multiple inserts with OPTIONS('table-name '=' XXX '), but only the first one takes effect

[ https://issues.apache.org/jira/browse/FLINK-21627?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-21627. -- Resolution: Fixed Fixed in 1.13.0: c6147f2df2e81c1b1db6aa43b3a827a8c4148af1 > When you insert

[GitHub] [flink] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Support to consume retractions for window aggregate operator

flinkbot edited a comment on pull request #14830: URL: https://github.com/apache/flink/pull/14830#issuecomment-770878871 ## CI report: * a2587cacaa7abea0059a6aadf16cbb1c5a4f31b3 Azure:

[GitHub] [flink] godfreyhe closed pull request #15559: [FLINK-21627][table-planner-blink] The digest of TableScan & Sink should consider table hints

godfreyhe closed pull request #15559: URL: https://github.com/apache/flink/pull/15559 -- 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] flinkbot edited a comment on pull request #14830: [FLINK-20487][table-planner-blink] Support to consume retractions for window aggregate operator

flinkbot edited a comment on pull request #14830: URL: https://github.com/apache/flink/pull/14830#issuecomment-770878871 ## CI report: * a2587cacaa7abea0059a6aadf16cbb1c5a4f31b3 Azure:

[jira] [Commented] (FLINK-20487) Support to consume retractions for window aggregate operator

[ https://issues.apache.org/jira/browse/FLINK-20487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324415#comment-17324415 ] Andy commented on FLINK-20487: -- [~flink-jira-bot] [~jark] [~godfreyhe] I'm still working on the issue,

[jira] [Commented] (FLINK-22099) Fix bug for semi/anti window join.

[ https://issues.apache.org/jira/browse/FLINK-22099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324414#comment-17324414 ] Andy commented on FLINK-22099: -- [~flink-jira-bot] [~jark] [~godfreyhe]  I'm still working on the issue,

[jira] [Commented] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324413#comment-17324413 ] Andy commented on FLINK-22098: -- [~flink-jira-bot] [~jark] [~godfreyhe]   I'm still working on the issue,

[jira] [Comment Edited] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324413#comment-17324413 ] Andy edited comment on FLINK-22098 at 4/18/21, 5:19 AM: [~flink-jira-bot]

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Implement streaming window join operator

flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 93b9b3d8dac2c3ecd13e3e3ede46f4a73263e34d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

flinkbot edited a comment on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-812337208 ## CI report: * 68bacb55c3c718eddba8cf5596bf94c3e4931d40 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

flinkbot edited a comment on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812307606 ## CI report: * 3023dfa33790b3140a132fd2f76f56a2caad4a78 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15479: [FLINK-19606][table-runtime-blink] Implement streaming window join operator

flinkbot edited a comment on pull request #15479: URL: https://github.com/apache/flink/pull/15479#issuecomment-812344008 ## CI report: * 93b9b3d8dac2c3ecd13e3e3ede46f4a73263e34d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15477: [FLINK-22099][table-planner-blink] Fix bug for semi/anti window join.

flinkbot edited a comment on pull request #15477: URL: https://github.com/apache/flink/pull/15477#issuecomment-812337208 ## CI report: * 68bacb55c3c718eddba8cf5596bf94c3e4931d40 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15476: [FLINK-22098][table-planner-blink] Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

flinkbot edited a comment on pull request #15476: URL: https://github.com/apache/flink/pull/15476#issuecomment-812307606 ## CI report: * 3023dfa33790b3140a132fd2f76f56a2caad4a78 Azure:

[GitHub] [flink] hehuiyuan removed a comment on pull request #15615: [FLINK-22021][table-planner-blink] Fix exception when PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types

hehuiyuan removed a comment on pull request #15615: URL: https://github.com/apache/flink/pull/15615#issuecomment-821067136 @flinkbot re-run -- 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

[jira] [Commented] (FLINK-21302) Fix NPE when use row_number() in over agg

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324405#comment-17324405 ] Andy commented on FLINK-21302: -- [~flink-jira-bot] [~jark] [~godfreyhe]   I'm still working on the issue,

[jira] [Comment Edited] (FLINK-19606) Implement streaming window join operator

[ https://issues.apache.org/jira/browse/FLINK-19606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324403#comment-17324403 ] Andy edited comment on FLINK-19606 at 4/18/21, 4:13 AM: [~flink-jira-bot]

[jira] [Updated] (FLINK-21302) Fix NPE when use row_number() in over agg

[ https://issues.apache.org/jira/browse/FLINK-21302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-21302: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Fix NPE when use row_number() in

[jira] [Updated] (FLINK-21923) SplitAggregateRule will be abnormal, when the sum/count and avg in SQL at the same time

[ https://issues.apache.org/jira/browse/FLINK-21923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tartarus updated FLINK-21923: - Labels: pull-request-available (was: pull-request-available stale-assigned) > SplitAggregateRule will

[jira] [Commented] (FLINK-19606) Implement streaming window join operator

[ https://issues.apache.org/jira/browse/FLINK-19606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324403#comment-17324403 ] Andy commented on FLINK-19606: -- [~flink-jira-bot] [~jark] [~godfreyhe]. I'm still working on the issue,

[jira] [Updated] (FLINK-22099) Fix bug for semi/anti window join.

[ https://issues.apache.org/jira/browse/FLINK-22099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22099: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Fix bug for semi/anti window

[jira] [Updated] (FLINK-22098) Fix bug for window join: plan is wrong if join condition contain 'IS NOT DISTINCT FROM'

[ https://issues.apache.org/jira/browse/FLINK-22098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andy updated FLINK-22098: - Labels: pull-request-available (was: pull-request-available stale-assigned) > Fix bug for window join: plan is

[jira] [Closed] (FLINK-22310) The result of LogicalWindowJsonDeserializer is incorrect

[ https://issues.apache.org/jira/browse/FLINK-22310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-22310. -- Resolution: Fixed Fixed in 1.13.0: d32ca07743c729e66656f119f057249e03e5c5e2 > The result of

[GitHub] [flink] godfreyhe closed pull request #15645: [FLINK-22310][table-planner-blink] Fix the incorrect deserialization result of LogicalWindowJsonDeserializer

godfreyhe closed pull request #15645: URL: https://github.com/apache/flink/pull/15645 -- 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] [Closed] (FLINK-19614) Further optimization of sort-merge based blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-19614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao closed FLINK-19614. --- Resolution: Resolved > Further optimization of sort-merge based blocking shuffle >

[jira] [Closed] (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 closed FLINK-22307. --- Resolution: Resolved > Increase the default value of data writing cache size (not configurable) for

[jira] [Commented] (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:comment-tabpanel=17324396#comment-17324396 ] Yingjie Cao commented on FLINK-22307: - Merged via d29357791315ace0218308f9f96bf65c7c8079d7 on

[jira] [Commented] (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:comment-tabpanel=17324394#comment-17324394 ] Yingjie Cao commented on FLINK-22305: - Merged via 77e0478a7879bd41f9f52872d84c467d158b8098 on

[jira] [Closed] (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 closed FLINK-22305. --- Resolution: Resolved > Improve log messages of sort-merge blocking shuffle >

[GitHub] [flink] guoweiM closed pull request #15651: [FLINK-22307][network] Increase the default value of data writing cache size (not configurable) for sort-merge blocking shuffle

guoweiM closed pull request #15651: URL: https://github.com/apache/flink/pull/15651 -- 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] flinkbot edited a comment on pull request #15651: [FLINK-22307][network] Increase the default value of data writing cache size (not configurable) for 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:

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

guoweiM closed pull request #15652: URL: https://github.com/apache/flink/pull/15652 -- 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] 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_r615332364 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SortMergeResultPartition.java ## @@ -160,18 +160,12 @@ public

[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=17324387#comment-17324387 ] Guowei Ma edited comment on FLINK-17510 at 4/18/21, 2:52 AM: -

[jira] [Updated] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.

[ https://issues.apache.org/jira/browse/FLINK-22333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22333: -- Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments failed due to deploy task timeout.

[jira] [Created] (FLINK-22333) Elasticsearch7DynamicSinkITCase.testWritingDocuments fail due to deploy task timeout.

Guowei Ma created FLINK-22333: - Summary: Elasticsearch7DynamicSinkITCase.testWritingDocuments fail due to deploy task timeout. Key: FLINK-22333 URL: https://issues.apache.org/jira/browse/FLINK-22333

[jira] [Updated] (FLINK-22332) ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse failed due to NPE when calling "notifyDataAvailable"

[ https://issues.apache.org/jira/browse/FLINK-22332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-22332: -- Summary: ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse failed due to NPE when

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324390#comment-17324390 ] Guowei Ma commented on FLINK-22266: --- Just for reporting

[jira] [Commented] (FLINK-22111) ClientTest.testSimpleRequests fail

[ https://issues.apache.org/jira/browse/FLINK-22111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17324388#comment-17324388 ] Guowei Ma commented on FLINK-22111: ---

[jira] [Created] (FLINK-22332) ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse due to NPE when calling "notifyDataAvailable"

Guowei Ma created FLINK-22332: - Summary: ConnectedComponentsWithObjectMapITCase.testJobWithoutObjectReuse due to NPE when calling "notifyDataAvailable" Key: FLINK-22332 URL:

[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

[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

[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=17324387#comment-17324387 ] Guowei Ma edited comment on FLINK-17510 at 4/18/21, 2:22 AM: -

[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=17324387#comment-17324387 ] Guowei Ma commented on FLINK-17510: ---

[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

[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

[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

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

[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

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

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

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

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

[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=17324335#comment-17324335 ] Olivier NOUGUIER commented on FLINK-7883: - Any update ?   > Make savepoints atomic with respect

[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

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

[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

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

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

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

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

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

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

[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

[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

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

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

[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

[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

[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

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

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

[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

[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

[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

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

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

[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

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

[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=17324255#comment-17324255 ] Stephan Ewen commented on FLINK-9043: - I think this might be a good one to revisit now. The last

[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

[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

[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

[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

[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

[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

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

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

[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

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

  1   2   >