[jira] [Created] (FLINK-24560) flink-yarn-tests should copy examples after package phase

Chesnay Schepler created FLINK-24560: Summary: flink-yarn-tests should copy examples after package phase Key: FLINK-24560 URL: https://issues.apache.org/jira/browse/FLINK-24560 Project: Flink

[jira] [Updated] (FLINK-24559) flink-rpc-akka-loader does not bundle flink-rpc-akka

[ https://issues.apache.org/jira/browse/FLINK-24559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24559: - Issue Type: Bug (was: Technical Debt) > flink-rpc-akka-loader does not bundle

[jira] [Updated] (FLINK-24559) flink-rpc-akka-loader does not bundle flink-rpc-akka

[ https://issues.apache.org/jira/browse/FLINK-24559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24559: - Issue Type: Technical Debt (was: Bug) > flink-rpc-akka-loader does not bundle

[jira] [Updated] (FLINK-24559) flink-rpc-akka-loader does not bundle flink-rpc-akka

[ https://issues.apache.org/jira/browse/FLINK-24559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-24559: - Priority: Blocker (was: Major) > flink-rpc-akka-loader does not bundle flink-rpc-akka

[jira] [Created] (FLINK-24559) flink-rpc-akka-loader does not bundle flink-rpc-akka

Chesnay Schepler created FLINK-24559: Summary: flink-rpc-akka-loader does not bundle flink-rpc-akka Key: FLINK-24559 URL: https://issues.apache.org/jira/browse/FLINK-24559 Project: Flink

[jira] [Updated] (FLINK-24558) dataStream can not use multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-24558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bai sui updated FLINK-24558: Description: create a dataStream demo as below，in the demo，create a very simple example， read stream

[jira] [Created] (FLINK-24558) dataStream can not use multiple classloaders

bai sui created FLINK-24558: --- Summary: dataStream can not use multiple classloaders Key: FLINK-24558 URL: https://issues.apache.org/jira/browse/FLINK-24558 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-24557) Support Knn in FlinkML

weibo zhao created FLINK-24557: -- Summary: Support Knn in FlinkML Key: FLINK-24557 URL: https://issues.apache.org/jira/browse/FLINK-24557 Project: Flink Issue Type: Bug Components:

[jira] [Created] (FLINK-24556) Support Logistic Regression in FlinkML

Zhipeng Zhang created FLINK-24556: - Summary: Support Logistic Regression in FlinkML Key: FLINK-24556 URL: https://issues.apache.org/jira/browse/FLINK-24556 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-24351) translate "JSON Function" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429101#comment-17429101 ] ZhuoYu Chen commented on FLINK-24351: - Hi [~jark],{color:#33}I saw that some lines were not

[jira] [Updated] (FLINK-24351) translate "JSON Function" pages into Chinese

[ https://issues.apache.org/jira/browse/FLINK-24351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ZhuoYu Chen updated FLINK-24351: Attachment: sql_functions_zh.yml > translate "JSON Function" pages into Chinese >

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Commented] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429095#comment-17429095 ] Junfan Zhang commented on FLINK-24555: -- [~jark] Could you help review it? Thanks > Incorrectly put

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Commented] (FLINK-15832) Test jars are installed twice

[ https://issues.apache.org/jira/browse/FLINK-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429094#comment-17429094 ] Xianxun Ye commented on FLINK-15832: version: Flink1.12.4 have the same problem. > Test jars are

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Commented] (FLINK-24497) Kafka metrics fetching throws IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-24497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429090#comment-17429090 ] Qingsheng Ren commented on FLINK-24497: --- Thank for reporting this issue! Looking into the warn log

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as

[jira] [Updated] (FLINK-24555) Incorrectly put empty list to flink configuration

[ https://issues.apache.org/jira/browse/FLINK-24555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junfan Zhang updated FLINK-24555: - Description: h2. Why As I found some warn logs in our production flink jobs, like as follows

[jira] [Created] (FLINK-24555) Incorrectly put empty list to flink configuration

Junfan Zhang created FLINK-24555: Summary: Incorrectly put empty list to flink configuration Key: FLINK-24555 URL: https://issues.apache.org/jira/browse/FLINK-24555 Project: Flink Issue

[jira] [Created] (FLINK-24554) Support metadata columns for format-json

WangMinChao created FLINK-24554: --- Summary: Support metadata columns for format-json Key: FLINK-24554 URL: https://issues.apache.org/jira/browse/FLINK-24554 Project: Flink Issue Type: New

[jira] [Resolved] (FLINK-24432) RocksIteratorWrapper.seekToLast() calls the wrong RocksIterator method

[ https://issues.apache.org/jira/browse/FLINK-24432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang resolved FLINK-24432. -- Fix Version/s: 1.14.1 1.15.0 Resolution: Fixed merged in master:

[jira] [Comment Edited] (FLINK-24497) Kafka metrics fetching throws IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-24497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429034#comment-17429034 ] Preston Price edited comment on FLINK-24497 at 10/14/21, 10:55 PM: --- It

[jira] [Comment Edited] (FLINK-24497) Kafka metrics fetching throws IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-24497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429034#comment-17429034 ] Preston Price edited comment on FLINK-24497 at 10/14/21, 10:53 PM: --- It

[jira] [Commented] (FLINK-24497) Kafka metrics fetching throws IllegalStateException

[ https://issues.apache.org/jira/browse/FLINK-24497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17429034#comment-17429034 ] Preston Price commented on FLINK-24497: --- It looks like this new metric "records-lag" was

[jira] [Assigned] (FLINK-24516) Modernize Maven Archetype

[ https://issues.apache.org/jira/browse/FLINK-24516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman reassigned FLINK-24516: Assignee: Seth Wiesman > Modernize Maven Archetype > - > >

[jira] [Commented] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing

[ https://issues.apache.org/jira/browse/FLINK-24493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428994#comment-17428994 ] Rion Williams commented on FLINK-24493: --- [~fabian.paul] / [~dmvk] / [~arvid] I had a bit of time

[jira] [Comment Edited] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing

[ https://issues.apache.org/jira/browse/FLINK-24493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428994#comment-17428994 ] Rion Williams edited comment on FLINK-24493 at 10/14/21, 7:52 PM: --

[GitHub] [flink] AHeise commented on a change in pull request #17374: [FLINK-24327][connectors/elasticsearch] Add Elasticsearch 7 sink for table API

AHeise commented on a change in pull request #17374: URL: https://github.com/apache/flink/pull/17374#discussion_r729115471 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/DynamicTableFactory.java ## @@ -95,11 +95,11 @@ *

[GitHub] [flink] flinkbot edited a comment on pull request #17481: [FLINK-24387][table-planner] Support JSON_STRING.

flinkbot edited a comment on pull request #17481: URL: https://github.com/apache/flink/pull/17481#issuecomment-943273916 ## CI report: * 37ac25e77251b0665bffb3c0e5640dd58c9f4176 Azure:

[GitHub] [flink] Airblader commented on a change in pull request #17483: [FLINK-24547][Table SQL / Planner]A function named row_kind() can get…

Airblader commented on a change in pull request #17483: URL: https://github.com/apache/flink/pull/17483#discussion_r729129963 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala ## @@ -504,6 +504,19 @@ object

[GitHub] [flink] Airblader commented on a change in pull request #17483: [FLINK-24547][Table SQL / Planner]A function named row_kind() can get…

Airblader commented on a change in pull request #17483: URL: https://github.com/apache/flink/pull/17483#discussion_r729124623 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala ## @@ -504,6 +504,19 @@ object

[GitHub] [flink] flinkbot edited a comment on pull request #17485: [FLINK-24038] Add support for single leader election per JobManager process

flinkbot edited a comment on pull request #17485: URL: https://github.com/apache/flink/pull/17485#issuecomment-943315428 ## CI report: * 6934d6236ab71309c59fab4432aa3234fe916e12 Azure:

[GitHub] [flink] AHeise commented on a change in pull request #17447: [hotfix] Update release notes with changes to StreamStatus

AHeise commented on a change in pull request #17447: URL: https://github.com/apache/flink/pull/17447#discussion_r729113800 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -201,6 +201,19 @@ applications do not interfere with each other. ### DataStream API

[GitHub] [flink] AHeise commented on a change in pull request #17447: [hotfix] Update release notes with changes to StreamStatus

AHeise commented on a change in pull request #17447: URL: https://github.com/apache/flink/pull/17447#discussion_r729113800 ## File path: docs/content.zh/release-notes/flink-1.14.md ## @@ -201,6 +201,19 @@ applications do not interfere with each other. ### DataStream API

[GitHub] [flink] akalash commented on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

akalash commented on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-943469088 I don't really sure about this proposal because we already create the client via clientBuilder, and then, by some reason, we need to wait on a future before the call of the one

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17481: [FLINK-24387][table-planner] Support JSON_STRING.

flinkbot edited a comment on pull request #17481: URL: https://github.com/apache/flink/pull/17481#issuecomment-943273916 ## CI report: * e0c506d88d78c9ce851b2fd080e55ad5e4d879a0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17444: [FLINK-24492][table-planner]incorrect implicit type conversion between numeric and (var)char

flinkbot edited a comment on pull request #17444: URL: https://github.com/apache/flink/pull/17444#issuecomment-939291136 ## CI report: * c4bd90be195feb51f8e2535d61779d431b6d1ae4 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17484: [hotfix][docs] Add Analytics GA4 implementation to be prepared for migration

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

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17480: [FLINK-24122][history] Add support to do clean in history server

flinkbot edited a comment on pull request #17480: URL: https://github.com/apache/flink/pull/17480#issuecomment-943265296 ## CI report: * faa63de3f17e8821c10b7400af909e1f66bd2268 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17479: [FLINK-24469][runtime] Allowed to have zero number of buffers in use …

flinkbot edited a comment on pull request #17479: URL: https://github.com/apache/flink/pull/17479#issuecomment-943241595 ## CI report: * dea92ed66f4965ffaba0afdb97653d01e877843e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[jira] [Updated] (FLINK-24553) Change buffer debloating default configuration values

[ https://issues.apache.org/jira/browse/FLINK-24553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24553: -- Description: After the investigation for buffer debloating effectiveness, there are

[GitHub] [flink] victorunique commented on pull request #17475: [FLINK-24432][rocksdb] RocksIteratorWrapper.seekToLast() logic typo

victorunique commented on pull request #17475: URL: https://github.com/apache/flink/pull/17475#issuecomment-943401610 @Myasuka CI works fine. Thanks. -- 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

[jira] [Comment Edited] (FLINK-24536) flink sql where condition is not supported != writing

[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428822#comment-17428822 ] Marios Trivyzas edited comment on FLINK-24536 at 10/14/21, 2:15 PM:

[GitHub] [flink] dawidwys commented on a change in pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

dawidwys commented on a change in pull request #17471: URL: https://github.com/apache/flink/pull/17471#discussion_r728988282 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BufferTimeoutITCase.java ## @@ -0,0 +1,87 @@ +/* + * Licensed to the

[jira] [Created] (FLINK-24553) Change buffer debloating default configuration values

Anton Kalashnikov created FLINK-24553: - Summary: Change buffer debloating default configuration values Key: FLINK-24553 URL: https://issues.apache.org/jira/browse/FLINK-24553 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

pnowojski commented on a change in pull request #17471: URL: https://github.com/apache/flink/pull/17471#discussion_r729026826 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BufferTimeoutITCase.java ## @@ -0,0 +1,87 @@ +/* + * Licensed to the

[GitHub] [flink] dawidwys commented on a change in pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

dawidwys commented on a change in pull request #17471: URL: https://github.com/apache/flink/pull/17471#discussion_r729026251 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -105,9 +105,7 @@

[jira] [Comment Edited] (FLINK-24489) The size of entryCache & eventsBufferCache in the SharedBuffer should be defined with a threshold to limit the number of the elements in the cache

[ https://issues.apache.org/jira/browse/FLINK-24489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428173#comment-17428173 ] Yuepeng Pan edited comment on FLINK-24489 at 10/14/21, 2:00 PM: Thanks

[jira] [Created] (FLINK-24552) Ineffective buffer debloat configuration in randomized tests

Dawid Wysakowicz created FLINK-24552: Summary: Ineffective buffer debloat configuration in randomized tests Key: FLINK-24552 URL: https://issues.apache.org/jira/browse/FLINK-24552 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #17482: [FLINK-24546][docs]fix miss Acknowledged description on Monitoring Ch…

flinkbot edited a comment on pull request #17482: URL: https://github.com/apache/flink/pull/17482#issuecomment-943277366 ## CI report: * 37bdb7a10810a10a3401241d8f5bb192b4862edf Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17473: [FLINK-24470][runtime] EMA calculation move to BufferDebloater

flinkbot edited a comment on pull request #17473: URL: https://github.com/apache/flink/pull/17473#issuecomment-943109733 ## CI report: * e10ec336a7b9defc556c45c601f55112f8659c89 Azure:

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

[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24551: -- Description: Right now, StreamTask receives the BUFFER_DEBLOAT_SAMPLES property from

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

[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24551: -- Component/s: Runtime / Checkpointing > BUFFER_DEBLOAT_SAMPLES property is taken from

[jira] [Commented] (FLINK-24536) flink sql where condition is not supported != writing

[ https://issues.apache.org/jira/browse/FLINK-24536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428822#comment-17428822 ] Marios Trivyzas commented on FLINK-24536: - *!=* is not in the SQL standard, but some DBs

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

[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24551: -- Affects Version/s: 1.14.0 > BUFFER_DEBLOAT_SAMPLES property is taken from the wrong

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

[ https://issues.apache.org/jira/browse/FLINK-24551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anton Kalashnikov updated FLINK-24551: -- Component/s: (was: Runtime / Checkpointing) Runtime / Task >

[GitHub] [flink] flinkbot edited a comment on pull request #17473: [FLINK-24470][runtime] EMA calculation move to BufferDebloater

flinkbot edited a comment on pull request #17473: URL: https://github.com/apache/flink/pull/17473#issuecomment-943109733 ## CI report: * e10ec336a7b9defc556c45c601f55112f8659c89 Azure:

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

Anton Kalashnikov created FLINK-24551: - Summary: BUFFER_DEBLOAT_SAMPLES property is taken from the wrong configuration Key: FLINK-24551 URL: https://issues.apache.org/jira/browse/FLINK-24551

[jira] [Updated] (FLINK-24550) Can not access job information from a standby jobmanager UI

[ https://issues.apache.org/jira/browse/FLINK-24550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24550: - Description: One can not access the "running jobs" section (if a job is running) or if

[jira] [Updated] (FLINK-24550) Can not access job information from a standby jobmanager UI

[ https://issues.apache.org/jira/browse/FLINK-24550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-24550: - Description: One can not access the "running jobs" section (if a job is running) or if

[jira] [Created] (FLINK-24550) Can not access job information from a standby jobmanager UI

Dawid Wysakowicz created FLINK-24550: Summary: Can not access job information from a standby jobmanager UI Key: FLINK-24550 URL: https://issues.apache.org/jira/browse/FLINK-24550 Project: Flink

[GitHub] [flink] dawidwys commented on a change in pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

dawidwys commented on a change in pull request #17471: URL: https://github.com/apache/flink/pull/17471#discussion_r728988282 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BufferTimeoutITCase.java ## @@ -0,0 +1,87 @@ +/* + * Licensed to the

[GitHub] [flink] pnowojski commented on a change in pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

pnowojski commented on a change in pull request #17471: URL: https://github.com/apache/flink/pull/17471#discussion_r728984824 ## File path: flink-tests/src/test/java/org/apache/flink/test/streaming/runtime/BufferTimeoutITCase.java ## @@ -0,0 +1,87 @@ +/* + * Licensed to the

[GitHub] [flink] flinkbot edited a comment on pull request #17345: [FLINK-24227][connectors] FLIP-171: 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: * 22da70a0496dc779777fe3b46e0c6ad306584b59 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

pnowojski commented on a change in pull request #17471: URL: https://github.com/apache/flink/pull/17471#discussion_r728983541 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java ## @@ -105,9 +105,7 @@

[jira] [Commented] (FLINK-24549) FlinkKinesisConsumer does not work with generic types disabled

[ https://issues.apache.org/jira/browse/FLINK-24549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428811#comment-17428811 ] Danny Cranmer commented on FLINK-24549: --- Seems like it should be a simple fix, I can pick this up

[GitHub] [flink] zentol commented on a change in pull request #17402: [FLINK-24017] Setup Kryo to be usable without flink-scala

zentol commented on a change in pull request #17402: URL: https://github.com/apache/flink/pull/17402#discussion_r728979086 ## File path: flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/KryoUtils.java ## @@ -90,28 +90,32 @@ * Apply a list of {@link

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17471: [FLINK-24465] Fix disabling buffer timeout for pipelined exchanges

flinkbot edited a comment on pull request #17471: URL: https://github.com/apache/flink/pull/17471#issuecomment-943073814 ## CI report: * 69f313a8625d6c5e6e103cbc23c3221287745f24 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #17440: [FLINK-24468][runtime] Wait for the channel activation before creating partition request client

flinkbot edited a comment on pull request #17440: URL: https://github.com/apache/flink/pull/17440#issuecomment-938816662 ## CI report: * 7d56eb7d002b7bf5c268b98e12a6e4879cd68216 Azure:

[jira] [Commented] (FLINK-24549) FlinkKinesisConsumer does not work with generic types disabled

[ https://issues.apache.org/jira/browse/FLINK-24549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428800#comment-17428800 ] Martijn Visser commented on FLINK-24549: CC [~dannycranmer] Is this fixable now or should this

[jira] [Created] (FLINK-24549) FlinkKinesisConsumer does not work with generic types disabled

Dawid Wysakowicz created FLINK-24549: Summary: FlinkKinesisConsumer does not work with generic types disabled Key: FLINK-24549 URL: https://issues.apache.org/jira/browse/FLINK-24549 Project:

[jira] [Commented] (FLINK-14588) Support Hive version 1.0.0 and 1.0.1

[ https://issues.apache.org/jira/browse/FLINK-14588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17428794#comment-17428794 ] Rui Li commented on FLINK-14588: [~camilesing] Yes that's because we want a single hive connector binary

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312][WIP]

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r728946703 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java ## @@ -683,19 +689,79 @@ JobManagerRunner

[GitHub] [flink] zentol commented on a change in pull request #17474: [FLINK-18312][WIP]

zentol commented on a change in pull request #17474: URL: https://github.com/apache/flink/pull/17474#discussion_r728922879 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/job/savepoints/SavepointHandlers.java ## @@ -227,19 +267,52 @@ public

[GitHub] [flink] flinkbot edited a comment on pull request #17481: [FLINK-24387][table-planner] Support JSON_STRING.

flinkbot edited a comment on pull request #17481: URL: https://github.com/apache/flink/pull/17481#issuecomment-943273916 ## CI report: * e0c506d88d78c9ce851b2fd080e55ad5e4d879a0 Azure:

  1   2   3   4   >