[GitHub] [flink] flinkbot edited a comment on pull request #16638: [FLINK-23513] Remove legacy descriptors

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16638: URL: https://github.com/apache/flink/pull/16638#issuecomment-889186834 ## CI report: * 73bacada917f02fb4f0a9b83c4c327ad0e6a7476 Azure:

[GitHub] [flink] tsreaper commented on a change in pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-04 Thread GitBox
tsreaper commented on a change in pull request #16650: URL: https://github.com/apache/flink/pull/16650#discussion_r682333062 ## File path: flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/agg/LeadLagAggITCase.scala ## @@ -0,0

[jira] [Closed] (FLINK-23524) AdaptiveSchedulerClusterITCase fails on Azure

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23524. Fix Version/s: 1.14.0 Resolution: Fixed master:

[GitHub] [flink] flinkbot commented on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
flinkbot commented on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * 3fef5459a0a1ac345b72c749f025b8e0136709e0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] zentol merged pull request #16681: [FLINK-23524][tests] Harden AdaptiveSchedulerClusterITCase

2021-08-04 Thread GitBox
zentol merged pull request #16681: URL: https://github.com/apache/flink/pull/16681 -- 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 #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-891870309 ## CI report: * 17de24375718fd602b26c77a8428b89ac8c8bb9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891870165 ## CI report: * dcebe54c19ee58530db300a6919e9c43589a6753 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16638: [FLINK-23513] Remove legacy descriptors

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16638: URL: https://github.com/apache/flink/pull/16638#issuecomment-889186834 ## CI report: * 73bacada917f02fb4f0a9b83c4c327ad0e6a7476 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * a4a37916fdd2d49a7682b2d90da22e5ed398eae5 Azure:

[GitHub] [flink] beyond1920 commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
beyond1920 commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r682347079 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[jira] [Created] (FLINK-23614) The resulting scale of TRUNCATE(DECIMAL, ...) is not correct

2021-08-04 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-23614: --- Summary: The resulting scale of TRUNCATE(DECIMAL, ...) is not correct Key: FLINK-23614 URL: https://issues.apache.org/jira/browse/FLINK-23614 Project: Flink

[GitHub] [flink-statefun] tzulitai opened a new pull request #247: [FLINK-23600] Rework remote module parsing and application component binding

2021-08-04 Thread GitBox
tzulitai opened a new pull request #247: URL: https://github.com/apache/flink-statefun/pull/247 This PR achieves the following goals: - Makes system code that parses `module.yaml` definition files responsible only up to the point of extracting multiple objects which each represent

[jira] [Commented] (FLINK-23613) debezium and canal support read medata op and type

2021-08-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392761#comment-17392761 ] Jark Wu commented on FLINK-23613: - What would you do with the action_type or RowKind ? > debezium and

[jira] [Commented] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392762#comment-17392762 ] 张祥兵 commented on FLINK-23608: - [~jark]It is solved, thank you. This Maven is built according to the official

[GitHub] [flink] rkhachatryan commented on a change in pull request #16685: [FLINK-23279][tests] Randomly use Changelog Backend in tests

2021-08-04 Thread GitBox
rkhachatryan commented on a change in pull request #16685: URL: https://github.com/apache/flink/pull/16685#discussion_r682324509 ## File path: flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/streaming/util/TestStreamEnvironment.java ## @@ -92,10 +94,18

[jira] [Commented] (FLINK-20329) Elasticsearch7DynamicSinkITCase hangs

2021-08-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392777#comment-17392777 ] Dawid Wysakowicz commented on FLINK-20329: --

[jira] [Updated] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

2021-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23590: --- Priority: Blocker (was: Critical) > StreamTaskTest#testProcessWithUnAvailableInput is

[GitHub] [flink] flinkbot edited a comment on pull request #16630: [FLINK-23531][table]Allow skip all change log for row-time deduplicate mini-batch

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16630: URL: https://github.com/apache/flink/pull/16630#issuecomment-17597 ## CI report: * 2d838f19f7c38f48b3942e2aa65269ee99cdd44d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * 90371dbd6607b40895efa416e66ddda65ea180d7 Azure:

[jira] [Updated] (FLINK-23539) InfluxDBReporter should filter characters in tags

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23539: - Affects Version/s: (was: 1.12.3) (was: 1.11.1)

[jira] [Updated] (FLINK-23539) InfluxDBReporter should filter characters in tags

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23539: - Fix Version/s: 1.13.3 1.12.6 1.14.0 >

