[jira] [Created] (FLINK-17693) Add createTypeInformation to DynamicTableSink#Context

Jark Wu created FLINK-17693: --- Summary: Add createTypeInformation to DynamicTableSink#Context Key: FLINK-17693 URL: https://issues.apache.org/jira/browse/FLINK-17693 Project: Flink Issue Type:

[GitHub] [flink] KurtYoung commented on a change in pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

KurtYoung commented on a change in pull request #12069: URL: https://github.com/apache/flink/pull/12069#discussion_r425106208 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectCoordinationRequest.java ## @@ -0,0 +1,65 @@

[jira] [Created] (FLINK-17692) "flink-end-to-end-tests/test-scripts/hadoop/yarn.classpath" present after building Flink

Robert Metzger created FLINK-17692: -- Summary: "flink-end-to-end-tests/test-scripts/hadoop/yarn.classpath" present after building Flink Key: FLINK-17692 URL: https://issues.apache.org/jira/browse/FLINK-17692

[GitHub] [flink] StephanEwen commented on a change in pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

StephanEwen commented on a change in pull request #12151: URL: https://github.com/apache/flink/pull/12151#discussion_r425134302 ## File path: flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java

[jira] [Commented] (FLINK-17469) Support override of DEFAULT_JOB_NAME with system property for StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-17469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107288#comment-17107288 ] Aljoscha Krettek commented on FLINK-17469: -- I agree on all of this, it would be good to control

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425134658 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r425134149 ## File path: contributing/contribute-code.zh.md ## @@ -136,91 +136,91 @@ Apache Flink is maintained, improved, and extended by code contributions of

[jira] [Commented] (FLINK-16383) KafkaProducerExactlyOnceITCase. testExactlyOnceRegularSink fails with "The producer has already been closed"

[ https://issues.apache.org/jira/browse/FLINK-16383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107287#comment-17107287 ] Robert Metzger commented on FLINK-16383: Another case:

[GitHub] [flink] lirui-apache commented on pull request #11990: [FLINK-17387][hive] Implement LookupableTableSource for Hive connector

lirui-apache commented on pull request #11990: URL: https://github.com/apache/flink/pull/11990#issuecomment-628633094 Build has passed on my personal repo: https://dev.azure.com/lirui-apache/flink/_build/results?buildId=40=results

[GitHub] [flink] flinkbot edited a comment on pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

flinkbot edited a comment on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628151351 ## CI report: * 531427273f179ba94af3397a354418ecac7d0d4f Azure:

[jira] [Created] (FLINK-17691) Failed to sinkKafka with exactly once mode when transactional.id too long

freezhan created FLINK-17691: Summary: Failed to sinkKafka with exactly once mode when transactional.id too long Key: FLINK-17691 URL: https://issues.apache.org/jira/browse/FLINK-17691 Project: Flink

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r425132742 ## File path: contributing/contribute-code.zh.md ## @@ -126,7 +126,7 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-14807][table] Add specialized collecting iterator to Blink planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

flinkbot edited a comment on pull request #12120: URL: https://github.com/apache/flink/pull/12120#issuecomment-628150581 ## CI report: * 91982f5d59af5b6540ffa4052050b18a56f92b25 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12119: [FLINK-17649][table-planner-blink] Generated hash aggregate code may …

flinkbot edited a comment on pull request #12119: URL: https://github.com/apache/flink/pull/12119#issuecomment-628150518 ## CI report: * 13962fa6930cf29f65ab11a368660f95ff4f29bc Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12076: [FLINK-15950][table] Remove registration of TableSource/TableSink in Table Env

flinkbot edited a comment on pull request #12076: URL: https://github.com/apache/flink/pull/12076#issuecomment-626599640 ## CI report: * 525efab0792cd8b81842e5964454ee373f34d029 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

flinkbot edited a comment on pull request #12152: URL: https://github.com/apache/flink/pull/12152#issuecomment-628617951 ## CI report: * 81d1f17f7dad4bed004616df23aa37a0e700b96a 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 #12130: [FLINK-17668][table] Fix shortcomings in new data structures

flinkbot edited a comment on pull request #12130: URL: https://github.com/apache/flink/pull/12130#issuecomment-628151265 ## CI report: * 3ce911785950f69b2ab7d6b1f74352cdc962cd94 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

flinkbot edited a comment on pull request #12153: URL: https://github.com/apache/flink/pull/12153#issuecomment-628618072 ## CI report: * 169ed4faedfbcd96213ee17ce19d5f19bb6aafc1 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/166004137) Azure:

[GitHub] [flink] twalthr commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425132394 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericMapData.java ## @@ -85,12 +85,15 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #12057: [FLINK-16210][docs] Extending the "Flink Architecture" section.

flinkbot edited a comment on pull request #12057: URL: https://github.com/apache/flink/pull/12057#issuecomment-626300700 ## CI report: * 41c4429c8ec2db10b05f65da3317ed08f2732823 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/165979160) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 2af1ec04f8659cc749ba61efdb103342d44f2c96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 89b43558a39741f04114f95011f784fd5414b22c UNKNOWN * 0d278faf6cd4d3972dd1fe64d4d851b70475c3ee Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425132315 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[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: * ae90bc7d6d3753da3e9bbadcc99c80a152801e43 Azure:

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r425132004 ## File path: contributing/contribute-code.zh.md ## @@ -79,44 +79,44 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425131551 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] dawidwys commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

dawidwys commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r425131321 ## File path: flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategies.java ## @@ -0,0 +1,230 @@ +/* + * Licensed to the

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425130785 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink-web] yangjf2019 commented on a change in pull request #268: [FLINK-13343][docs-zh] Translate "Contribute Code" page into Chinese

