[jira] [Updated] (FLINK-24740) Update testcontainers dependency to v1.16.2

[ https://issues.apache.org/jira/browse/FLINK-24740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Paul updated FLINK-24740: Affects Version/s: 1.13.3 1.14.0 1.15.0 > Update tes

[jira] [Commented] (FLINK-15493) FlinkKafkaInternalProducerITCase.testProducerWhenCommitEmptyPartitionsToOutdatedTxnCoordinator failed on travis

[ https://issues.apache.org/jira/browse/FLINK-15493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452226#comment-17452226 ] Fabian Paul commented on FLINK-15493: - I'll merged a fix to master 2e018d0bc04935e50

[GitHub] [flink] flinkbot edited a comment on pull request #17974: [FLINK-15493][test] Add retry rule for all tests based on KafkaTestBase

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

[jira] [Commented] (FLINK-25134) Unused RetryRule in KafkaConsumerTestBase swallows retries

[ https://issues.apache.org/jira/browse/FLINK-25134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452225#comment-17452225 ] Fabian Paul commented on FLINK-25134: - Merged master: e4c7d7863962b32b1ea1f79927828

[GitHub] [flink] fapaul commented on pull request #17974: [FLINK-15493][test] Add retry rule for all tests based on KafkaTestBase

fapaul commented on pull request #17974: URL: https://github.com/apache/flink/pull/17974#issuecomment-984374527 @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 specific c

[jira] [Commented] (FLINK-24740) Update testcontainers dependency to v1.16.2

[ https://issues.apache.org/jira/browse/FLINK-24740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452223#comment-17452223 ] Martijn Visser commented on FLINK-24740: [~fpaul] I'll create the backport > Up

[jira] [Assigned] (FLINK-24862) The user-defined hive udaf/udtf cannot be used normally in hive dialect

[ https://issues.apache.org/jira/browse/FLINK-24862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-24862: -- Assignee: xiangqiao > The user-defined hive udaf/udtf cannot be used normally in hive dialect

[jira] [Commented] (FLINK-24740) Update testcontainers dependency to v1.16.2

[ https://issues.apache.org/jira/browse/FLINK-24740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452221#comment-17452221 ] Fabian Paul commented on FLINK-24740: - Can we also backport the change to the releas

[GitHub] [flink] flinkbot edited a comment on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

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

[jira] [Updated] (FLINK-25139) S3 tests failing due to rotating credentials

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-25139: --- Summary: S3 tests failing due to rotating credentials (was: Shaded Hadoop S3A with credenti

[GitHub] [flink] flinkbot edited a comment on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

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

[jira] [Resolved] (FLINK-25140) Streaming File Sink s3 end-to-end test failed due to job has not started within a timeout of 10 sec

[ https://issues.apache.org/jira/browse/FLINK-25140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser resolved FLINK-25140. Resolution: Fixed This test failed due to the related ticket > Streaming File Sink s3 end

[GitHub] [flink] fapaul merged pull request #17973: [FLINK-15493][test] Add retry rule for all tests based on KafkaTestBase

fapaul merged pull request #17973: URL: https://github.com/apache/flink/pull/17973 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

flinkbot edited a comment on pull request #17987: URL: https://github.com/apache/flink/pull/17987#issuecomment-984305827 ## CI report: * 1532dfde994f529a784ada830e2b32a75a526907 Azure: [CANCELED](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/resul

[jira] [Assigned] (FLINK-25140) Streaming File Sink s3 end-to-end test failed due to job has not started within a timeout of 10 sec

[ https://issues.apache.org/jira/browse/FLINK-25140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-25140: -- Assignee: Martijn Visser > Streaming File Sink s3 end-to-end test failed due to job h

[GitHub] [flink] flinkbot edited a comment on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[GitHub] [flink] flinkbot commented on pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

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

[jira] [Commented] (FLINK-25010) Speed up hive's createMRSplits by multi thread

[ https://issues.apache.org/jira/browse/FLINK-25010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452213#comment-17452213 ] Liu commented on FLINK-25010: - [~luoyuxia] Could you review my code? Thank you very much. >

[jira] [Updated] (FLINK-25010) Speed up hive's createMRSplits by multi thread

[ https://issues.apache.org/jira/browse/FLINK-25010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25010: --- Labels: pull-request-available (was: ) > Speed up hive's createMRSplits by multi thread > -

[GitHub] [flink] Myracle opened a new pull request #17988: [FLINK-25010][Connectors/Hive] Speed up hive's createMRSplits by multi thread

Myracle opened a new pull request #17988: URL: https://github.com/apache/flink/pull/17988 ## What is the purpose of the change *If there are many hive partitions, creating splits will take much time, for example, up to ten minutes. This mr speeds up the process by multi threads for

[jira] [Closed] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao closed FLINK-25139. --- > Shaded Hadoop S3A with credentials provider failed on azure >

[jira] [Resolved] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao resolved FLINK-25139. - Resolution: Fixed > Shaded Hadoop S3A with credentials provider failed on azure > --

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add One Hot Encoder to Flink ML

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r760811448 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderModelParams.java ## @@ -0,0 +1,31 @@ +/* + * License

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add One Hot Encoder to Flink ML

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r760811339 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/feature/onehotencoder/OneHotEncoderParams.java ## @@ -0,0 +1,26 @@ +/* + * Licensed to

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #37: [FLINK-24955] Add One Hot Encoder to Flink ML

yunfengzhou-hub commented on a change in pull request #37: URL: https://github.com/apache/flink-ml/pull/37#discussion_r760811184 ## File path: flink-ml-api/src/main/java/org/apache/flink/ml/linalg/SparseVector.java ## @@ -0,0 +1,157 @@ +/* + * Licensed to the Apache Software F

[GitHub] [flink] flinkbot edited a comment on pull request #16964: [FLINK-23791] Enable RocksDB info log by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #16964: [FLINK-23791] Enable RocksDB info log by default

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] hililiwei commented on pull request #17777: [FLINK-24886][core] TimeUtils supports the form of m.

hililiwei commented on pull request #1: URL: https://github.com/apache/flink/pull/1#issuecomment-984331192 Can 'm' and 'min' be supported at the same time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the U

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] tsreaper commented on pull request #17845: [FLINK-24352] [flink-table-planner] Add null check for temporal table check on SqlSnapshot

tsreaper commented on pull request #17845: URL: https://github.com/apache/flink/pull/17845#issuecomment-984329079 @godfreyhe > since we do not check whether the query in `with` is temporal I don't quite understand this. I think `with` is always temporal? -- This is an autom

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[jira] [Commented] (FLINK-25071) Enable ParquetFileSystemITCase.testLimitableBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-25071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452188#comment-17452188 ] Jingsong Lee commented on FLINK-25071: -- SerializableConfiguration load resources fr

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink] flinkbot edited a comment on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[GitHub] [flink-ml] yunfengzhou-hub commented on a change in pull request #24: [Flink 24557] - Add knn algorithm to flink-ml

yunfengzhou-hub commented on a change in pull request #24: URL: https://github.com/apache/flink-ml/pull/24#discussion_r760737278 ## File path: flink-ml-lib/src/test/java/org/apache/flink/ml/classification/knn/KnnTest.java ## @@ -0,0 +1,273 @@ +package org.apache.flink.ml.class

[GitHub] [flink] flinkbot commented on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

flinkbot commented on pull request #17987: URL: https://github.com/apache/flink/pull/17987#issuecomment-984306224 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 commented on pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

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

[jira] [Updated] (FLINK-25071) Enable ParquetFileSystemITCase.testLimitableBulkFormat

[ https://issues.apache.org/jira/browse/FLINK-25071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-25071: --- Labels: pull-request-available (was: ) > Enable ParquetFileSystemITCase.testLimitableBulkFo

[GitHub] [flink] JingsongLi opened a new pull request #17987: [FLINK-25071][parquet] SerializableConfiguration should not load resources

JingsongLi opened a new pull request #17987: URL: https://github.com/apache/flink/pull/17987 ## What is the purpose of the change SerializableConfiguration load resources from ClassLoader lead to many unstable tests: https://issues.apache.org/jira/browse/FLINK-24763 https:/

[GitHub] [flink] shenzhu commented on pull request #17793: [FLINK-21565][Table SQL/API] Support more integer types in TIMESTAMPADD

shenzhu commented on pull request #17793: URL: https://github.com/apache/flink/pull/17793#issuecomment-984282352 Hey @wuchong , would you mind taking a look at this PR when you have a moment? Thanks! -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink-ml] lindong28 commented on a change in pull request #28: [Flink-24556] Add Estimator and Transformer for logistic regression

lindong28 commented on a change in pull request #28: URL: https://github.com/apache/flink-ml/pull/28#discussion_r760717691 ## File path: flink-ml-lib/src/main/java/org/apache/flink/ml/classification/linear/LogisticRegression.java ## @@ -0,0 +1,488 @@ +/* + * Licensed to the Ap

[GitHub] [flink] wjcgood commented on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

wjcgood commented on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-984276501 I think there are some problems in ReadableMetadata of OggJsonDecodingFormat 1 "current_ts","op_ts","table " not nested inside ogg json. So key is themselves , isJsonPayload

[GitHub] [flink] Myasuka commented on pull request #16964: [FLINK-23791] Enable RocksDB info log by default

Myasuka commented on pull request #16964: URL: https://github.com/apache/flink/pull/16964#issuecomment-984271162 @Zakelly As discussed, I think 25MB * 4 files could be better to avoid too many splits. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-25141) Elasticsearch connector customize sink parallelism

Ada Wong created FLINK-25141: Summary: Elasticsearch connector customize sink parallelism Key: FLINK-25141 URL: https://issues.apache.org/jira/browse/FLINK-25141 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-25141) Elasticsearch connector customize sink parallelism

[ https://issues.apache.org/jira/browse/FLINK-25141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452165#comment-17452165 ] Ada Wong commented on FLINK-25141: -- I want to fix this ticket. > Elasticsearch connect

[GitHub] [flink] flinkbot edited a comment on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

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

[GitHub] [flink] flinkbot edited a comment on pull request #17891: [FLINK-12941][chinese-translation, Documentation ]Translate "Amazon A…

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

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452160#comment-17452160 ] Yun Gao commented on FLINK-23944: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452159#comment-17452159 ] Yuan Zhu commented on FLINK-23687: -- At the same time, I suggest adding an option to tog

[jira] [Commented] (FLINK-25102) ParquetFileSystemITCase.testPartialDynamicPartition failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452157#comment-17452157 ] Yun Gao commented on FLINK-25102: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Created] (FLINK-25140) Streaming File Sink s3 end-to-end test failed due to job has not started within a timeout of 10 sec

Yun Gao created FLINK-25140: --- Summary: Streaming File Sink s3 end-to-end test failed due to job has not started within a timeout of 10 sec Key: FLINK-25140 URL: https://issues.apache.org/jira/browse/FLINK-25140

[jira] [Updated] (FLINK-23830) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-23830: Affects Version/s: 1.13.3 > FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on azure > -

[jira] [Commented] (FLINK-23830) FlinkKafkaProducerMigrationOperatorTest.testRestoreProducer fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452154#comment-17452154 ] Yun Gao commented on FLINK-23830: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452153#comment-17452153 ] Yun Gao commented on FLINK-25139: - The tests should be failed due to rotating credential

[jira] [Commented] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452152#comment-17452152 ] Yun Gao commented on FLINK-25139: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452151#comment-17452151 ] Yun Gao commented on FLINK-25139: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452150#comment-17452150 ] Yun Gao commented on FLINK-25139: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Updated] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-25139: Affects Version/s: 1.14.0 1.15.0 > Shaded Hadoop S3A with credentials provider fail

[jira] [Commented] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452149#comment-17452149 ] Yun Gao commented on FLINK-25139: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] [Commented] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452148#comment-17452148 ] Yun Gao commented on FLINK-25139: - [https://dev.azure.com/apache-flink/apache-flink/_bui

[jira] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

[ https://issues.apache.org/jira/browse/FLINK-25139 ] Yun Gao deleted comment on FLINK-25139: - was (Author: gaoyunhaii): [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=27381&view=logs&j=d44f43ce-542c-597d-bf94-b0718c71e5e8&t

[jira] [Created] (FLINK-25139) Shaded Hadoop S3A with credentials provider failed on azure

Yun Gao created FLINK-25139: --- Summary: Shaded Hadoop S3A with credentials provider failed on azure Key: FLINK-25139 URL: https://issues.apache.org/jira/browse/FLINK-25139 Project: Flink Issue Type

[GitHub] [flink] JingsongLi commented on pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on pull request #17542: URL: https://github.com/apache/flink/pull/17542#issuecomment-984249951 @meetjunsu Thanks for the contribution. Left some comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760729158 ## File path: flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriterTest.java ## @@ -120,15 +144,18 @@ pr

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760727608 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -224,6 +293,176 @@ privat

[GitHub] [flink] Myasuka edited a comment on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

Myasuka edited a comment on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-984247296 @camilesing I have assigned the ticket to you, and please get the assignment first before creating a PR for the next time. The CI is still broken, please ensure the CI

[GitHub] [flink] Myasuka commented on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

Myasuka commented on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-984247296 @camilesing I have assigned the ticket to you, and please get the assignment first before creating a PR for the next time. The CI is still broken, please ensure the CI works f

[jira] [Assigned] (FLINK-24777) Processed (persisted) in-flight data description miss on Monitoring Checkpointing page

[ https://issues.apache.org/jira/browse/FLINK-24777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang reassigned FLINK-24777: Assignee: camilesing > Processed (persisted) in-flight data description miss on Monitoring > Che

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760727340 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -224,6 +293,176 @@ privat

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760725974 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -224,6 +293,176 @@ privat

[GitHub] [flink] camilesing commented on pull request #17686: [FLINK-24777][docs]fix Processed (persisted) in-flight data descripti…

camilesing commented on pull request #17686: URL: https://github.com/apache/flink/pull/17686#issuecomment-984244661 @Myasuka Could you review this? thx -- 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

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760725040 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java ## @@ -101,11 +110,32 @@ pr

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760724189 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -224,6 +293,176 @@ privat

[jira] [Comment Edited] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452139#comment-17452139 ] xiangqiao edited comment on FLINK-25095 at 12/2/21, 2:43 AM: -

[jira] [Commented] (FLINK-25095) org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'BOOLEAN NOT NULL' and actual argument type 'BOOLEAN'.

[ https://issues.apache.org/jira/browse/FLINK-25095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452139#comment-17452139 ] xiangqiao commented on FLINK-25095: --- I verified that if default dialect is used, the e

[jira] [Commented] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column

[ https://issues.apache.org/jira/browse/FLINK-25137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452137#comment-17452137 ] Jing Zhang commented on FLINK-25137: [~liuhb86]I agree with [~wenlong.lwl]. After re

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452135#comment-17452135 ] Yuan Zhu commented on FLINK-23687: -- [~jingzhang] I am willing to review, but I may not

[jira] [Commented] (FLINK-25029) Hadoop Caller Context Setting In Flink

[ https://issues.apache.org/jira/browse/FLINK-25029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452132#comment-17452132 ] 刘方奇 commented on FLINK-25029: - [~dmvk] , THX very much, Look forward to your feedback! > Ha

[jira] [Assigned] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Zhang reassigned FLINK-23687: -- Assignee: Jing Zhang > Add Sql query hint to enable LookupJoin shuffle by join key of left in

[jira] [Commented] (FLINK-23687) Add Sql query hint to enable LookupJoin shuffle by join key of left input

[ https://issues.apache.org/jira/browse/FLINK-23687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452121#comment-17452121 ] Jing Zhang commented on FLINK-23687: [~straw]Thanks a lot. However the JIRA is alre

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760714379 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -189,6 +243,11 @@ public

[GitHub] [flink] JingsongLi commented on a change in pull request #17542: [FLINK-17782] Add array,map,row types support for parquet row writer

JingsongLi commented on a change in pull request #17542: URL: https://github.com/apache/flink/pull/17542#discussion_r760713947 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/row/ParquetRowDataWriter.java ## @@ -126,13 +134,29 @@ privat

[GitHub] [flink] flinkbot edited a comment on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17966: [FLINK-24227][connectors/kinesis] Moved AWS constants and general utils to common AWS connector

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

[GitHub] [flink] flinkbot edited a comment on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

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

[GitHub] [flink] flinkbot edited a comment on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

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

[GitHub] [flink] godfreyhe commented on pull request #17962: [FLINK-22113][table-planner] Implement column uniqueness checking for TableSourceTable

godfreyhe commented on pull request #17962: URL: https://github.com/apache/flink/pull/17962#issuecomment-984210690 @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

[jira] [Commented] (FLINK-25137) Cannot do window aggregation after a regular join: Window can only be defined on a time attribute column

[ https://issues.apache.org/jira/browse/FLINK-25137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17452108#comment-17452108 ] Wenlong Lyu commented on FLINK-25137: - hi, [~liuhb86] this is a by-designed limitati

  1   2   3   4   5   6   7   8   >