[GitHub] [flink] zentol merged pull request #16645: [FLINK-23539][metrics-influxdb] InfluxDBReporter should filter charac…

2021-08-04 Thread GitBox
zentol merged pull request #16645: URL: https://github.com/apache/flink/pull/16645 -- 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] beyond1920 commented on a change in pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
beyond1920 commented on a change in pull request #16620: URL: https://github.com/apache/flink/pull/16620#discussion_r682345064 ## File path: flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.java ## @@ -544,11

[GitHub] [flink] gaborgsomogyi commented on a change in pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

2021-08-04 Thread GitBox
gaborgsomogyi commented on a change in pull request #16463: URL: https://github.com/apache/flink/pull/16463#discussion_r682345714 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/InboundChannelHandlerFactory.java ## @@ -0,0 +1,55 @@ +/* + *

[GitHub] [flink] gaborgsomogyi commented on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

2021-08-04 Thread GitBox
gaborgsomogyi commented on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-892419691 The tests are not yet testing the netty chain so discovering how is it possible to do that w/o horror complex code... -- This is an automated message from the Apache

[GitHub] [flink-docker] Myasuka merged pull request #87: Release 1.13.2

2021-08-04 Thread GitBox
Myasuka merged pull request #87: URL: https://github.com/apache/flink-docker/pull/87 -- 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 #16513: [FLINK-23389][Formats] Glue schema registry JSON support

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16513: URL: https://github.com/apache/flink/pull/16513#issuecomment-881248601 ## CI report: * 90371dbd6607b40895efa416e66ddda65ea180d7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16652: [FLINK-22483][flink-runtime] Remove CompletedCheckpointStore#recover(…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16652: URL: https://github.com/apache/flink/pull/16652#issuecomment-889863499 ## CI report: * bec31db7e5954054997b68fc2eaceb3556ea7200 UNKNOWN * b564f54f0618507fbdaf78ab7db2fe5c569d85cc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16606: [FLINK-21357][runtime/statebackend]Periodic materialization for generalized incremental checkpoints

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16606: URL: https://github.com/apache/flink/pull/16606#issuecomment-887431748 ## CI report: * 264be5cc6a0485171413099e8b64b9e917d06e85 UNKNOWN * e47b1ded46ebf510d1d62bc10584fb3c934afda1 Azure:

[jira] [Commented] (FLINK-22885) Support 'SHOW COLUMNS'.

2021-08-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392757#comment-17392757 ] Jark Wu commented on FLINK-22885: - Thanks [~RocMarshal] for the detailed investigation, I'm fine with

[jira] [Updated] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

2021-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23590: --- Labels: test-stability (was: ) > StreamTaskTest#testProcessWithUnAvailableInput is flaky >

[jira] [Commented] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

2021-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392781#comment-17392781 ] Piotr Nowojski commented on FLINK-23590: bumping to release blocker due to frequency of

[jira] [Commented] (FLINK-23449) YarnTaskExecutorRunner does not contains MapReduce classes

2021-08-04 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392798#comment-17392798 ] Gabor Somogyi commented on FLINK-23449: --- Sounds like an agreement. [~yuchuanchen] since you have

[jira] [Updated] (FLINK-23600) Rework StateFun's remote module parsing and binding

2021-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23600: --- Labels: pull-request-available (was: ) > Rework StateFun's remote module parsing and

[GitHub] [flink] RollsBean commented on pull request #16478: [FLINK-23228][docs-zh] Translate "Stateful Stream Processing" page into Chinese

2021-08-04 Thread GitBox
RollsBean commented on pull request #16478: URL: https://github.com/apache/flink/pull/16478#issuecomment-892433561 Hi @xccui @klion26 , can you have a look at this PR? I have finished translation and hackergin reviewed this PR but no one merge it. -- This is an automated message from

[GitHub] [flink] flinkbot edited a comment on pull request #16620: [FLINK-23246][table-planner] Refactor the time indicator materialization

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16620: URL: https://github.com/apache/flink/pull/16620#issuecomment-888120908 ## CI report: * 12c0dbb7a1359053f4804910f58f06434e542dad UNKNOWN * 59644cc0b8b79495818890290190e7cf91caed7d Azure:

[GitHub] [flink] fapaul commented on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
fapaul commented on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-892406837 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] rkhachatryan commented on pull request #16685: [FLINK-23279][tests] Randomly use Changelog Backend in tests

