[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * Unknown: [CANCELED](TBD) * 8792e55dbc0639fdc32b5a1fe17ed391cda0e788 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-958647607 ## CI report: * Unknown: [CANCELED](TBD) * 8792e55dbc0639fdc32b5a1fe17ed391cda0e788 UNKNOWN Bot commands The @flinkbot bot supports the

[jira] [Assigned] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-24490: --- Assignee: JasonLee > The sample code is wrong in Apache Kafka Connector page >

[GitHub] [flink] xuyangzhong commented on pull request #17652: [FLINK-24717][table-planner]Push down partitions before filters

2021-11-04 Thread GitBox
xuyangzhong commented on pull request #17652: URL: https://github.com/apache/flink/pull/17652#issuecomment-961639325 @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

[jira] [Commented] (FLINK-24551) BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration

2021-11-04 Thread Yuan Mei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439040#comment-17439040 ] Yuan Mei commented on FLINK-24551: -- merged commit 3e341d0 into apache:release-1.14 [~akalashnikov] do

[GitHub] [flink] curcur commented on pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

2021-11-04 Thread GitBox
curcur commented on pull request #17621: URL: https://github.com/apache/flink/pull/17621#issuecomment-961636576 @akalash , do you need to put this fix into master as well? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-24533) Flink SQL Upsert To Hbase Appear data loss

2021-11-04 Thread licp (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439038#comment-17439038 ] licp commented on FLINK-24533: -- Thanks [~jark].I have made temporary modifications based on this idea based

[GitHub] [flink] curcur merged pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

2021-11-04 Thread GitBox
curcur merged pull request #17621: URL: https://github.com/apache/flink/pull/17621 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] curcur commented on pull request #17621: [FLINK-24551][runtime] Read BUFFER_DEBLOAT_SAMPLES from task manager …

2021-11-04 Thread GitBox
curcur commented on pull request #17621: URL: https://github.com/apache/flink/pull/17621#issuecomment-961636235 thanks @akalash for clarification! -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 441c4b009499984fbf1bea466ab8c8c44de8ff73 Azure:

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Lee Y S (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439030#comment-17439030 ] Lee Y S commented on FLINK-24767: - Hi [~sjwiesman], Because I set the random seed (0), the result

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-960539433 ## CI report: * 16720729ab05a82626b9e72e070ce4f9b36acb03 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619732 ## CI report: * b76e02bc31eb3d1c6e757e7cbc0cd1561777844c Azure:

[jira] [Commented] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439023#comment-17439023 ] JasonLee commented on FLINK-24490: --  [~jark]  Can you assign this to me ?  thanks > The sample code is

[jira] [Updated] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder

[jira] [Updated] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder

[GitHub] [flink] flinkbot commented on pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

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

[GitHub] [flink] flinkbot commented on pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-04 Thread GitBox
flinkbot commented on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619732 ## CI report: * b76e02bc31eb3d1c6e757e7cbc0cd1561777844c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-21325) NoResourceAvailableException while cancel then resubmit jobs or after running tow days

2021-11-04 Thread Leon Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439021#comment-17439021 ] Leon Xu commented on FLINK-21325: - Hi Is there any update on this ticket? I am experiencing the similar

[jira] [Updated] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 26b6b9c6159d8bc45e892462f7104f2c37c33cc8 Azure:

[GitHub] [flink] lincoln-lil opened a new pull request #17689: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-04 Thread GitBox
lincoln-lil opened a new pull request #17689: URL: https://github.com/apache/flink/pull/17689 This pr cherry-pick FLINK-24704 from master to release-1.14 ## What is the purpose of the change Fix the exception when the input record loses monotonicity on the sort key field of

[jira] [Updated] (FLINK-24490) The sample code is wrong in Apache Kafka Connector page

2021-11-04 Thread JasonLee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JasonLee updated FLINK-24490: - Description: There is a sample code error in the kafka sink part {code:java} // code placeholder

[GitHub] [flink] JingsongLi merged pull request #17605: [FLINK-24704][table] Fix exception when the input record loses monotonicity on the sort key field of UpdatableTopNFunction

2021-11-04 Thread GitBox
JingsongLi merged pull request #17605: URL: https://github.com/apache/flink/pull/17605 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439017#comment-17439017 ] Zakelly Lan commented on FLINK-24046: - Moreover, we could remove this special value since 15.0 >

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-04 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439015#comment-17439015 ] Zakelly Lan commented on FLINK-24046: - [~yunta] Good point. I think we could treat

[GitHub] [flink] cshuo commented on a change in pull request #17634: [FLINK-24691][table-common] Fix precision for sum on decimal types

2021-11-04 Thread GitBox
cshuo commented on a change in pull request #17634: URL: https://github.com/apache/flink/pull/17634#discussion_r743368304 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/SumAggFunction.java ## @@ -66,7 +66,10

[jira] [Comment Edited] (FLINK-24730) Support prompt style in SqlCli

2021-11-04 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439009#comment-17439009 ] Yubin Li edited comment on FLINK-24730 at 11/5/21, 3:27 AM: Hi, [~twalthr]

[jira] [Commented] (FLINK-24730) Support prompt style in SqlCli

2021-11-04 Thread Yubin Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439009#comment-17439009 ] Yubin Li commented on FLINK-24730: -- Hi, [~twalthr] After discussing with [~Sergey Nuyanzin] ,will

[jira] [Commented] (FLINK-24046) Refactor the relationship bwtween PredefinedOptions and RocksDBConfigurableOptions

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439002#comment-17439002 ] Yun Tang commented on FLINK-24046: -- [~Zakelly] Since {{DefaultConfigurableOptionsFactory}} had existed

[GitHub] [flink] Myasuka commented on a change in pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

2021-11-04 Thread GitBox
Myasuka commented on a change in pull request #16582: URL: https://github.com/apache/flink/pull/16582#discussion_r743366210 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -339,78 +343,107

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 26b6b9c6159d8bc45e892462f7104f2c37c33cc8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 124ffefd4430bb8a86db7815280d5f2d1e16b076 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-954546978 ## CI report: * 26b6b9c6159d8bc45e892462f7104f2c37c33cc8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17653: FLINK SQL checkpoint不生效

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 124ffefd4430bb8a86db7815280d5f2d1e16b076 Azure:

[GitHub] [flink] ruanhang1993 commented on pull request #17601: [FLINK-24697][flink-connectors-kafka] add auto.offset.reset configuration for group-offsets startup mode

2021-11-04 Thread GitBox
ruanhang1993 commented on pull request #17601: URL: https://github.com/apache/flink/pull/17601#issuecomment-961592246 @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

[jira] [Resolved] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24597. -- Resolution: Fixed Merged master: a907d92673a711612b287d184c00dad7fa42269f release-1.14:

[GitHub] [flink] flinkbot edited a comment on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure:

[jira] [Updated] (FLINK-24597) RocksdbStateBackend getKeysAndNamespaces would return duplicate data when using MapState

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-24597: - Fix Version/s: 1.13.4 1.14.1 1.15.0 > RocksdbStateBackend

[GitHub] [flink] flinkbot edited a comment on pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17650: URL: https://github.com/apache/flink/pull/17650#issuecomment-958638599 ## CI report: * 150b5f9f464913cc83756cbadd233cdb279db0c7 Azure:

[GitHub] [flink] Myasuka closed pull request #17525: [FLINK-24597][state] fix the problem that RocksStateKeysAndNamespaceIterator would return duplicate data

2021-11-04 Thread GitBox
Myasuka closed pull request #17525: URL: https://github.com/apache/flink/pull/17525 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] Zakelly commented on a change in pull request #17650: [FLINK-24475] Remove no longer used NestedMap* classes

2021-11-04 Thread GitBox
Zakelly commented on a change in pull request #17650: URL: https://github.com/apache/flink/pull/17650#discussion_r743359346 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java ## @@ -4376,7 +4373,7 @@ protected void

[jira] [Closed] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang closed FLINK-18473. Resolution: Information Provided > Optimize RocksDB disk load balancing strategy >

[jira] [Commented] (FLINK-18473) Optimize RocksDB disk load balancing strategy

2021-11-04 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438997#comment-17438997 ] Yun Tang commented on FLINK-18473: -- [~fanrui] I think your proposed idea cannot resolve the case of

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 ## CI report: * 8a1fb9a7fc7ea43c249cbe7792102fe8ffe26321 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-960539433 ## CI report: * dde91e1cf145a36e329a88159e53eac00b453d6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16582: [FLINK-21504][checkpoint] Introduce notification of subsumed checkpoint

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #16582: URL: https://github.com/apache/flink/pull/16582#issuecomment-885598535 ## CI report: * 8a1fb9a7fc7ea43c249cbe7792102fe8ffe26321 Azure:

[GitHub] [flink] beyond1920 commented on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-04 Thread GitBox
beyond1920 commented on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-961582912 @MartijnVisser @infoverload Thanks a lot for review. I updated pull request to address those typos. -- This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #17670: [FLINK-24760][docs] Update user document for batch window tvf

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17670: URL: https://github.com/apache/flink/pull/17670#issuecomment-960539433 ## CI report: * dde91e1cf145a36e329a88159e53eac00b453d6c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] hililiwei commented on pull request #17648: [FLINK-20443][API/DataStream] ContinuousProcessingTimeTrigger doesn't fire at the end of the window

2021-11-04 Thread GitBox
hililiwei commented on pull request #17648: URL: https://github.com/apache/flink/pull/17648#issuecomment-961569348 > There are test failures for which I don't have an explanation. Could you please rebase on top of release-1.13 again? I'm suspecting someone broke the branch. @AHeise

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[jira] [Comment Edited] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438989#comment-17438989 ] Leonard Xu edited comment on FLINK-14527 at 11/5/21, 1:47 AM: --

[jira] [Commented] (FLINK-14527) Add integeration tests for PostgreSQL and MySQL dialects in flink jdbc module

2021-11-04 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438989#comment-17438989 ] Leonard Xu commented on FLINK-14527: [~MartijnVisser] I think we need this, we did cover this from

[GitHub] [flink] leonardBang commented on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

2021-11-04 Thread GitBox
leonardBang commented on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-961556377 > @leonardBang Would you be able to help with a review? Yes, my pleasure -- This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17657: [FLINK-24745][format][json] Add support for Oracle OGG JSON format parser

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17657: URL: https://github.com/apache/flink/pull/17657#issuecomment-958746170 ## CI report: * bedfee8176a1e57581aacde1a032243ec5f9582b Azure:

[GitHub] [flink-training] sjwiesman opened a new pull request #42: [FLINK-24782] Upgrade training exercises to 1.14

2021-11-04 Thread GitBox
sjwiesman opened a new pull request #42: URL: https://github.com/apache/flink-training/pull/42 Upgrades Flink to 1.14. After merging, we will create a release-1.14 branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Updated] (FLINK-24782) Create 1.14 release branch for training repo

2021-11-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24782: --- Labels: pull-request-available (was: ) > Create 1.14 release branch for training repo >

[jira] [Updated] (FLINK-18255) Add API annotations to RocksDB user-facing classes

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18255: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18354) when use ParquetAvroWriters.forGenericRecord(Schema schema) error java.lang.ClassCastException: org.apache.flink.api.java.tuple.Tuple2 cannot be cast to org.apache.avro

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18354: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18245) Support to parse -1 for MemorySize and Duration ConfigOption

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18245: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18249) Cannot create index by time field?

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18249: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18210) The tmpdir will be clean up when stop historyserver

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18210: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18216) "Start time" column should not expand if a job is running

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18216: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18243) Flink SQL (1.10.0) From Kafkasource can not get data

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18243: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18167) Flink Job hangs there when one vertex is failed and another is cancelled.

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18167: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18379) Introduce asynchronous UDF/UDTF

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18379: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18180) unify the logic of time attribute derivation for both batch and streaming

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18180: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Updated] (FLINK-18357) ContinuousFileReaderOperator checkpoint timeout when files and directories get larger

