[GitHub] [flink] flinkbot edited a comment on pull request #17732: [FLINK-24825][nifi] Update nifi-site-to-site-client to v1.14.0

flinkbot edited a comment on pull request #17732: URL: https://github.com/apache/flink/pull/17732#issuecomment-963897690 ## CI report: * 4176fea3a45ddf6032b9e11233c83e6bb92653b9 Azure:

[jira] [Updated] (FLINK-21470) SafetyNetCloseableRegistryTest.testSafetyNetClose fail

[ https://issues.apache.org/jira/browse/FLINK-21470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-21470: -- Summary: SafetyNetCloseableRegistryTest.testSafetyNetClose fail (was: testSafetyNetClose

[jira] [Commented] (FLINK-21470) SafetyNetCloseableRegistryTest.testSafetyNetClose fail

[ https://issues.apache.org/jira/browse/FLINK-21470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440956#comment-17440956 ] Till Rohrmann commented on FLINK-21470: --- Another instance:

[GitHub] [flink] flinkbot commented on pull request #17732: [FLINK-24825][nifi] Update nifi-site-to-site-client to v1.14.0

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

[jira] [Updated] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-23956: -- Priority: Critical (was: Major) > KafkaITCase.testOneSourceMultiplePartitions fails due to

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440954#comment-17440954 ] Till Rohrmann commented on FLINK-23956: --- fyi [~arvid] >

[jira] [Commented] (FLINK-23956) KafkaITCase.testOneSourceMultiplePartitions fails due to "The topic metadata failed to propagate to Kafka broker"

[ https://issues.apache.org/jira/browse/FLINK-23956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440953#comment-17440953 ] Till Rohrmann commented on FLINK-23956: --- Another instance:

[GitHub] [flink] flinkbot commented on pull request #17732: [FLINK-24825][nifi] Update nifi-site-to-site-client to v1.14.0

flinkbot commented on pull request #17732: URL: https://github.com/apache/flink/pull/17732#issuecomment-963897690 ## CI report: * 4176fea3a45ddf6032b9e11233c83e6bb92653b9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

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

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 04ce83574e39a3f4401c0d5f7b55cd3f4af01cd7 Azure:

[GitHub] [flink] fapaul commented on a change in pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

fapaul commented on a change in pull request #17731: URL: https://github.com/apache/flink/pull/17731#discussion_r745362976 ## File path:

[jira] [Closed] (FLINK-24659) Two active miniCluster in RemoteBenchmarkBase

[ https://issues.apache.org/jira/browse/FLINK-24659?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-24659. -- Fix Version/s: 1.15.0 Resolution: Fixed merged commit 0f8d2e3 into

[jira] [Updated] (FLINK-24825) Update nifi-site-to-site-client to v1.14.0

[ https://issues.apache.org/jira/browse/FLINK-24825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-24825: --- Labels: pull-request-available (was: ) > Update nifi-site-to-site-client to v1.14.0 >

[GitHub] [flink] MartijnVisser opened a new pull request #17732: [FLINK-24825][nifi] Update nifi-site-to-site-client to v1.14.0

MartijnVisser opened a new pull request #17732: URL: https://github.com/apache/flink/pull/17732 ## What is the purpose of the change * Update NiFi client to latest version ## Brief change log * Updated POM file to include latest version (currently v1.14.0) ##

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * edcadd9f732f4717bf5043b4c45c97e461e4e11b Azure:

[GitHub] [flink-ml] zhipeng93 commented on a change in pull request #10: [FLINK-24354][FLIP-174] Improve the WithParams interface

zhipeng93 commented on a change in pull request #10: URL: https://github.com/apache/flink-ml/pull/10#discussion_r745361122 ## File path: pom.xml ## @@ -53,11 +53,8 @@ under the License. flink-ml-api -flink-ml-lib Review comment: We should probably add

[jira] [Assigned] (FLINK-24481) Translate buffer debloat documenation to chinese

[ https://issues.apache.org/jira/browse/FLINK-24481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24481: -- Assignee: Liu (was: Jichun Liu) > Translate buffer debloat documenation to chinese

[jira] [Assigned] (FLINK-24481) Translate buffer debloat documenation to chinese

[ https://issues.apache.org/jira/browse/FLINK-24481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24481: -- Assignee: Jichun Liu > Translate buffer debloat documenation to chinese >

[jira] [Commented] (FLINK-24481) Translate buffer debloat documenation to chinese

[ https://issues.apache.org/jira/browse/FLINK-24481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440950#comment-17440950 ] Piotr Nowojski commented on FLINK-24481: Sure [~Jiangang], done. > Translate buffer debloat

[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

flinkbot edited a comment on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619732 ## CI report: * 1d59aedd2d99a67943fb4cf11955971784edb2cb Azure:

[jira] [Updated] (FLINK-24838) Add BaseAlgoImpl class to support link and linkFrom (FlinkML)

[ https://issues.apache.org/jira/browse/FLINK-24838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-24838: -- Summary: Add BaseAlgoImpl class to support link and linkFrom (FlinkML) (was: Add

[jira] [Updated] (FLINK-24838) Add BaseAlgoImpl class to support link() and linkFrom() (FlinkML)

[ https://issues.apache.org/jira/browse/FLINK-24838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhipeng Zhang updated FLINK-24838: -- Summary: Add BaseAlgoImpl class to support link() and linkFrom() (FlinkML) (was: Add

[jira] [Created] (FLINK-24838) Add BaseAlgoImpl class to support link() and linkFrom()

Zhipeng Zhang created FLINK-24838: - Summary: Add BaseAlgoImpl class to support link() and linkFrom() Key: FLINK-24838 URL: https://issues.apache.org/jira/browse/FLINK-24838 Project: Flink

[jira] [Assigned] (FLINK-24376) Operator name in OperatorCoordinator should not use chained name

[ https://issues.apache.org/jira/browse/FLINK-24376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-24376: -- Assignee: Qingsheng Ren > Operator name in OperatorCoordinator should not use

[GitHub] [flink-training] NicoK commented on a change in pull request #42: [FLINK-24782] Upgrade training exercises to 1.14

NicoK commented on a change in pull request #42: URL: https://github.com/apache/flink-training/pull/42#discussion_r745353261 ## File path: common/build.gradle ## @@ -14,11 +14,11 @@ dependencies { // Compile-time dependencies that should NOT be part of the // shadow

[jira] [Commented] (FLINK-24690) Clarification of buffer size threshold calculation in BufferDebloater

[ https://issues.apache.org/jira/browse/FLINK-24690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440943#comment-17440943 ] Piotr Nowojski commented on FLINK-24690: I would be in favour of simplifying this so that

[jira] [Commented] (FLINK-24831) Upgrade DataStream Window examples

[ https://issues.apache.org/jira/browse/FLINK-24831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440939#comment-17440939 ] Yao Zhang commented on FLINK-24831: --- Hi [~sjwiesman] , I can help you with it. Should I go over all

[jira] [Commented] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440937#comment-17440937 ] loyi commented on FLINK-23190: -- Hi, [~trohrmann] , it seems to be a few months since we last talked about

[GitHub] [flink] beyond1920 commented on a change in pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

beyond1920 commented on a change in pull request #17651: URL: https://github.com/apache/flink/pull/17651#discussion_r745333651 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-deduplication.md ## @@ -0,0 +1,93 @@ +--- +title: "窗口去重" +weight: 16 +type: docs +---

[GitHub] [flink] beyond1920 commented on a change in pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

beyond1920 commented on a change in pull request #17651: URL: https://github.com/apache/flink/pull/17651#discussion_r745332586 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-deduplication.md ## @@ -0,0 +1,93 @@ +--- +title: "窗口去重" +weight: 16 +type: docs +---

[GitHub] [flink] beyond1920 commented on a change in pull request #17651: [FLINK-24656][docs] Add documentation for window deduplication

beyond1920 commented on a change in pull request #17651: URL: https://github.com/apache/flink/pull/17651#discussion_r745330897 ## File path: docs/content.zh/docs/dev/table/sql/queries/window-deduplication.md ## @@ -0,0 +1,93 @@ +--- +title: "窗口去重" +weight: 16 +type: docs +---

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

flinkbot edited a comment on pull request #17632: URL: https://github.com/apache/flink/pull/17632#issuecomment-956326604 ## CI report: * 70cfb98caf145627e2d46aabf14d4e5b41956e0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

flinkbot edited a comment on pull request #17632: URL: https://github.com/apache/flink/pull/17632#issuecomment-956326604 ## CI report: * 70cfb98caf145627e2d46aabf14d4e5b41956e0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * 01a81f7dc9dcfc1289db980385c8524335c7b386 Azure:

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

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * 8e3f7755d4812df721ff4038c2f0b1599c759af6 Azure:

[jira] [Created] (FLINK-24837) submit flink job failed via restapi

Spongebob created FLINK-24837: - Summary: submit flink job failed via restapi Key: FLINK-24837 URL: https://issues.apache.org/jira/browse/FLINK-24837 Project: Flink Issue Type: Bug

[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

flinkbot edited a comment on pull request #17689: URL: https://github.com/apache/flink/pull/17689#issuecomment-961619732 ## CI report: * b76e02bc31eb3d1c6e757e7cbc0cd1561777844c 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

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

[jira] [Updated] (FLINK-24836) Over window in month time calculated an incorrect aggregation result.

[ https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-24836: - Description: 1. When i use tumble window in month, it throw an exception: _Window aggregate only SECOND,

[jira] [Updated] (FLINK-24836) Over window in month time calculated an incorrect aggregation result.

[ https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-24836: - Description: 1. When i use tumble window in month, it throw an exception: _Window aggregate only SECOND,

[jira] [Updated] (FLINK-24836) Over window in month time calculated an incorrect aggregation result.

[ https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-24836: - Attachment: image-2021-11-09-12-32-04-053.png > Over window in month time calculated an incorrect aggregation

[jira] [Updated] (FLINK-24836) Over window in month time calculated an incorrect aggregation result.

[ https://issues.apache.org/jira/browse/FLINK-24836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Carl updated FLINK-24836: - Description: 1. When i use tumble window in month, it throw an exception: _Window aggregate only SECOND,

[jira] [Created] (FLINK-24836) Over window in month time calculated an incorrect aggregation result.

Carl created FLINK-24836: Summary: Over window in month time calculated an incorrect aggregation result. Key: FLINK-24836 URL: https://issues.apache.org/jira/browse/FLINK-24836 Project: Flink Issue

[jira] [Assigned] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he reassigned FLINK-24835: -- Assignee: JING ZHANG > "group by" in the interval join will throw a exception >

[jira] [Commented] (FLINK-24835) "group by" in the interval join will throw a exception

[ https://issues.apache.org/jira/browse/FLINK-24835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440890#comment-17440890 ] JING ZHANG commented on FLINK-24835: [~xuyangzhong] Thanks for reporting this problem. The case is

[jira] [Commented] (FLINK-24000) window aggregate support allow lateness

[ https://issues.apache.org/jira/browse/FLINK-24000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440888#comment-17440888 ] Yuepeng Pan commented on FLINK-24000: - Hi, [~qingru zhang] [~MartijnVisser] . I'm very interested in

[jira] [Commented] (FLINK-24002) Support count window with the window TVF

[ https://issues.apache.org/jira/browse/FLINK-24002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440889#comment-17440889 ] Yuepeng Pan commented on FLINK-24002: - Hi, [~qingru zhang]  [~twalthr] . Could you please assign

[GitHub] [flink] flinkbot edited a comment on pull request #17598: [WIP][FLINK-24703][connectors][formats] Add FileSource support for reading CSV files.

flinkbot edited a comment on pull request #17598: URL: https://github.com/apache/flink/pull/17598#issuecomment-954282485 ## CI report: * 6aea9ddf28bf11ed35c87ef57e477fecca94f266 Azure:

[jira] [Updated] (FLINK-24761) Fix PartitionPruner code gen compile fail

[ https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-24761: - Fix Version/s: 1.15.0 1.14.1 1.13.4 > Fix PartitionPruner

[jira] [Closed] (FLINK-24761) Fix PartitionPruner code gen compile fail

[ https://issues.apache.org/jira/browse/FLINK-24761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-24761. Resolution: Fixed master: 08a5969069b23ae831fbc8f759c9d7fe9473ffde release-1.14:

[GitHub] [flink] JingsongLi merged pull request #17724: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

JingsongLi merged pull request #17724: URL: https://github.com/apache/flink/pull/17724 -- 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] flinkbot edited a comment on pull request #17676: [FLINK-14100][connectors] Add Oracle dialect

flinkbot edited a comment on pull request #17676: URL: https://github.com/apache/flink/pull/17676#issuecomment-960641444 ## CI report: * 7255961d5deef5f150679ca64753ccf886faae75 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17724: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17724: URL: https://github.com/apache/flink/pull/17724#issuecomment-963167087 ## CI report: * c9ce7f29985ef0b82983c86ca24920b54ebb67f3 Azure:

[jira] [Created] (FLINK-24835) "group by" in the interval join will throw a exception

xuyang created FLINK-24835: -- Summary: "group by" in the interval join will throw a exception Key: FLINK-24835 URL: https://issues.apache.org/jira/browse/FLINK-24835 Project: Flink Issue Type: Bug

[GitHub] [flink] ysymi commented on a change in pull request #17698: [FLINK-24689][runtime-web] Add log's last modify time in log list view

ysymi commented on a change in pull request #17698: URL: https://github.com/apache/flink/pull/17698#discussion_r745257054 ## File path: flink-runtime-web/web-dashboard/src/app/pages/task-manager/log-list/task-manager-log-list.component.html ## @@ -29,14 +29,16 @@

[GitHub] [flink] beyond1920 commented on a change in pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

beyond1920 commented on a change in pull request #17632: URL: https://github.com/apache/flink/pull/17632#discussion_r745252868 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWindowDeduplicate.java ##

[GitHub] [flink] beyond1920 commented on a change in pull request #17632: [FLINK-23014][table-planner] Support streaming window Deduplicate in planner

beyond1920 commented on a change in pull request #17632: URL: https://github.com/apache/flink/pull/17632#discussion_r745252868 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecWindowDeduplicate.java ##

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

[ https://issues.apache.org/jira/browse/FLINK-13247 ] roryqi deleted comment on FLINK-13247: was (Author: roryqi): [~maguowei] Can I give me your email? I want to communicate with you about the remote shuffle service? > Implement external shuffle

[jira] [Closed] (FLINK-24823) Yarn-session report metrics error

[ https://issues.apache.org/jira/browse/FLINK-24823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] douyongpeng closed FLINK-24823. --- Resolution: Fixed > Yarn-session report metrics error > - > >

[GitHub] [flink] baisui1981 commented on pull request #17521: [FLINK-24558][API/DataStream]make parent ClassLoader variable which c…

baisui1981 commented on pull request #17521: URL: https://github.com/apache/flink/pull/17521#issuecomment-963767164 > I'm sorry, but that implementation sounds really unsafe and will only work for the simplest of use-cases. Let's say you have 2 of your plugin jars that both bundle the

[jira] [Commented] (FLINK-24632) "where ... in(..)" has wrong result

[ https://issues.apache.org/jira/browse/FLINK-24632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440862#comment-17440862 ] godfrey he commented on FLINK-24632: This is a valid query, but not much business value > "where

[GitHub] [flink] wangyang0918 commented on pull request #17685: [FLINK-24631][Kubernetes]Use minimal selector to select jobManager and taskManager pod

wangyang0918 commented on pull request #17685: URL: https://github.com/apache/flink/pull/17685#issuecomment-963760870 @Aitozi Could you please check the azure failure first? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] 1996fanrui commented on pull request #17668: [FLINK-24401][runtime] Fix the bug of TM cannot exit after Metaspace OOM

1996fanrui commented on pull request #17668: URL: https://github.com/apache/flink/pull/17668#issuecomment-963759700 Thanks for your review. @pnowojski -- 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] flinkbot edited a comment on pull request #17724: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17724: URL: https://github.com/apache/flink/pull/17724#issuecomment-963167087 ## CI report: * c9ce7f29985ef0b82983c86ca24920b54ebb67f3 Azure:

[jira] [Closed] (FLINK-24822) Improve CatalogTableSpecBase and its subclass method parameter

[ https://issues.apache.org/jira/browse/FLINK-24822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he closed FLINK-24822. -- Resolution: Fixed Fixed in 1.15.0: 34e7c650319e96cc4f77f46ea4ecf4a1416e6c5e > Improve

[GitHub] [flink] flinkbot edited a comment on pull request #17724: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

flinkbot edited a comment on pull request #17724: URL: https://github.com/apache/flink/pull/17724#issuecomment-963167087 ## CI report: * c9ce7f29985ef0b82983c86ca24920b54ebb67f3 Azure:

[GitHub] [flink] godfreyhe closed pull request #17721: [FLINK-24822][table-planner]Improve CatalogTableSpecBase and its subclass related method parameter

godfreyhe closed pull request #17721: URL: https://github.com/apache/flink/pull/17721 -- 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] JingsongLi commented on pull request #17724: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

JingsongLi commented on pull request #17724: URL: https://github.com/apache/flink/pull/17724#issuecomment-963755941 @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] FiveAgo commented on pull request #17592: There is a misspelling of a word in YarnConfigOptions.java

FiveAgo commented on pull request #17592: URL: https://github.com/apache/flink/pull/17592#issuecomment-963748407 @MartijnVisser What should I do next？ or I just wait？ -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

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

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 8707347fb7ab300580791bb58e4d188f20db607a Azure:

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

flinkbot edited a comment on pull request #17653: URL: https://github.com/apache/flink/pull/17653#issuecomment-958686553 ## CI report: * 8707347fb7ab300580791bb58e4d188f20db607a Azure:

[GitHub] [flink] JingsongLi merged pull request #17723: [FLINK-24761][table] Fix PartitionPruner code gen compile fail

JingsongLi merged pull request #17723: URL: https://github.com/apache/flink/pull/17723 -- 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-24802) Improve cast ROW to STRING

[ https://issues.apache.org/jira/browse/FLINK-24802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440850#comment-17440850 ] Shen Zhu commented on FLINK-24802: -- Hey Timo, I was checking the unit tests and seems casting from ROW

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * 80fbcfa899e495cd367dc7c94e9ced2b6b21aaac Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

flinkbot edited a comment on pull request #17711: URL: https://github.com/apache/flink/pull/17711#issuecomment-962917757 ## CI report: * 80fbcfa899e495cd367dc7c94e9ced2b6b21aaac Azure:

[GitHub] [flink] yangjunhan commented on a change in pull request #17711: [FLINK-24737][runtime-web] Update outdated web dependencies

yangjunhan commented on a change in pull request #17711: URL: https://github.com/apache/flink/pull/17711#discussion_r745225460 ## File path: flink-runtime-web/web-dashboard/package.json ## @@ -9,72 +9,73 @@ "lint": "eslint --cache src --ext .ts,.html && stylelint

[GitHub] [flink] flinkbot edited a comment on pull request #17731: [FLINK-24834][connectors / filesystem] Add typed builders to DefaultRollingPolicy

flinkbot edited a comment on pull request #17731: URL: https://github.com/apache/flink/pull/17731#issuecomment-963552076 ## CI report: * 85ea82b249c6bee70d296e25d1b324d8f43fe67b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17730: [FLINK-24829][examples] Rename example directories based on API

flinkbot edited a comment on pull request #17730: URL: https://github.com/apache/flink/pull/17730#issuecomment-963506792 ## CI report: * 32df2c2cc81d26abc28dd0aec014e7c84cd191b4 Azure:

[GitHub] [flink] cmick commented on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

cmick commented on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-963655134 @fapaul Thanks, You're absolutely right here. I've added resetting the DummyContext state in 01a81f7. Now it can be run multiple times - I've executed it locally a thousand times

[jira] (FLINK-24773) KafkaCommitter should fail on unknown Exception

[ https://issues.apache.org/jira/browse/FLINK-24773 ] Anand M deleted comment on FLINK-24773: - was (Author: amatts): Hi I'd like to work on this, can this please be assigned to me?  > KafkaCommitter should fail on unknown Exception >

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

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * a4bfd1285575f38165a928dd0a0ed1c4efe213e8 Azure:

[GitHub] [flink] CrynetLogistics commented on pull request #17687: [FLINK-24227][connectors] Improved AsyncSink base by adding a builder…

CrynetLogistics commented on pull request #17687: URL: https://github.com/apache/flink/pull/17687#issuecomment-963652742 Tests pass  -- 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 #17345: [FLINK-24227][connectors/kinesis] Added Kinesis Data Streams Sink i…

flinkbot edited a comment on pull request #17345: URL: https://github.com/apache/flink/pull/17345#issuecomment-926109717 ## CI report: * a4bfd1285575f38165a928dd0a0ed1c4efe213e8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * 4bed55593cdf11d800dcf0f63443bb9a2bfd21ad Azure:

[jira] [Commented] (FLINK-24773) KafkaCommitter should fail on unknown Exception

[ https://issues.apache.org/jira/browse/FLINK-24773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440809#comment-17440809 ] Anand M commented on FLINK-24773: - Hi I'd like to work on this, can this please be assigned to me?  >

[GitHub] [flink] flinkbot edited a comment on pull request #17708: [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck

flinkbot edited a comment on pull request #17708: URL: https://github.com/apache/flink/pull/17708#issuecomment-962715413 ## CI report: * 4bed55593cdf11d800dcf0f63443bb9a2bfd21ad Azure:

[jira] [Updated] (FLINK-16575) develop HBaseCatalog to integrate HBase metadata into Flink

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

[jira] [Updated] (FLINK-16419) Avoid to recommit transactions which are known committed successfully to Kafka upon recovery

[ https://issues.apache.org/jira/browse/FLINK-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16419: --- Labels: auto-deprioritized-major stale-minor usability (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16553) Missing KafkaFetcher topic/partition metrics

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

[jira] [Updated] (FLINK-20350) [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict

[ https://issues.apache.org/jira/browse/FLINK-20350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20350: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-16425) Add rate limiting feature for kafka table source

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

[jira] [Updated] (FLINK-20368) Supports custom operator name for Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-20368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20368: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21788) Throw PartitionNotFoundException if the partition file has been lost for blocking shuffle

[ https://issues.apache.org/jira/browse/FLINK-21788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21788: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state (registry+changelog)

[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23139: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-16446) Add rate limiting feature for FlinkKafkaConsumer

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

[jira] [Updated] (FLINK-20289) Computed columns can be calculated after ChangelogNormalize to reduce shuffle

[ https://issues.apache.org/jira/browse/FLINK-20289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-20289: --- Labels: auto-deprioritized-major auto-deprioritized-minor (was: auto-deprioritized-major

[jira] [Updated] (FLINK-21439) Adaptive Scheduler: Add support for exception history

[ https://issues.apache.org/jira/browse/FLINK-21439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-21439: --- Labels: pull-request-available reactive stale-assigned (was: pull-request-available

[jira] [Updated] (FLINK-16578) join lateral table function with condition fails with exception

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

[jira] [Updated] (FLINK-16420) Support CREATE TABLE with schema inference

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

[jira] [Updated] (FLINK-23190) Make task-slot allocation much more evenly

[ https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-23190: --- Labels: pull-request-available stale-assigned (was: pull-request-available) I am the

[jira] [Updated] (FLINK-16551) WebFrontendITCase.getFrontPage fails

[ https://issues.apache.org/jira/browse/FLINK-16551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-16551: --- Labels: auto-deprioritized-major pull-request-available stale-minor test-stability (was:

  1   2   3   4   5   6   7   8   >