2021-08-04 Thread GitBox
rkhachatryan commented on pull request #16685: URL: https://github.com/apache/flink/pull/16685#issuecomment-892406955 Thanks for the review @curcur , 1. Yes, I first ran the build with changelog enabled 2. Good point. I'll add this change to the first (hotfix) commit - 709a6e4

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 33ad09863a81711ff79b040e12eabb051470ba40 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892415455 ## CI report: * 3fef5459a0a1ac345b72c749f025b8e0136709e0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16696: Port FLINK-23529 to 1.13

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16696: URL: https://github.com/apache/flink/pull/16696#issuecomment-892319172 ## CI report: * 21941f92e977b4fd1df115fef1122aab4428d196 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16698: [FLINK-23602][runtime] org.codehaus.commons.compiler.CompileException…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16698: URL: https://github.com/apache/flink/pull/16698#issuecomment-892376359 ## CI report: * 7b305e3726aa946d5ac25324347e4ce0a1f9a28c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-889863557 ## CI report: * 3c55e8dea31b4e4ff475f85114cb38957f1a831d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16697: [FLINK-23587] Set Deployment's Annotation when using native kubernetes

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16697: URL: https://github.com/apache/flink/pull/16697#issuecomment-892340685 ## CI report: * 2039e73b02de7485b105be09146ab50b627084c0 UNKNOWN * 274516bb1510a46a87a39e207666e3cfffc9859b Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-891870309 ## CI report: * 17de24375718fd602b26c77a8428b89ac8c8bb9d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16676: [FLINK-22902] Port KafkaSink to FLIP-143

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16676: URL: https://github.com/apache/flink/pull/16676#issuecomment-890987522 ## CI report: * a4a37916fdd2d49a7682b2d90da22e5ed398eae5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16692: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16692: URL: https://github.com/apache/flink/pull/16692#issuecomment-891870165 ## CI report: * dcebe54c19ee58530db300a6919e9c43589a6753 Azure:

[jira] [Commented] (FLINK-23608) org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory

2021-08-04 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392752#comment-17392752 ] Jark Wu commented on FLINK-23608: - [~zhangxiangbing] you can follow the documentation I posted above, to

[jira] [Updated] (FLINK-23420) sql stream mode lag function java.lang.NullPointerException

2021-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23420: --- Labels: pull-request-available (was: ) > sql stream mode lag function

[GitHub] [flink] fapaul commented on pull request #16694: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
fapaul commented on pull request #16694: URL: https://github.com/apache/flink/pull/16694#issuecomment-892406449 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[GitHub] [flink] tsreaper opened a new pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
tsreaper opened a new pull request #16699: URL: https://github.com/apache/flink/pull/16699 ## What is the purpose of the change `LinkedListSerializer` in the table runtime module currently is not aware of the null elements in the list. This will cause NPE in some functions like the

[jira] [Closed] (FLINK-23539) InfluxDBReporter should filter characters in tags

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23539. Resolution: Fixed master: 1c7100a8e528d620c4ce77673630f8bf8f8e6966 1.13:

[jira] [Created] (FLINK-23615) Documentation of the TRUNCATE SQL function is not correct

2021-08-04 Thread Caizhi Weng (Jira)
Caizhi Weng created FLINK-23615: --- Summary: Documentation of the TRUNCATE SQL function is not correct Key: FLINK-23615 URL: https://issues.apache.org/jira/browse/FLINK-23615 Project: Flink

[jira] [Updated] (FLINK-23615) Documentation of the TRUNCATE SQL function is not correct

2021-08-04 Thread Caizhi Weng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caizhi Weng updated FLINK-23615: Description: The documentation of the {{TRUNCATE}} SQL function states that "E.g.

[GitHub] [flink] flinkbot edited a comment on pull request #16465: [FLINK-22910][runtime] Refine ShuffleMaster lifecycle management for pluggable shuffle service framework

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16465: URL: https://github.com/apache/flink/pull/16465#issuecomment-878076127 ## CI report: * 56a034b0ebd265f1da25721aac1f30d9d375 Azure:

[GitHub] [flink] flinkbot commented on pull request #16699: [FLINK-23420][table-runtime] LinkedListSerializer now checks for null elements in the list

2021-08-04 Thread GitBox
flinkbot commented on pull request #16699: URL: https://github.com/apache/flink/pull/16699#issuecomment-892407951 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-docker] Myasuka merged pull request #90: Update Dockerfiles for 1.13.2 release

2021-08-04 Thread GitBox
Myasuka merged pull request #90: URL: https://github.com/apache/flink-docker/pull/90 -- 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] pnowojski commented on pull request #16710: [FLINK-23560][task] Fix performance regression by unnecessary throughput calculations

