[jira] [Updated] (FLINK-23978) FieldAccessor has direct scala dependency

2021-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23978?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23978: - Parent: FLINK-23986 Issue Type: Sub-task (was: Technical Debt) > FieldAccessor

[jira] [Updated] (FLINK-23968) Remove unused code in TestBaseUtils

2021-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23968: - Parent: FLINK-23986 Issue Type: Sub-task (was: Technical Debt) > Remove unused

[jira] [Commented] (FLINK-23979) Exceptions with Kotlin 1.5.0 and higher

2021-08-26 Thread Hank (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405007#comment-17405007 ] Hank commented on FLINK-23979: -- The Serialization issue was fixed in 1.5.10, I will update

[jira] [Updated] (FLINK-23979) Exceptions with Kotlin 1.5.0 and higher

2021-08-26 Thread Hank (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hank updated FLINK-23979: - Description: *Summary* keyBy(..) function triggers exceptions when using Kotlin. Different Kotlin compiler ver

[GitHub] [flink] pnowojski commented on a change in pull request #16990: [FLINK-23776][datastream] Optimize source metric calculation

2021-08-26 Thread GitBox
pnowojski commented on a change in pull request #16990: URL: https://github.com/apache/flink/pull/16990#discussion_r696349341 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/SourceListener.java ## @@ -0,0 +1,48 @@ +/* + * Licensed to the Apach

[jira] [Updated] (FLINK-23979) Exceptions with Kotlin 1.5.0 and higher

2021-08-26 Thread Hank (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hank updated FLINK-23979: - Description: *Summary* keyBy(..) function triggers exceptions when using Kotlin. Different Kotlin compiler ver

[jira] [Commented] (FLINK-23979) Exceptions with Kotlin 1.5.0 and higher

2021-08-26 Thread Hank (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405009#comment-17405009 ] Hank commented on FLINK-23979: -- InvalidTypesException seemed to be an issue with Kotlin < 1

[jira] [Commented] (FLINK-13973) Checkpoint recovery failed after user set uidHash

2021-08-26 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405010#comment-17405010 ] Yun Gao commented on FLINK-13973: - Fix on master via 8bf1fbd4d4bb0c0ce664aeb363952386123

[jira] [Commented] (FLINK-23979) Exceptions with Kotlin 1.5.0 and higher

2021-08-26 Thread Hank (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405012#comment-17405012 ] Hank commented on FLINK-23979: -- Kotlin bug tracker: https://youtrack.jetbrains.com/issue/KT

[jira] [Created] (FLINK-23987) Move Powered By section into separate page

2021-08-26 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-23987: Summary: Move Powered By section into separate page Key: FLINK-23987 URL: https://issues.apache.org/jira/browse/FLINK-23987 Project: Flink Issue Type

[GitHub] [flink] luryson commented on pull request #4827: [FLINK-7840] [build] Shade netty in akka

2021-08-26 Thread GitBox
luryson commented on pull request #4827: URL: https://github.com/apache/flink/pull/4827#issuecomment-906156030 Is there any way to shade all akka dependencies ? In my project, scala has been shaded in another jar, which cause the failure of flink's initilization. -- This is an automated

[jira] [Updated] (FLINK-7840) Shade Akka's Netty Dependency

2021-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7840: -- Labels: pull-request-available (was: ) > Shade Akka's Netty Dependency > -

[GitHub] [flink] tillrohrmann commented on a change in pull request #16971: [FLINK-23794][tests] Fix InMemoryReporter instantiation and memory consumption.

2021-08-26 Thread GitBox
tillrohrmann commented on a change in pull request #16971: URL: https://github.com/apache/flink/pull/16971#discussion_r696353483 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceMetricsITCase.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #16861: [FLINK-23808][checkpoint] Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16861: URL: https://github.com/apache/flink/pull/16861#issuecomment-900179085 ## CI report: * a10c86eef00f4ac5e3d3594b9e939d55ab7f16fc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16971: [FLINK-23794][tests] Fix InMemoryReporter instantiation and memory consumption.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16971: URL: https://github.com/apache/flink/pull/16971#issuecomment-904969319 ## CI report: * 7960af7d4e53785f300d77acdbf372f9c91d3204 UNKNOWN * d9da2add065aea3ac802bb72872aa8fdeb7e1275 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Commented] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

2021-08-26 Thread Yingjie Cao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405019#comment-17405019 ] Yingjie Cao commented on FLINK-23466: - >>> Thanks for the investigation and writing

[GitHub] [flink] tillrohrmann commented on pull request #16981: [FLINK-23965][e2e] Store logs under FLINK_DIR/log

2021-08-26 Thread GitBox
tillrohrmann commented on pull request #16981: URL: https://github.com/apache/flink/pull/16981#issuecomment-906164798 Thanks for the review @AHeise. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] tillrohrmann closed pull request #16981: [FLINK-23965][e2e] Store logs under FLINK_DIR/log

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

[GitHub] [flink] tillrohrmann commented on pull request #16982: [BP-1.13][FLINK-23965][e2e] Store logs under FLINK_DIR/log

2021-08-26 Thread GitBox
tillrohrmann commented on pull request #16982: URL: https://github.com/apache/flink/pull/16982#issuecomment-906167576 Thanks for the review @AHeise. Merging this PR now. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] tillrohrmann merged pull request #16982: [BP-1.13][FLINK-23965][e2e] Store logs under FLINK_DIR/log

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

[jira] [Closed] (FLINK-23965) E2E do not execute locally on MacOS

2021-08-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-23965. - Resolution: Fixed Fixed via 1.14.0: e5de4a2b003f2cacb89d04b6f1a379cd555d6270 1.13.3: e67acb5f26

[GitHub] [flink] tillrohrmann commented on pull request #16986: [FLINK-23954][tests] Add more logging to test_queryable_state_restart_tm.sh for debugging purposes

2021-08-26 Thread GitBox
tillrohrmann commented on pull request #16986: URL: https://github.com/apache/flink/pull/16986#issuecomment-906172028 The test failure is unrelated. Merging this PR in order to improve the debug log output of `test_queryable_state_restart_tm.sh`. -- This is an automated message from the

[GitHub] [flink] zentol commented on a change in pull request #16986: [FLINK-23954][tests] Add more logging to test_queryable_state_restart_tm.sh for debugging purposes

2021-08-26 Thread GitBox
zentol commented on a change in pull request #16986: URL: https://github.com/apache/flink/pull/16986#discussion_r696372014 ## File path: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsStateClient.java ## @@ -61

[GitHub] [flink] tillrohrmann commented on a change in pull request #16986: [FLINK-23954][tests] Add more logging to test_queryable_state_restart_tm.sh for debugging purposes

2021-08-26 Thread GitBox
tillrohrmann commented on a change in pull request #16986: URL: https://github.com/apache/flink/pull/16986#discussion_r696376120 ## File path: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsStateClient.java ##

[GitHub] [flink] tillrohrmann commented on a change in pull request #16986: [FLINK-23954][tests] Add more logging to test_queryable_state_restart_tm.sh for debugging purposes

2021-08-26 Thread GitBox
tillrohrmann commented on a change in pull request #16986: URL: https://github.com/apache/flink/pull/16986#discussion_r696376827 ## File path: flink-end-to-end-tests/flink-queryable-state-test/src/main/java/org/apache/flink/streaming/tests/queryablestate/QsStateClient.java ##

[jira] [Assigned] (FLINK-19303) Disable WAL in RocksDB recovery

2021-08-26 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li reassigned FLINK-19303: - Assignee: Juha Mynttinen Thanks [~juha.mynttinen], I've assigned the JIRA back to you. > Disable WAL i

[GitHub] [flink] tillrohrmann edited a comment on pull request #16986: [FLINK-23954][tests] Add more logging to test_queryable_state_restart_tm.sh for debugging purposes

2021-08-26 Thread GitBox
tillrohrmann edited a comment on pull request #16986: URL: https://github.com/apache/flink/pull/16986#issuecomment-906172028 Thanks for the review @zentol. The test failure is unrelated. Merging this PR in order to improve the debug log output of `test_queryable_state_restart_tm.sh`. --

[jira] [Updated] (FLINK-19303) Disable WAL in RocksDB recovery

2021-08-26 Thread Yu Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yu Li updated FLINK-19303: -- Labels: (was: auto-deprioritized-major auto-unassigned) > Disable WAL in RocksDB recovery >

[GitHub] [flink] tillrohrmann closed pull request #16986: [FLINK-23954][tests] Add more logging to test_queryable_state_restart_tm.sh for debugging purposes

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

[jira] [Commented] (FLINK-23954) Queryable state (rocksdb) with TM restart end-to-end test fails on azure

2021-08-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405032#comment-17405032 ] Till Rohrmann commented on FLINK-23954: --- Added more debug logs via 2fef9eda1e76cf

[GitHub] [flink] zhuzhurk commented on a change in pull request #16959: [FLINK-23912] Remove unnecessary "Clearing resource requirements of job" in SlotManager

2021-08-26 Thread GitBox
zhuzhurk commented on a change in pull request #16959: URL: https://github.com/apache/flink/pull/16959#discussion_r696381040 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java ## @@ -117,7 +117,7 @@ public void

[GitHub] [flink] zhuzhurk commented on a change in pull request #16959: [FLINK-23912] Remove unnecessary "Clearing resource requirements of job" in SlotManager

2021-08-26 Thread GitBox
zhuzhurk commented on a change in pull request #16959: URL: https://github.com/apache/flink/pull/16959#discussion_r696381188 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java ## @@ -117,7 +117,7 @@ public void

[GitHub] [flink] twalthr closed pull request #16960: [FLINK-23915][table] Fix catalog and primary key resolution of temporary tables

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

[jira] [Closed] (FLINK-23221) Migrate Docker images to Debian Bullseye

2021-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23221. Fix Version/s: (was: 1.13.3) 1.11.4 1.12.5

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * cf4d3c1ec2008e17ad6b8b6a86d0c399d1e9c48d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[jira] [Updated] (FLINK-23967) Remove scala references in OneInputStreamTaskTest

2021-08-26 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-23967: - Parent: FLINK-23986 Issue Type: Sub-task (was: Technical Debt) > Remove scala r

[GitHub] [flink] tillrohrmann commented on a change in pull request #8527: [FLINK-12610] [table-planner-blink] Introduce planner rules about aggregate

2021-08-26 Thread GitBox
tillrohrmann commented on a change in pull request #8527: URL: https://github.com/apache/flink/pull/8527#discussion_r696390658 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/runtime/batch/sql/agg/AggregateReduceGroupingITCase.scala ##

[GitHub] [flink] flinkbot edited a comment on pull request #16787: [FLINK-18080][docs-zh] Translate "security-kerberos" page into Chinese

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16787: URL: https://github.com/apache/flink/pull/16787#issuecomment-897334392 ## CI report: * 19eb37d2ae8019e2075cec18a36f36a2518fa891 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16861: [FLINK-23808][checkpoint] Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16861: URL: https://github.com/apache/flink/pull/16861#issuecomment-900179085 ## CI report: * a10c86eef00f4ac5e3d3594b9e939d55ab7f16fc Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * f3180e650ed121eb4706dffbd4584d2a08189e24 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16971: [FLINK-23794][tests] Fix InMemoryReporter instantiation and memory consumption.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16971: URL: https://github.com/apache/flink/pull/16971#issuecomment-904969319 ## CI report: * 7960af7d4e53785f300d77acdbf372f9c91d3204 UNKNOWN * d9da2add065aea3ac802bb72872aa8fdeb7e1275 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot edited a comment on pull request #16993: [FLINK-23818][python][docs] Add documentation about tgz files for python archives

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16993: URL: https://github.com/apache/flink/pull/16993#issuecomment-906106746 ## CI report: * 8c5f1ede48695bbb00c785cca78aac13d095922a Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] syhily commented on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

2021-08-26 Thread GitBox
syhily commented on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-906194276 These typo have been fixed. I'm writing document on top of this PR. I hope it can be merged soon or later. -- This is an automated message from the Apache Git Service. To respo

[jira] [Updated] (FLINK-23457) Sending the buffer of the right size for broadcast

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23457: --- Fix Version/s: 1.15.0 > Sending the buffer of the right size for broadcast > ---

[jira] [Updated] (FLINK-23457) Sending the buffer of the right size for broadcast

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23457: --- Parent Issue: FLINK-23973 (was: FLINK-23451) > Sending the buffer of the right size for bro

[jira] [Updated] (FLINK-23457) Sending the buffer of the right size for broadcast

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23457: --- Affects Version/s: 1.14.0 > Sending the buffer of the right size for broadcast > ---

[jira] [Created] (FLINK-23988) Test corner cases

2021-08-26 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-23988: -- Summary: Test corner cases Key: FLINK-23988 URL: https://issues.apache.org/jira/browse/FLINK-23988 Project: Flink Issue Type: Sub-task Componen

[jira] [Updated] (FLINK-23973) FLIP-183: Buffer debloat 1.1

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23973: --- Affects Version/s: 1.14.0 > FLIP-183: Buffer debloat 1.1 > > >

[jira] [Updated] (FLINK-23973) FLIP-183: Buffer debloat 1.1

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23973: --- Fix Version/s: 1.15.0 > FLIP-183: Buffer debloat 1.1 > > >

[jira] [Updated] (FLINK-23973) FLIP-183: Buffer debloating 1.1

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23973: --- Summary: FLIP-183: Buffer debloating 1.1 (was: FLIP-183: Buffer debloat 1.1) > FLIP-183: B

[jira] [Updated] (FLINK-23973) FLIP-183: Buffer debloat 1.1

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23973: --- Component/s: Runtime / Network > FLIP-183: Buffer debloat 1.1 >

[jira] [Commented] (FLINK-23821) Test loopback mode to allow Python UDF worker and client reuse the same Python VM

2021-08-26 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405054#comment-17405054 ] Liu commented on FLINK-23821: - Hello, [~hxbks2ks], I am willing to do this ticket. Can you a

[GitHub] [flink] flinkbot edited a comment on pull request #14395: [FLINK-16491][formats] Add compression support for ParquetAvroWriters

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #14395: URL: https://github.com/apache/flink/pull/14395#issuecomment-745744218 ## CI report: * cf4d3c1ec2008e17ad6b8b6a86d0c399d1e9c48d Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * f3180e650ed121eb4706dffbd4584d2a08189e24 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16971: [FLINK-23794][tests] Fix InMemoryReporter instantiation and memory consumption.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16971: URL: https://github.com/apache/flink/pull/16971#issuecomment-904969319 ## CI report: * 7960af7d4e53785f300d77acdbf372f9c91d3204 UNKNOWN * ca12cee214cb00e89f8175cc0c3d8645ed350d51 Azure: [FAILURE](https://dev.azure.com/apache-fl

[jira] [Created] (FLINK-23989) Flink SQL visibility

2021-08-26 Thread wangzhihao (Jira)
wangzhihao created FLINK-23989: -- Summary: Flink SQL visibility Key: FLINK-23989 URL: https://issues.apache.org/jira/browse/FLINK-23989 Project: Flink Issue Type: New Feature Component

[jira] [Commented] (FLINK-21003) Flink add Sink to AliyunOSS doesn't work

2021-08-26 Thread Alex Z (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405061#comment-17405061 ] Alex Z commented on FLINK-21003: I think the pr seems to solve this problem[ FLINK-11388

[jira] [Commented] (FLINK-23740) SQL Full Outer Join bug

2021-08-26 Thread wangzhihao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405065#comment-17405065 ] wangzhihao commented on FLINK-23740: This SIM is currently depending on  https://iss

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

2021-08-26 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405067#comment-17405067 ] Liu commented on FLINK-23969: - Hello, [~arvid]. I am willing to write the tests. Can you ass

[jira] [Comment Edited] (FLINK-23740) SQL Full Outer Join bug

2021-08-26 Thread wangzhihao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405065#comment-17405065 ] wangzhihao edited comment on FLINK-23740 at 8/26/21, 8:38 AM:

[jira] [Updated] (FLINK-23989) Flink SQL visibility

2021-08-26 Thread wangzhihao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] wangzhihao updated FLINK-23989: --- Description: It’s desired to inspect into the internal states generated by SQL especially for debug

[jira] [Commented] (FLINK-11388) Add an OSS RecoverableWriter

2021-08-26 Thread Alex Z (Jira)
[ https://issues.apache.org/jira/browse/FLINK-11388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405071#comment-17405071 ] Alex Z commented on FLINK-11388: I want to know why the pr was closed and not merged.I t

[jira] [Created] (FLINK-23990) Replace custom monaco editor component

2021-08-26 Thread Jira
Ingo Bürk created FLINK-23990: - Summary: Replace custom monaco editor component Key: FLINK-23990 URL: https://issues.apache.org/jira/browse/FLINK-23990 Project: Flink Issue Type: Improvement

[GitHub] [flink] Airblader commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

2021-08-26 Thread GitBox
Airblader commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r696419462 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.less ## @@ -32,12 +32,15 @@ nz-table { flink-mon

[jira] [Comment Edited] (FLINK-23740) SQL Full Outer Join bug

2021-08-26 Thread Zhihao Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405065#comment-17405065 ] Zhihao Wang edited comment on FLINK-23740 at 8/26/21, 8:44 AM: ---

[jira] [Created] (FLINK-23991) Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme

2021-08-26 Thread Junfan Zhang (Jira)
Junfan Zhang created FLINK-23991: Summary: Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme Key: FLINK-23991 URL: https://issues.apache.org/jira/browse/FLINK-23991

[jira] [Updated] (FLINK-23989) Flink SQL visibility

2021-08-26 Thread Zhihao Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhihao Wang updated FLINK-23989: Description: It’s desired to inspect into the internal states generated by SQL especially for deb

[GitHub] [flink] zuston opened a new pull request #16994: [FLINK-23991] Specifying yarn.staging-dir fail when staging scheme is…

2021-08-26 Thread GitBox
zuston opened a new pull request #16994: URL: https://github.com/apache/flink/pull/16994 … different from default fs scheme ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC.

[jira] [Updated] (FLINK-23991) Specifying yarn.staging-dir fail when staging scheme is different from default fs scheme

2021-08-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23991: --- Labels: pull-request-available (was: ) > Specifying yarn.staging-dir fail when staging sche

[GitHub] [flink] Myasuka commented on pull request #16846: [FLINK-23800][rocksdb] Expose live-sst-files-size to RocksDB native metrics

2021-08-26 Thread GitBox
Myasuka commented on pull request #16846: URL: https://github.com/apache/flink/pull/16846#issuecomment-906219947 @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

[jira] [Updated] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.

2021-08-26 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23943: Labels: rest (was: ) > "/jobs/:jobid/stop" in REST API can't stop the target job. > -

[jira] [Updated] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.

2021-08-26 Thread Roc Marshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roc Marshal updated FLINK-23943: Labels: REST_API (was: rest) > "/jobs/:jobid/stop" in REST API can't stop the target job. > -

[GitHub] [flink] flinkbot commented on pull request #16994: [FLINK-23991] Specifying yarn.staging-dir fail when staging scheme is…

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

[GitHub] [flink] dianfu closed pull request #16993: [FLINK-23818][python][docs] Add documentation about tgz files for python archives

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

[jira] [Closed] (FLINK-23818) Add documentation about tgz files support for python archives

2021-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-23818. --- Resolution: Fixed Merged to master via 5289b0e3ce7fad03225d064afceda35462454fe2 > Add documentation about t

[jira] [Updated] (FLINK-23819) Testing tgz file for python archives

2021-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-23819: Description: This feature is to support tar.gz files as python archives. In the past, it only support zip

[GitHub] [flink] flinkbot edited a comment on pull request #16723: [FLINK-22885][table] Supports 'SHOW COLUMNS' syntax.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16723: URL: https://github.com/apache/flink/pull/16723#issuecomment-893364145 ## CI report: * feca59d37ac86df05f11b8ecec57b93e4356f2e8 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16846: [FLINK-23800][rocksdb] Expose live-sst-files-size to RocksDB native metrics

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16846: URL: https://github.com/apache/flink/pull/16846#issuecomment-899526733 ## CI report: * 57e020c5f8de174d9e2f55983fb51936e1657f3e Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16861: [FLINK-23808][checkpoint] Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16861: URL: https://github.com/apache/flink/pull/16861#issuecomment-900179085 ## CI report: * 7165c3df04d5b5520cced9f44b34d7bd0ad22c02 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16900: [FLINK-23877][connector/pulsar] Provide an embedded pulsar broker for testing.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16900: URL: https://github.com/apache/flink/pull/16900#issuecomment-902199681 ## CI report: * f3180e650ed121eb4706dffbd4584d2a08189e24 Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] flinkbot edited a comment on pull request #16971: [FLINK-23794][tests] Fix InMemoryReporter instantiation and memory consumption.

2021-08-26 Thread GitBox
flinkbot edited a comment on pull request #16971: URL: https://github.com/apache/flink/pull/16971#issuecomment-904969319 ## CI report: * 7960af7d4e53785f300d77acdbf372f9c91d3204 UNKNOWN * ca12cee214cb00e89f8175cc0c3d8645ed350d51 Azure: [FAILURE](https://dev.azure.com/apache-fl

[GitHub] [flink] flinkbot commented on pull request #16994: [FLINK-23991] Specifying yarn.staging-dir fail when staging scheme is…

2021-08-26 Thread GitBox
flinkbot commented on pull request #16994: URL: https://github.com/apache/flink/pull/16994#issuecomment-906233672 ## CI report: * 3c616589d6e315d0f29513fb0c7132f67b11d3bb UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot r

[GitHub] [flink] yangjunhan commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

2021-08-26 Thread GitBox
yangjunhan commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r696449877 ## File path: flink-runtime-web/web-dashboard/src/app/share/common/monaco-editor/monaco-editor.component.ts ## @@ -74,7 +74,7 @@ export class MonacoEd

[GitHub] [flink] yangjunhan commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

2021-08-26 Thread GitBox
yangjunhan commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r696449877 ## File path: flink-runtime-web/web-dashboard/src/app/share/common/monaco-editor/monaco-editor.component.ts ## @@ -74,7 +74,7 @@ export class MonacoEd

[GitHub] [flink] gaoyunhaii commented on pull request #16861: [FLINK-23808][checkpoint] Bypass operators when advanceToEndOfEventTime for both legacy and new source tasks

2021-08-26 Thread GitBox
gaoyunhaii commented on pull request #16861: URL: https://github.com/apache/flink/pull/16861#issuecomment-906240714 @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 specif

[GitHub] [flink] pnowojski commented on a change in pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-08-26 Thread GitBox
pnowojski commented on a change in pull request #16988: URL: https://github.com/apache/flink/pull/16988#discussion_r696380229 ## File path: docs/content/docs/ops/state/network_buffer.md ## @@ -0,0 +1,108 @@ +--- +title: "Network Buffers" +weight: 100 +type: docs +aliases: + -

[GitHub] [flink] pnowojski commented on pull request #16988: [FLINK-23458][docs] Added the network buffer documentation along wit…

2021-08-26 Thread GitBox
pnowojski commented on pull request #16988: URL: https://github.com/apache/flink/pull/16988#issuecomment-906244628 Also as we discussed off line, I think the best place for this docs is a sibling of this page: https://ci.apache.org/projects/flink/flink-docs-master/docs/deployment/memory/me

[GitHub] [flink] yangjunhan commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

2021-08-26 Thread GitBox
yangjunhan commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r696457528 ## File path: flink-runtime-web/web-dashboard/src/app/share/common/monaco-editor/monaco-editor.component.ts ## @@ -74,7 +74,7 @@ export class MonacoEd

[jira] [Updated] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-23466: --- Priority: Blocker (was: Critical) > UnalignedCheckpointITCase hangs on Azure >

[GitHub] [flink] yangjunhan commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

2021-08-26 Thread GitBox
yangjunhan commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r696458715 ## File path: flink-runtime-web/web-dashboard/src/app/pages/job/exceptions/job-exceptions.component.less ## @@ -32,12 +32,15 @@ nz-table { flink-mo

[jira] [Commented] (FLINK-23466) UnalignedCheckpointITCase hangs on Azure

2021-08-26 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405097#comment-17405097 ] Piotr Nowojski commented on FLINK-23466: I've bumped the priority to the release

[GitHub] [flink] Airblader commented on a change in pull request #16980: [FLINK-23111][runtime-web] Fix monaco editor async setup

2021-08-26 Thread GitBox
Airblader commented on a change in pull request #16980: URL: https://github.com/apache/flink/pull/16980#discussion_r696462684 ## File path: flink-runtime-web/web-dashboard/src/app/share/common/monaco-editor/monaco-editor.component.ts ## @@ -74,7 +74,7 @@ export class MonacoEdi

[jira] [Assigned] (FLINK-22002) AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail because of submitting task time-out.

2021-08-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-22002: - Assignee: Till Rohrmann > AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_Wi

[jira] [Commented] (FLINK-22002) AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail because of submitting task time-out.

2021-08-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405103#comment-17405103 ] Till Rohrmann commented on FLINK-22002: --- The test failure has a different cause {

[jira] [Updated] (FLINK-22002) AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail because of submitting task time-out.

2021-08-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22002: -- Fix Version/s: 1.13.3 > AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAg

[jira] [Updated] (FLINK-22002) AggregateReduceGroupingITCase.testSingleAggOnTable_HashAgg_WithLocalAgg fail because of submitting task time-out.

2021-08-26 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-22002: -- Affects Version/s: (was: 1.12.2) 1.13.2 > AggregateReduceGroupingIT

[jira] [Assigned] (FLINK-23969) Test Pulsar source end 2 end

2021-08-26 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23969: --- Assignee: Liu > Test Pulsar source end 2 end > > >

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

2021-08-26 Thread Arvid Heise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405107#comment-17405107 ] Arvid Heise commented on FLINK-23969: - I assigned you, please wait for the documenta

[GitHub] [flink] pnowojski commented on a change in pull request #16905: [FLINK-23884][checkpoint] Fix the concurrent problem between triggering savepoint with drain and task finishing

2021-08-26 Thread GitBox
pnowojski commented on a change in pull request #16905: URL: https://github.com/apache/flink/pull/16905#discussion_r696469744 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -244,6 +234,28 @@ protecte

[GitHub] [flink] pnowojski commented on a change in pull request #16905: [FLINK-23884][checkpoint] Fix the concurrent problem between triggering savepoint with drain and task finishing

2021-08-26 Thread GitBox
pnowojski commented on a change in pull request #16905: URL: https://github.com/apache/flink/pull/16905#discussion_r696468015 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/MultipleInputStreamTask.java ## @@ -244,6 +234,28 @@ protecte

  1   2   3   4   5   6   >