2021-11-04 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18357: --- Labels: auto-deprioritized-major stale-minor (was: auto-deprioritized-major) I am the

[jira] [Comment Edited] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438953#comment-17438953 ] Seth Wiesman edited comment on FLINK-24767 at 11/4/21, 10:19 PM: - -When

[GitHub] [flink] flinkbot edited a comment on pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17501: URL: https://github.com/apache/flink/pull/17501#issuecomment-944297212 ## CI report: * b48104914a31c05ad902cb0c36aef52b2b4093a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 947cf916e75db07707842940dab5dac62b5c71c5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17387: [WIP][FLINK-23486][state] ChangelogUploader metrics

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17387: URL: https://github.com/apache/flink/pull/17387#issuecomment-930245327 ## CI report: * 947cf916e75db07707842940dab5dac62b5c71c5 Azure:

[jira] [Commented] (FLINK-24767) A keyBy following countWindow does not preserve order within the same partition

2021-11-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438953#comment-17438953 ] Seth Wiesman commented on FLINK-24767: -- When executing a `keyBy` under batch execution, the

[GitHub] [flink] flinkbot edited a comment on pull request #17688: [FLINK-24778][table-common] Add DataTypes#ROW(List) to reduce friction when using Stream of fields

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17688: URL: https://github.com/apache/flink/pull/17688#issuecomment-961225517 ## CI report: * b8eb494f1399b771c02a9d3f401bd14f9d168df3 Azure:

[jira] [Commented] (FLINK-24592) FlinkSQL multiline parser improvements

2021-11-04 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438943#comment-17438943 ] Sergey Nuyanzin commented on FLINK-24592: - Looks like from one side fix for this issue is ready

[GitHub] [flink] JingGe commented on a change in pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

2021-11-04 Thread GitBox
JingGe commented on a change in pull request #17574: URL: https://github.com/apache/flink/pull/17574#discussion_r743208772 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE ## @@ -21,7 +21,7 @@ This project bundles the following

[GitHub] [flink] JingGe removed a comment on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

2021-11-04 Thread GitBox
JingGe removed a comment on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-961425986 LGTM -- 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

[GitHub] [flink] JingGe commented on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

2021-11-04 Thread GitBox
JingGe commented on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-961425986 LGTM -- 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

[GitHub] [flink] JingGe commented on a change in pull request #17501: [Draft][FLINK-21406][RecordFormat] build AvroParquetRecordFormat for the new FileSource

2021-11-04 Thread GitBox
JingGe commented on a change in pull request #17501: URL: https://github.com/apache/flink/pull/17501#discussion_r743200328 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/avro/AvroParquetRecordFormat.java ## @@ -0,0 +1,189 @@ +/* + *

[jira] [Created] (FLINK-24782) Create 1.14 release branch for training repo