2021-08-04 Thread GitBox
pnowojski commented on pull request #16710: URL: https://github.com/apache/flink/pull/16710#issuecomment-892738784 I can confirm that this PR solves the regression. For example: ``` "Benchmark","Mode","Threads","Samples","Score","Score Error (99.9%)","Unit"

[GitHub] [flink] zentol opened a new pull request #16712: [FLINK-23624][metrics] Migrate TaskManagerMG instatiations to factory method

2021-08-04 Thread GitBox
zentol opened a new pull request #16712: URL: https://github.com/apache/flink/pull/16712 Modify all existing usages of the TaskManagerMG constructor to use the (moved) MetricUtils factory method, for consistency and to make constructor changes easier. -- This is an automated

[jira] [Updated] (FLINK-23624) Migrate all TaskManagerMG instantiations to factory method

2021-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23624: --- Labels: pull-request-available (was: ) > Migrate all TaskManagerMG instantiations to

[GitHub] [flink] hapihu commented on pull request #16670: [FLINK-23581][docs] Change site.download_url to https://flink.apache.…

2021-08-04 Thread GitBox
hapihu commented on pull request #16670: URL: https://github.com/apache/flink/pull/16670#issuecomment-892748007 @zentol , Hi Thank you for your review. I have made the changes according to your suggestion. I consulted Hugo's official

[jira] [Assigned] (FLINK-23628) MeasurementInfoProviderTest fails on Azure

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-23628: Assignee: Chesnay Schepler > MeasurementInfoProviderTest fails on Azure >

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 080e028bd3e774711cdc73a204dd6a8b979943bb Azure:

[GitHub] [flink] klam-shop commented on pull request #16693: [FLINK-23509][connectors/kafka] Create new ProducerIdAndEpoch when re…

2021-08-04 Thread GitBox
klam-shop commented on pull request #16693: URL: https://github.com/apache/flink/pull/16693#issuecomment-892771406 I just tried this backport and got the following error, with the reproduction I described in

[jira] [Comment Edited] (FLINK-23593) Performance regression on 15.07.2021

2021-08-04 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393287#comment-17393287 ] Stephan Ewen edited comment on FLINK-23593 at 8/4/21, 4:00 PM: --- Here is a

[GitHub] [flink] StephanEwen opened a new pull request #16715: [FLINK-23629][FLINK-23630][tests] Some fixes to EventTimeWindowCheckpointingITCase

2021-08-04 Thread GitBox
StephanEwen opened a new pull request #16715: URL: https://github.com/apache/flink/pull/16715 ## What is the purpose of the change Fixes `EventTimeWindowCheckpointingITCase` and `LocalRecoveryITCase` to run on Windows and speeds up `EventTimeWindowCheckpointingITCase` by removing

[GitHub] [flink] StephanEwen commented on pull request #16715: [FLINK-23629][FLINK-23630][tests] Some fixes to EventTimeWindowCheckpointingITCase

2021-08-04 Thread GitBox
StephanEwen commented on pull request #16715: URL: https://github.com/apache/flink/pull/16715#issuecomment-892832073 @zentol you might like this change. -- 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

[GitHub] [flink] flinkbot commented on pull request #16715: [FLINK-23629][FLINK-23630][tests] Some fixes to EventTimeWindowCheckpointingITCase

2021-08-04 Thread GitBox
flinkbot commented on pull request #16715: URL: https://github.com/apache/flink/pull/16715#issuecomment-892842320 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-23631) [docs-zh] The name attribute of GH_link in shortcodes was lost. As a result, the Link to Flink-examexam-batch failed

2021-08-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23631: --- Labels: pull-request-available (was: ) > [docs-zh] The name attribute of GH_link in

[jira] [Commented] (FLINK-23525) Docker command fails on Azure: Exit code 137 returned from process: file name '/usr/bin/docker'

2021-08-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17393364#comment-17393364 ] Robert Metzger commented on FLINK-23525: Machine looks "normal", I can see the OOM killer

[jira] [Updated] (FLINK-23631) [docs-zh] The name attribute of GH_link in shortcodes was lost. As a result, the Link to Flink-examexam-batch failed

2021-08-04 Thread wuguihu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wuguihu updated FLINK-23631: Attachment: image-20210805014000555.png > [docs-zh] The name attribute of GH_link in shortcodes was lost.

[jira] [Closed] (FLINK-23590) StreamTaskTest#testProcessWithUnAvailableInput is flaky

