[GitHub] [flink] zhijiangW commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

zhijiangW commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r424911901 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -129,7 +132,6 @@ private

[GitHub] [flink] dianfu commented on pull request #12142: [FLINK-17679][python] Fix the bug of encoding bytes in cython coder

dianfu commented on pull request #12142: URL: https://github.com/apache/flink/pull/12142#issuecomment-628431049 LGTM. The tests have passed actually. Merging.. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-14106) Make SlotManager pluggable

[ https://issues.apache.org/jira/browse/FLINK-14106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14106: - Fix Version/s: (was: 1.11.0) 1.12.0 > Make SlotManager pluggable >

[GitHub] [flink] wuchong commented on a change in pull request #12126: [FLINK-17664][table] Introduce print, blackhole connector in table

wuchong commented on a change in pull request #12126: URL: https://github.com/apache/flink/pull/12126#discussion_r424907675 ## File path: flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/runtime/stream/table/BlackHoleITCase.java ## @@ -0,0

[GitHub] [flink] JingsongLi commented on a change in pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

JingsongLi commented on a change in pull request #12062: URL: https://github.com/apache/flink/pull/12062#discussion_r424339019 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingFileWriter.java ## @@ -0,0 +1,190

[jira] [Created] (FLINK-17685) Remove flink-shaded-hadoop-2-parent and submodules

Robert Metzger created FLINK-17685: -- Summary: Remove flink-shaded-hadoop-2-parent and submodules Key: FLINK-17685 URL: https://issues.apache.org/jira/browse/FLINK-17685 Project: Flink Issue

[jira] [Updated] (FLINK-17646) Reduce the python package size of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17646: Fix Version/s: 1.11.0 > Reduce the python package size of PyFlink >

[jira] [Updated] (FLINK-14187) FLIP-56 Dynamic Slot Allocation

[ https://issues.apache.org/jira/browse/FLINK-14187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-14187: - Fix Version/s: (was: 1.11.0) 1.12.0 > FLIP-56 Dynamic Slot Allocation >

[jira] [Assigned] (FLINK-17646) Reduce the python package size of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-17646: --- Assignee: Wei Zhong > Reduce the python package size of PyFlink >

[jira] [Closed] (FLINK-17646) Reduce the python package size of PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17646. --- Resolution: Resolved Merged to master via d45985d27dbc44fe414d69baa685e43d877b082c > Reduce the python

[GitHub] [flink] flinkbot edited a comment on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

flinkbot edited a comment on pull request #12143: URL: https://github.com/apache/flink/pull/12143#issuecomment-628420573 ## CI report: * f257f908133b924d5d1b52d4b01afe80a7e62ebe Azure:

[GitHub] [flink] dianfu merged pull request #12106: [FLINK-17646][python] Reduce the package size of PyFlink.

dianfu merged pull request #12106: URL: https://github.com/apache/flink/pull/12106 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

[GitHub] [flink] flinkbot edited a comment on pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

flinkbot edited a comment on pull request #12133: URL: https://github.com/apache/flink/pull/12133#issuecomment-628151482 ## CI report: * 0ef2a95a929ccad047252a0543eace4b4ea5b804 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12140: [FLINK-17629] Implement format factory for JSON serialization and des…

flinkbot edited a comment on pull request #12140: URL: https://github.com/apache/flink/pull/12140#issuecomment-628369975 ## CI report: * fe5768a8e7d347f7cfda93ce70bfbea4f67645af Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12110: [FLINK-17652][config] Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone

flinkbot edited a comment on pull request #12110: URL: https://github.com/apache/flink/pull/12110#issuecomment-627830489 ## CI report: * 53765ae3b33f89e112de080f60c375f69a2ef8a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12141: [FLINK-17680][docs] Support @ExcludeFromDocumentation when generating REST API documentations

flinkbot edited a comment on pull request #12141: URL: https://github.com/apache/flink/pull/12141#issuecomment-628375347 ## CI report: * cc7001d01358400a227d132784534ff6a79b4dc7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12142: [FLINK-17679][python] Fix the bug of encoding bytes in cython coder

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

[jira] [Updated] (FLINK-17652) Legacy JM heap options should fallback to new JVM_HEAP_MEMORY in standalone

[ https://issues.apache.org/jira/browse/FLINK-17652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17652: --- Labels: pull-request-available (was: ) > Legacy JM heap options should fallback to new

[GitHub] [flink] dianfu commented on pull request #12106: [FLINK-17646][python] Reduce the package size of PyFlink.

dianfu commented on pull request #12106: URL: https://github.com/apache/flink/pull/12106#issuecomment-628429141 The test failure is not related to PR. Merging... This is an automated message from the Apache Git Service. To

[GitHub] [flink] flinkbot edited a comment on pull request #12126: [FLINK-17664][table] Introduce print, blackhole connector in table

flinkbot edited a comment on pull request #12126: URL: https://github.com/apache/flink/pull/12126#issuecomment-628150997 ## CI report: * 9a9ae4d5447c18f4cd593e7f0ea115698026db4f Azure:

[jira] [Updated] (FLINK-17448) Implement table DDLs for Hive dialect part2

[ https://issues.apache.org/jira/browse/FLINK-17448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17448: --- Labels: pull-request-available (was: ) > Implement table DDLs for Hive dialect part2 >

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * dc6d79bf21878d500c4284e6346cf280eeaea53f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

flinkbot edited a comment on pull request #12136: URL: https://github.com/apache/flink/pull/12136#issuecomment-628258215 ## CI report: * 411561c7763474d77bf4db9c52b07613395b1384 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12053: [FLINK-17590][connector/filesystem] Support bucket lifecycle listener in streaming file sink buckets

flinkbot edited a comment on pull request #12053: URL: https://github.com/apache/flink/pull/12053#issuecomment-626125971 ## CI report: * 9f7cb8a717202562c9074e8b8bab636cf0a92994 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12074: [FLINK-17606][table] Introduce DataGenerator connector in table

flinkbot edited a comment on pull request #12074: URL: https://github.com/apache/flink/pull/12074#issuecomment-626543188 ## CI report: * 0fb435bee16969f02c3ebee46beee75c2b8c074a Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12037: [FLINK-14807][runtime][client] Introduce communication through REST API between the clients and the operator coordinators

flinkbot edited a comment on pull request #12037: URL: https://github.com/apache/flink/pull/12037#issuecomment-625870801 ## CI report: * ba87f55e1d19fbf84eec52d084736694497e9307 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12092: [FLINK-17597][python] Refactor the ProcessPythonEnvironmentManager to move the pyflink udf runner script to the pyflink python packag

flinkbot edited a comment on pull request #12092: URL: https://github.com/apache/flink/pull/12092#issuecomment-627157672 ## CI report: * dcf027cd45d55c4d531df1840e09de9e3b857a8c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

flinkbot edited a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-613965719 ## CI report: * abbd96a3ab0c75a09234ea792f5b9cf45df96e5e Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/164608033) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12009: [FLINK-17303][python]Return TableResult for Python TableEnvironment

flinkbot edited a comment on pull request #12009: URL: https://github.com/apache/flink/pull/12009#issuecomment-624669132 ## CI report: * 0223c1e8900dc1d98baab83e09022ae9bb7192ae UNKNOWN * 5bfc2745bd865c641e1d2ad1e23ccb0ff3befff2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 17969b130ddb6c2c9f99c338b1bad013412cf248 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * 6abf4ce6e94c0b9d16370bc58381c4e4c3951267 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

flinkbot edited a comment on pull request #11877: URL: https://github.com/apache/flink/pull/11877#issuecomment-618273998 ## CI report: * e033307ba22ee660cd6c39063896500075b60671 Azure:

[jira] [Assigned] (FLINK-17681) TableEnvironment fromValues not work with map type and SQL

[ https://issues.apache.org/jira/browse/FLINK-17681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-17681: Assignee: Dawid Wysakowicz > TableEnvironment fromValues not work with map type

[GitHub] [flink] flinkbot edited a comment on pull request #11385: [FLINK-11395][formats] Support for Avro StreamingFileSink

flinkbot edited a comment on pull request #11385: URL: https://github.com/apache/flink/pull/11385#issuecomment-597956562 ## CI report: * 9e1bbeafa1a4d0f673ebba7f87ef9032253a29f0 UNKNOWN * 55bbaced3ca77aecde372a75505363cceb280fb6 Azure:

[GitHub] [flink] zhijiangW commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

zhijiangW commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r424906972 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java ## @@ -313,7 +313,7 @@ int

[GitHub] [flink] zhijiangW commented on a change in pull request #11877: [FLINK-16641][network] Announce sender's backlog to solve the deadlock issue without exclusive buffers

zhijiangW commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r424902024 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java ## @@ -418,8 +437,8 @@ public

[GitHub] [flink] jinglining commented on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-628424419 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] jinglining removed a comment on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining removed a comment on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-628374079 This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] wuchong commented on a change in pull request #12133: [FLINK-17526][avro] Support AVRO serialization and deseriazation sche…

wuchong commented on a change in pull request #12133: URL: https://github.com/apache/flink/pull/12133#discussion_r424864692 ## File path: flink-formats/flink-avro/pom.xml ## @@ -93,6 +93,14 @@ under the License. test +

[jira] [Updated] (FLINK-16999) Data structure should cover all conversions declared in logical types

[ https://issues.apache.org/jira/browse/FLINK-16999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16999: --- Labels: pull-request-available (was: ) > Data structure should cover all conversions

[jira] [Updated] (FLINK-17594) Support Hadoop path-based PartFileWriter

[ https://issues.apache.org/jira/browse/FLINK-17594?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17594: --- Labels: pull-request-available (was: ) > Support Hadoop path-based PartFileWriter >

[GitHub] [flink] Myasuka commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r424901092 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java ## @@ -183,6 +209,41 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12126: [FLINK-17664][table] Introduce print, blackhole connector in table

flinkbot edited a comment on pull request #12126: URL: https://github.com/apache/flink/pull/12126#issuecomment-628150997 ## CI report: * 9a9ae4d5447c18f4cd593e7f0ea115698026db4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12134: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

flinkbot edited a comment on pull request #12134: URL: https://github.com/apache/flink/pull/12134#issuecomment-628151544 ## CI report: * b5730a413c2fc8577796bedb6c4fffc269877398 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12129: [FLINK-17667][table-planner-blink][hive] Implement INSERT for Hive di…

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

[GitHub] [flink] flinkbot edited a comment on pull request #12135: [FLINK-16999][table-runtime-blink] Add converters for all data types and classes

flinkbot edited a comment on pull request #12135: URL: https://github.com/apache/flink/pull/12135#issuecomment-628176758 ## CI report: * b92665e8257e52b97570621523e7fe0143481a3c Azure:

[GitHub] [flink] flinkbot commented on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

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

[GitHub] [flink] Myasuka commented on a change in pull request #8693: [FLINK-8871] Support to cancel checkpoing via notification

Myasuka commented on a change in pull request #8693: URL: https://github.com/apache/flink/pull/8693#discussion_r424899752 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -182,7 +181,7 @@ protected final

[jira] [Updated] (FLINK-17684) Run containerized end-to-end tests for all Travis builds

[ https://issues.apache.org/jira/browse/FLINK-17684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17684: --- Labels: pull-request-available (was: ) > Run containerized end-to-end tests for all Travis

[jira] [Updated] (FLINK-17665) Serialize DataType of Buffer into BufferResponse

[ https://issues.apache.org/jira/browse/FLINK-17665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-17665: Labels: pull (was: ) > Serialize DataType of Buffer into BufferResponse >

[jira] [Updated] (FLINK-17665) Serialize DataType of Buffer into BufferResponse

[ https://issues.apache.org/jira/browse/FLINK-17665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-17665: Labels: pull-request-available (was: pull) > Serialize DataType of Buffer into BufferResponse >

[GitHub] [flink-statefun] tzulitai opened a new pull request #109: [FLINK-17684] [e2e] Enable E2E tests in Travis builds

tzulitai opened a new pull request #109: URL: https://github.com/apache/flink-statefun/pull/109 ## Verifying The Travis build should pass, and the logs should be checked that the E2E tests did actually run. This is

[jira] [Created] (FLINK-17684) Run containerized end-to-end tests for all Travis builds

Tzu-Li (Gordon) Tai created FLINK-17684: --- Summary: Run containerized end-to-end tests for all Travis builds Key: FLINK-17684 URL: https://issues.apache.org/jira/browse/FLINK-17684 Project: Flink

[GitHub] [flink] JingsongLi commented on a change in pull request #12074: [FLINK-17606][table] Introduce DataGenerator connector in table

JingsongLi commented on a change in pull request #12074: URL: https://github.com/apache/flink/pull/12074#discussion_r424893175 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/datagen/SequenceGenerator.java ## @@ -0,0 +1,177 @@

[GitHub] [flink] JingsongLi commented on pull request #12126: [FLINK-17664][table] Introduce print, blackhole connector in table

JingsongLi commented on pull request #12126: URL: https://github.com/apache/flink/pull/12126#issuecomment-628410150 Nested row print is not good, but leave it present situation and wait for Row refactor. This is an

[GitHub] [flink] flinkbot commented on pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

flinkbot commented on pull request #12143: URL: https://github.com/apache/flink/pull/12143#issuecomment-628408733 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] [Commented] (FLINK-17678) Support fink-sql-connector-hbase

[ https://issues.apache.org/jira/browse/FLINK-17678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106941#comment-17106941 ] ShenDa commented on FLINK-17678: [~jark] Yes, may be it's not easy to shade, but I have already

[GitHub] [flink] jinglining commented on pull request #11752: [FLINK-14713][rest]Show All Attempts For Vertex SubTask In Rest Api

jinglining commented on pull request #11752: URL: https://github.com/apache/flink/pull/11752#issuecomment-628408254 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-17632) Support to specify a remote path for job jar

[ https://issues.apache.org/jira/browse/FLINK-17632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17632: --- Labels: pull-request-available (was: ) > Support to specify a remote path for job jar >

[jira] [Commented] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106940#comment-17106940 ] Robert Metzger commented on FLINK-12030: This time its

[GitHub] [flink] JingsongLi merged pull request #12124: [hotfix][hive] Should clear StreamTestSink in HiveTableSourceTest

JingsongLi merged pull request #12124: URL: https://github.com/apache/flink/pull/12124 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

[jira] [Updated] (FLINK-12030) KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host this topic-partition

[ https://issues.apache.org/jira/browse/FLINK-12030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12030: --- Summary: KafkaITCase.testMultipleSourcesOnePartition is unstable: This server does not host

[GitHub] [flink] wangyang0918 opened a new pull request #12143: [FLINK-17632][yarn] Support to specify a remote path for job jar

wangyang0918 opened a new pull request #12143: URL: https://github.com/apache/flink/pull/12143 ## What is the purpose of the change After FLINK-13938, we could support to register remote shared libs as Yarn local resources and prevent unnecessary uploading and downloading

[GitHub] [flink] JingsongLi commented on pull request #12126: [FLINK-17664][table] Introduce print, blackhole connector in table

JingsongLi commented on pull request #12126: URL: https://github.com/apache/flink/pull/12126#issuecomment-628406070 Thanks @wuchong and @sjwiesman , updated, for print table, add: `print-identifier` and `standard-error`.

<    5   6   7   8   9   10