yangjf2019 commented on a change in pull request #268: URL: https://github.com/apache/flink-web/pull/268#discussion_r425130635 ## File path: contributing/contribute-code.zh.md ## @@ -79,44 +79,44 @@ Apache Flink is maintained, improved, and extended by code contributions of

[GitHub] [flink] StephanEwen commented on a change in pull request #12122: [FLINK-15102] Add continuousSource() method to StreamExecutionEnvironment.

StephanEwen commented on a change in pull request #12122: URL: https://github.com/apache/flink/pull/12122#discussion_r425118547 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java ## @@ -266,7 +268,10 @@ public boolean

[GitHub] [flink] dawidwys commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

dawidwys commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r425126049 ## File path: flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkOutputMultiplexer.java ## @@ -0,0 +1,266 @@ +/* + * Licensed to

[jira] [Commented] (FLINK-17676) Is there some way to rollback the .out file of TaskManager

[ https://issues.apache.org/jira/browse/FLINK-17676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107277#comment-17107277 ] Gary Yao commented on FLINK-17676: -- [~hejiefang] Can you use

[GitHub] [flink] alpinegizmo commented on a change in pull request #12057: [FLINK-16210][docs] Extending the "Flink Architecture" section.

alpinegizmo commented on a change in pull request #12057: URL: https://github.com/apache/flink/pull/12057#discussion_r425124863 ## File path: docs/concepts/flink-architecture.md ## @@ -129,4 +167,108 @@ two main benefits: +## Flink Application Execution + +A _Flink

[GitHub] [flink] dawidwys commented on a change in pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

dawidwys commented on a change in pull request #12147: URL: https://github.com/apache/flink/pull/12147#discussion_r425081822 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java ## @@

[jira] [Comment Edited] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107270#comment-17107270 ] Francesco Guardiani edited comment on FLINK-17611 at 5/14/20, 1:05 PM:

[jira] [Commented] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107270#comment-17107270 ] Francesco Guardiani commented on FLINK-17611: - Opened the PR here:

[GitHub] [flink] twalthr commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425120240 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericMapData.java ## @@ -85,12 +85,15 @@ public boolean

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425117737 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink-statefun] slinkydeveloper opened a new pull request #110: [FLINK-17611] Unix domain socket connection between worker and function