2021-08-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-23590. -- Resolution: Fixed Merged to master as 97727afa449 >

[jira] [Created] (FLINK-23624) Migrate all TaskManagerMG instantiations to factory method

2021-08-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23624: Summary: Migrate all TaskManagerMG instantiations to factory method Key: FLINK-23624 URL: https://issues.apache.org/jira/browse/FLINK-23624 Project: Flink

[GitHub] [flink] pnowojski edited a comment on pull request #16710: [FLINK-23560][task] Fix performance regression by unnecessary throughput calculations

2021-08-04 Thread GitBox
pnowojski edited a comment on pull request #16710: URL: https://github.com/apache/flink/pull/16710#issuecomment-892738784 I can confirm that this PR solves the regression. For example benchmark request results: ``` "Benchmark","Mode","Threads","Samples","Score","Score Error

[jira] [Updated] (FLINK-23628) MeasurementInfoProviderTest fails on Azure

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23628: - Affects Version/s: 1.13.3 > MeasurementInfoProviderTest fails on Azure >

[jira] [Closed] (FLINK-23628) MeasurementInfoProviderTest fails on Azure

2021-08-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23628. Fix Version/s: 1.13.3 Resolution: Fixed 1.13:

[GitHub] [flink] flinkbot edited a comment on pull request #16703: [FLINK-23619][python] Remove PythonTimestampsAndWatermarksOperator

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16703: URL: https://github.com/apache/flink/pull/16703#issuecomment-892555446 ## CI report: * a04d0249d9bfab2e10b3193963db96731904 UNKNOWN * c97577c9843515cab235cfcb23c208dd58169fb1 Azure:

[GitHub] [flink] rkhachatryan commented on pull request #16615: [FLINK-23437][jdbc] Add an option to (dis)allow XA transaction multiplexing

2021-08-04 Thread GitBox
rkhachatryan commented on pull request #16615: URL: https://github.com/apache/flink/pull/16615#issuecomment-892768433 Sure, squashed and changed the commit message. The build was green in the private branch before, but let's wait for the final run. -- This is an automated message

[GitHub] [flink] flinkbot edited a comment on pull request #16615: [FLINK-23437][jdbc] Add an option to (dis)allow XA transaction multiplexing

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16615: URL: https://github.com/apache/flink/pull/16615#issuecomment-888048174 ## CI report: * 8a30b7174477c703595c717d8c6b525293a25d82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16653: [FLINK-23558][streaming] Ignoring RejectedExecutionException during s…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16653: URL: https://github.com/apache/flink/pull/16653#issuecomment-889863557 ## CI report: * 7b59f60e16b9c87fd03af747548c17097a2113ff Azure:

[GitHub] [flink] pnowojski opened a new pull request #16713: [FLINK-23408][task] Add metrics for buffer debloating

2021-08-04 Thread GitBox
pnowojski opened a new pull request #16713: URL: https://github.com/apache/flink/pull/16713 This PR depends on https://github.com/apache/flink/pull/16710 Add metrics for buffer debloating ## Brief change log Please check individual commits for the change log ##

[GitHub] [flink] izzyacademy commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
izzyacademy commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r682769816 ## File path: flink-filesystems/flink-azure-fs-hadoop/src/main/java/org/apache/flink/fs/azurefs/AbstractAzureFSFactory.java ## @@ -75,18 +76,27 @@

[GitHub] [flink] izzyacademy commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
izzyacademy commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r682770874 ## File path: flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java ## @@ -248,6 +248,8 @@ ImmutableMultimap.builder()

[GitHub] [flink] flinkbot edited a comment on pull request #16705: [BP-1.13][FLINK-22382][tests] Harden ProcessFailureCancelingITCase.testCancelingOnProcessFailure

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16705: URL: https://github.com/apache/flink/pull/16705#issuecomment-892583108 ## CI report: * e7a457dcb25dd902aff51f7d02d39afc2eef6a95 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16706: [BP-1.12][FLINK-22382][tests] Harden ProcessFailureCancelingITCase.testCancelingOnProcessFailure

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16706: URL: https://github.com/apache/flink/pull/16706#issuecomment-892583153 ## CI report: * bd94657544e1793b0509c2a9170c6ccf4115ddef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16708: [FLINK-23192][table] Move connector & format options to consistent packages

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16708: URL: https://github.com/apache/flink/pull/16708#issuecomment-892598184 ## CI report: * 9ece6e5247b833ba664fb20c0edffa43a6665f27 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16713: [FLINK-23408][task] Add metrics for buffer debloating

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16713: URL: https://github.com/apache/flink/pull/16713#issuecomment-892809437 ## CI report: * fbc2d0a0912a2ee1ce4e1c0ca167c88e9efcabe7 UNKNOWN * 726bca864172e75739ebb679837a2cc6501e UNKNOWN Bot commands The