2021-11-04 Thread Seth Wiesman (Jira)
Seth Wiesman created FLINK-24782: Summary: Create 1.14 release branch for training repo Key: FLINK-24782 URL: https://issues.apache.org/jira/browse/FLINK-24782 Project: Flink Issue Type:

[jira] [Commented] (FLINK-24746) Alibaba maven mirror is unstable

2021-11-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438924#comment-17438924 ] Chesnay Schepler commented on FLINK-24746: -- Local Nexus instance used: 1.14:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 4f4b9435ed8af37966a5a5216f149745da511c84 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17688: [FLINK-24778][table-common] Add DataTypes#ROW(List) to reduce friction when using Stream of fields

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17688: URL: https://github.com/apache/flink/pull/17688#issuecomment-961225517 ## CI report: * 97585fd2ab3c7721c1be884f930554aa70b28688 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17679: [FLINK-24770] Remove error from JobStatusListener

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17679: URL: https://github.com/apache/flink/pull/17679#issuecomment-960792789 ## CI report: * c954966b6d8d000bb8498fe1bece6eae94c4f4ff UNKNOWN * d8bf558c545cc1eb9edb8808dfe6ec496e270897 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17574: [FLINK-24665][s3] Update Presto Hadoop dependency to v2.7.4-9

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17574: URL: https://github.com/apache/flink/pull/17574#issuecomment-952625580 ## CI report: * d66e0a7a35d44f839942dafe28aa7df2cfd3d932 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] Added Kinesis Data Streams Sink i…

2021-11-04 Thread GitBox
flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 543c11afd4a755b620b8318cdd62cf8551a079e7 Azure:

  1   2   3   4   5   6   7   8   >