slinkydeveloper opened a new pull request #110: URL: https://github.com/apache/flink-statefun/pull/110 Hi all, This pr implements https://issues.apache.org/jira/browse/FLINK-17611 . To enable a unix domain socket connection in a remote module, use `uds` field: ```

[jira] [Updated] (FLINK-17611) Support unix domain sockets for sidecar communication in Stateful Functions

[ https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17611: --- Labels: pull-request-available (was: ) > Support unix domain sockets for sidecar

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

wsry commented on a change in pull request #11877: URL: https://github.com/apache/flink/pull/11877#discussion_r425117136 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java ## @@ -163,8 +172,15 @@

[jira] [Created] (FLINK-17690) Python function wrapper omits docstr

Igal Shilman created FLINK-17690: Summary: Python function wrapper omits docstr Key: FLINK-17690 URL: https://issues.apache.org/jira/browse/FLINK-17690 Project: Flink Issue Type: Improvement

[GitHub] [flink] flinkbot commented on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

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

[GitHub] [flink] flinkbot edited a comment on pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

flinkbot edited a comment on pull request #12150: URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536 ## CI report: * e0e57e5b94fe42e04146af4796431cdc40efc2bb Azure:

[GitHub] [flink] flinkbot commented on pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

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

[GitHub] [flink] wuchong commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

wuchong commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425116004 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericMapData.java ## @@ -85,12 +85,15 @@ public boolean

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d94801c55893bfc984f0d59ea53c70d30168465f Azure:

[jira] [Updated] (FLINK-17450) Implement function & catalog DDLs for Hive dialect

[ https://issues.apache.org/jira/browse/FLINK-17450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-17450: --- Summary: Implement function & catalog DDLs for Hive dialect (was: Implement function DDLs for Hive

[GitHub] [flink] flinkbot edited a comment on pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

flinkbot edited a comment on pull request #12151: URL: https://github.com/apache/flink/pull/12151#issuecomment-628604664 ## CI report: * c38ce628f6d041da0daa96d2faa881df60caef35 Azure:

[GitHub] [flink] wuchong commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

wuchong commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425116004 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericMapData.java ## @@ -85,12 +85,15 @@ public boolean

[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 #12130: [FLINK-17668][table] Fix shortcomings in new data structures

flinkbot edited a comment on pull request #12130: URL: https://github.com/apache/flink/pull/12130#issuecomment-628151265 ## CI report: * 3ce911785950f69b2ab7d6b1f74352cdc962cd94 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 #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

flinkbot edited a comment on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628151351 ## CI report: * 531427273f179ba94af3397a354418ecac7d0d4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12125: [FLINK-12717][python] Remove unnecessary 'pyflink-gateway-server.sh'.

flinkbot edited a comment on pull request #12125: URL: https://github.com/apache/flink/pull/12125#issuecomment-628150904 ## CI report: * 18eb506e5387100cfddb108a3a97f920038c59ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12111: [hotfix][test] Disable Google PubSub Emulator e2e test on aarch64

flinkbot edited a comment on pull request #12111: URL: https://github.com/apache/flink/pull/12111#issuecomment-627830590 ## CI report: * c626c6bb4bc8efa59e01b9a32d6068736b2717ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12092: [FLINK-17596][python] Move the Python UDF runner script out of the jar of flink-python

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

[GitHub] [flink] flinkbot edited a comment on pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

flinkbot edited a comment on pull request #12120: URL: https://github.com/apache/flink/pull/12120#issuecomment-628150581 ## CI report: * 91982f5d59af5b6540ffa4052050b18a56f92b25 Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425115061 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] flinkbot edited a comment on pull request #12076: [FLINK-15950][table] Remove registration of TableSource/TableSink in Table Env

flinkbot edited a comment on pull request #12076: URL: https://github.com/apache/flink/pull/12076#issuecomment-626599640 ## CI report: * 525efab0792cd8b81842e5964454ee373f34d029 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

flinkbot edited a comment on pull request #11948: URL: https://github.com/apache/flink/pull/11948#issuecomment-621327009 ## CI report: * e4ce0de30cb5d324dc4a2a030e416de1f7f1a79d UNKNOWN * d54111c2ca84686374c6e1c787fa8999ad26971c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12057: [FLINK-16210][docs] Extending the "Flink Architecture" section.

flinkbot edited a comment on pull request #12057: URL: https://github.com/apache/flink/pull/12057#issuecomment-626300700 ## CI report: * 41c4429c8ec2db10b05f65da3317ed08f2732823 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/165979160) Azure:

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425114909 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-14807][table] Add specialized collecting iterator to Blink planner

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

[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: * ae90bc7d6d3753da3e9bbadcc99c80a152801e43 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12062: [FLINK-17587][filesystem] Filesystem streaming sink support commit success file

flinkbot edited a comment on pull request #12062: URL: https://github.com/apache/flink/pull/12062#issuecomment-626437386 ## CI report: * 89b43558a39741f04114f95011f784fd5414b22c UNKNOWN * 0d278faf6cd4d3972dd1fe64d4d851b70475c3ee Azure:

[GitHub] [flink] SteNicholas removed a comment on pull request #12078: [FLINK-17610][state]Align the behavior of result of internal map state to re…

SteNicholas removed a comment on pull request #12078: URL: https://github.com/apache/flink/pull/12078#issuecomment-627770828 @Myasuka Please check again the comments. This is an automated message from the Apache Git Service.

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425113095 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] twalthr commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425112702 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericMapData.java ## @@ -85,12 +85,15 @@ public boolean

[GitHub] [flink] twalthr commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425111957 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/ArrayData.java ## @@ -215,4 +226,103 @@ static Object

[GitHub] [flink-statefun] igalshilman edited a comment on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

igalshilman edited a comment on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-628613062 Hi @abc863377, I think that there is a consensus not to proceed with the change here, but I'd like to suggest the following: can you set the

[GitHub] [flink-statefun] igalshilman commented on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

igalshilman commented on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-628613062 Hi @abc863377, I think that there is a consensus, proceed with the change here, but I'd like to suggest the following: can you set the `statefun.flink-job-name` key

[GitHub] [flink-statefun] igalshilman edited a comment on pull request #106: [FLINK-16985] Stateful Functions Examples have their specific job names

igalshilman edited a comment on pull request #106: URL: https://github.com/apache/flink-statefun/pull/106#issuecomment-628613062 Hi @abc863377, I think that there is a consensus not to proceed with the change here, but I'd like to suggest the following: can you set the

[GitHub] [flink] flinkbot commented on pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

flinkbot commented on pull request #12153: URL: https://github.com/apache/flink/pull/12153#issuecomment-628612286 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] wuchong commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

wuchong commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425109858 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/ArrayData.java ## @@ -215,4 +226,103 @@ static Object

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425108297 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] complone commented on pull request #11912: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

complone commented on pull request #11912: URL: https://github.com/apache/flink/pull/11912#issuecomment-628609863 > @complone当然，没问题；1.11功能冻结是在星期五，所以如果我们早点安装它，那就好了:) Hello, I have modified and resubmitted a new pull request. Maybe I can close the current pull request

[GitHub] [flink] aljoscha commented on pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

aljoscha commented on pull request #12151: URL: https://github.com/apache/flink/pull/12151#issuecomment-628609324 @becketqin I added some debug logging. This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] WeiZhong94 commented on pull request #12104: [FLINK-15138][e2e][python] Add PyFlink e2e tests.

WeiZhong94 commented on pull request #12104: URL: https://github.com/apache/flink/pull/12104#issuecomment-628609069 @dianfu It seems the e2e test has passed in my Azure build. This is an automated message from the Apache Git

[GitHub] [flink] complone opened a new pull request #12153: [FLINK-16966][metrics][infuxdb] Convert InfluxDB reporter to plugin

complone opened a new pull request #12153: URL: https://github.com/apache/flink/pull/12153 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferring them

[GitHub] [flink] WeiZhong94 commented on pull request #12104: [FLINK-15138][e2e][python] Add PyFlink e2e tests.

WeiZhong94 commented on pull request #12104: URL: https://github.com/apache/flink/pull/12104#issuecomment-628608702 https://dev.azure.com/weizhong0618/Flink/_build/results?buildId=97=logs=1f3ed471-1849-5d3c-a34c-19792af4ad16=2f5b54d0-1d28-5b01-d344-aa50ffe0cdf8

[GitHub] [flink] wuchong commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

wuchong commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425102181 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericMapData.java ## @@ -85,12 +85,15 @@ public boolean

[GitHub] [flink] WeiZhong94 commented on a change in pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

WeiZhong94 commented on a change in pull request #12148: URL: https://github.com/apache/flink/pull/12148#discussion_r425097800 ## File path: flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowUtils.java ## @@ -588,6 +607,89 @@ private static void

[GitHub] [flink] flinkbot commented on pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

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

[GitHub] [flink] flinkbot edited a comment on pull request #12149: [FLINK-17681] Correct type when converting Row, Map, Array to RexNodes

flinkbot edited a comment on pull request #12149: URL: https://github.com/apache/flink/pull/12149#issuecomment-628585908 ## CI report: * fa262ac0db9fd73454093771e3c6c27649a9ab17 Azure:

[GitHub] [flink] flinkbot commented on pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

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

[GitHub] [flink] twalthr commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425101178 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/ArrayData.java ## @@ -215,4 +226,103 @@ static Object

[GitHub] [flink] azagrebin commented on a change in pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

azagrebin commented on a change in pull request #12131: URL: https://github.com/apache/flink/pull/12131#discussion_r425096153 ## File path: docs/ops/deployment/docker.md ## @@ -24,119 +24,476 @@ under the License. --> [Docker](https://www.docker.com) is a popular container

[GitHub] [flink] flinkbot edited a comment on pull request #12144: [FLINK-17384][flink-dist] support read hbase conf dir from flink.conf.

flinkbot edited a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628475376 ## CI report: * d94801c55893bfc984f0d59ea53c70d30168465f 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 #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: * c7a835625072893c37381a3844d7ad4334ad4318 UNKNOWN * 562929e227cfc1ca070b2085d37bae032b751e29 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12125: [FLINK-12717][python] Remove unnecessary 'pyflink-gateway-server.sh'.

flinkbot edited a comment on pull request #12125: URL: https://github.com/apache/flink/pull/12125#issuecomment-628150904 ## CI report: * 18eb506e5387100cfddb108a3a97f920038c59ed Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12131: [FLINK-17161][docs][docker] Document the official docker hub image and examples of how to use it

flinkbot edited a comment on pull request #12131: URL: https://github.com/apache/flink/pull/12131#issuecomment-628151351 ## CI report: * 531427273f179ba94af3397a354418ecac7d0d4f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12069: [FLINK-14807][streaming] Add specialized collecting sink function

flinkbot edited a comment on pull request #12069: URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528 ## CI report: * 2af1ec04f8659cc749ba61efdb103342d44f2c96 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-14807][table] Add specialized collecting iterator to Blink planner

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

[GitHub] [flink] flinkbot edited a comment on pull request #11990: [FLINK-17387][hive] Implement LookupableTableSource for Hive connector

flinkbot edited a comment on pull request #11990: URL: https://github.com/apache/flink/pull/11990#issuecomment-623910490 ## CI report: * 99f3bca89ea39ba4b354fee78dcc233394b6477e Azure:

[GitHub] [flink] twalthr commented on a change in pull request #12130: [FLINK-17668][table] Fix shortcomings in new data structures

twalthr commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425099078 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/ArrayData.java ## @@ -215,4 +226,103 @@ static Object

[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:

<    1   2   3   4   5   6   7   8   9   10   >