[GitHub] [flink] flinkbot edited a comment on pull request #16615: [FLINK-23437][jdbc] Add an option to (dis)allow XA transaction multiplexing

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16615: URL: https://github.com/apache/flink/pull/16615#issuecomment-888048174 ## CI report: * 8a30b7174477c703595c717d8c6b525293a25d82 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16644: [FLINK-23551][Connectors/ORC] Bump ORC to 1.6.9

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16644: URL: https://github.com/apache/flink/pull/16644#issuecomment-889635734 ## CI report: * 03591349dd1f23a5289067286b450f17ef677e6e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16650: [FLINK-22405] [Table SQL / API] Support fixed-lengh chars in the Lead…

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16650: URL: https://github.com/apache/flink/pull/16650#issuecomment-889769193 ## CI report: * 6a29ac6e799567274b4583fd8c2924546d8185c8 UNKNOWN * b3bf140b00391f7fea50a444d9212684a3cf9b34 Azure:

[jira] [Created] (FLINK-23625) Migrate all TaskManagerJobMG instantiations to factory method

2021-08-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23625: Summary: Migrate all TaskManagerJobMG instantiations to factory method Key: FLINK-23625 URL: https://issues.apache.org/jira/browse/FLINK-23625 Project: Flink

[jira] [Created] (FLINK-23626) Migrate all TaskMG instantiations to factory method

2021-08-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23626: Summary: Migrate all TaskMG instantiations to factory method Key: FLINK-23626 URL: https://issues.apache.org/jira/browse/FLINK-23626 Project: Flink

[jira] [Assigned] (FLINK-23507) The node IP obtained in NodePort mode is a VIP

2021-08-04 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Morávek reassigned FLINK-23507: - Assignee: David Morávek > The node IP obtained in NodePort mode is a VIP >

[jira] [Created] (FLINK-23628) MeasurementInfoProviderTest fails on Azure

2021-08-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-23628: Summary: MeasurementInfoProviderTest fails on Azure Key: FLINK-23628 URL: https://issues.apache.org/jira/browse/FLINK-23628 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #16463: [FLINK-23272][web] Add custom netty HTTP request inbound/outbound handlers

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16463: URL: https://github.com/apache/flink/pull/16463#issuecomment-878058026 ## CI report: * 8b5159766fdbab7f84ffb96a151cf9cbb659f71f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 080e028bd3e774711cdc73a204dd6a8b979943bb Azure:

[GitHub] [flink] izzyacademy commented on a change in pull request #16559: [FLINK-18562] Support for Hadoop ABFS for Azure Datalake Gen2 accounts

2021-08-04 Thread GitBox
izzyacademy commented on a change in pull request #16559: URL: https://github.com/apache/flink/pull/16559#discussion_r682766129 ## File path: flink-filesystems/flink-s3-fs-presto/src/main/resources/META-INF/NOTICE ## @@ -34,14 +34,25 @@ This project bundles the following

[GitHub] [flink] flinkbot edited a comment on pull request #16399: [FLINK-23621][datastream] FLIP-177: Extend Sink API

2021-08-04 Thread GitBox
flinkbot edited a comment on pull request #16399: URL: https://github.com/apache/flink/pull/16399#issuecomment-874970474 ## CI report: * 139a2f7f23b491dda7b3388061e07e7f690850a7 Azure:

[jira] [Updated] (FLINK-23631) [docs-zh] The name attribute of GH_link in shortcodes was lost. As a result, the Link to Flink-examexam-batch failed

2021-08-04 Thread wuguihu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wuguihu updated FLINK-23631: Attachment: image-20210805011518012.png > [docs-zh] The name attribute of GH_link in shortcodes was lost.

[jira] [Created] (FLINK-23631) [docs-zh] The name attribute of GH_link in shortcodes was lost. As a result, the Link to Flink-examexam-batch failed

2021-08-04 Thread wuguihu (Jira)
wuguihu created FLINK-23631: --- Summary: [docs-zh] The name attribute of GH_link in shortcodes was lost. As a result, the Link to Flink-examexam-batch failed Key: FLINK-23631 URL:

  1   2   3   4   5   6   7   >