[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r425096713 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.java ##

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

danny0405 commented on a change in pull request #12130: URL: https://github.com/apache/flink/pull/12130#discussion_r425096517 ## 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] 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_r425096134 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java ## @@ -132,6 +135,25 @@ public boolean

[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_r425092603 ## 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] 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_r425092603 ## 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] 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

[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-628595484 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] 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-628592688 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-17149) Introduce Debezium format to support reading debezium changelogs

[ https://issues.apache.org/jira/browse/FLINK-17149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17149: --- Labels: pull-request-available (was: ) > Introduce Debezium format to support reading

[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=17107244#comment-17107244 ] Igal Shilman edited comment on FLINK-17611 at 5/14/20, 12:11 PM: -

[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=17107244#comment-17107244 ] Igal Shilman edited comment on FLINK-17611 at 5/14/20, 12:11 PM: -

[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=17107244#comment-17107244 ] Igal Shilman edited comment on FLINK-17611 at 5/14/20, 12:11 PM: -

[GitHub] [flink] wuchong opened a new pull request #12152: [FLINK-17149][debezium][canal] Introduce Debezium and Canal changelog format

wuchong opened a new pull request #12152: URL: https://github.com/apache/flink/pull/12152 ## What is the purpose of the change Introduce `DebeziumFormatFactory` and `CanalFormatFactory` to read changelogs. ```sql CREATE TABLE my_table ( ... ) WITH (

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

wuchong commented on pull request #12152: URL: https://github.com/apache/flink/pull/12152#issuecomment-628592513 cc @danny0405 This is an automated message from the Apache Git Service. To respond to the message, please log

[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=17107244#comment-17107244 ] Igal Shilman commented on FLINK-17611: -- [~slinkydeveloper] having an endpoint in addition to uds

[GitHub] [flink] damjad commented on pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

damjad commented on pull request #12136: URL: https://github.com/apache/flink/pull/12136#issuecomment-628591004 @ajoscha Added the cases in `SideOutputITCase.java`. This is an automated message from the Apache Git Service.

[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_r425072701 ## File path: flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/CoordinatedSourceITCase.java ## @@

[GitHub] [flink] damjad commented on a change in pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

damjad commented on a change in pull request #12136: URL: https://github.com/apache/flink/pull/12136#discussion_r425085400 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -137,7 +137,12 @@ public void

[GitHub] [flink] damjad commented on a change in pull request #12136: [FLINK-17578][flink-streaming] Union of 2 SideOutputs behaviour incorrect

damjad commented on a change in pull request #12136: URL: https://github.com/apache/flink/pull/12136#discussion_r425085499 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamEdge.java ## @@ -150,8 +155,9 @@ public boolean equals(Object

[jira] [Updated] (FLINK-17150) Introduce Canal format to support reading canal changelogs

[ https://issues.apache.org/jira/browse/FLINK-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17150: Description: Introduce CanalFormatFactory and CanalRowDeserializationSchema to read

[jira] [Updated] (FLINK-17149) Introduce Debezium format to support reading debezium changelogs

[ https://issues.apache.org/jira/browse/FLINK-17149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17149: Description: Introduce {{DebeziumFormatFactory}} and {{DebeziumRowDeserializationSchema}} to read

[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-628588481 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] becketqin commented on pull request #12151: [FLINK-16383] Set close = true in monitor/lock scope in KafkaProducer

becketqin commented on pull request #12151: URL: https://github.com/apache/flink/pull/12151#issuecomment-628588687 Thanks for the patch, Aljoscha. LGTM. This is an automated message from the Apache Git Service. To respond to

[jira] [Assigned] (FLINK-17150) Introduce Canal format to support reading canal changelogs

[ https://issues.apache.org/jira/browse/FLINK-17150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17150: --- Assignee: Jark Wu > Introduce Canal format to support reading canal changelogs >

[jira] [Assigned] (FLINK-17149) Introduce Debezium format to support reading debezium changelogs

[ https://issues.apache.org/jira/browse/FLINK-17149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17149: --- Assignee: Jark Wu > Introduce Debezium format to support reading debezium changelogs >

[jira] [Created] (FLINK-17689) Add integeration tests for Debezium and Canal formats

Jark Wu created FLINK-17689: --- Summary: Add integeration tests for Debezium and Canal formats Key: FLINK-17689 URL: https://issues.apache.org/jira/browse/FLINK-17689 Project: Flink Issue Type:

[jira] [Updated] (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:all-tabpanel ] ASF GitHub Bot updated FLINK-16383: --- Labels: pull-request-available test-stability (was: test-stability) >

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

aljoscha opened a new pull request #12151: URL: https://github.com/apache/flink/pull/12151 Before, the flag was changed outside the lock, which would allow the case that the flag is set to true while someone else is holding the "close lock".

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

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

[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 #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 #12146: [hotfix][hbase]Fix HBaseRowInputFormat cannot get the zk address set …

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

[GitHub] [flink] flinkbot edited a comment on pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

flinkbot edited a comment on pull request #12148: URL: https://github.com/apache/flink/pull/12148#issuecomment-628530225 ## CI report: * 634970c61d1579a1456f36d9374230f5b93098c2 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 #12092: [FLINK-17596][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: * a9c696fd00358fc2e142f0546524ce5d30d8f7e8 UNKNOWN * c15428a5630795ec0e7e23d7a4d5c27367ea7e34 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12104: [FLINK-15138][e2e][python] Add PyFlink e2e tests.

flinkbot edited a comment on pull request #12104: URL: https://github.com/apache/flink/pull/12104#issuecomment-627708665 ## CI report: * 76737cc17ae639a100387e11b17f3b84fc13ca76 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: * 650972d1cce62e96571b1650b27f926a1e7613b9 Azure:

[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: * 041714738531dd2a7247fa27e98c2a0202f497ac Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/165501981) 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] flinkbot edited a comment on pull request #12019: [FLINK-17522][tests] Add details on how to run Jepsen tests

flinkbot edited a comment on pull request #12019: URL: https://github.com/apache/flink/pull/12019#issuecomment-625150097 ## CI report: * e6d3120e9b2f7c5149b7b2d2928c2975e1e49ef8 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_r425079339 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java ## @@ -94,13 +99,22 @@

[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] 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_r425078707 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java ## @@ -69,6 +73,7 @@

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

[GitHub] [flink] flinkbot edited a comment on pull request #12008: [FLINK-14881] [s3|kinesis] Add support for IAM Roles for Service Accounts on AWS EKS

flinkbot edited a comment on pull request #12008: URL: https://github.com/apache/flink/pull/12008#issuecomment-624669036 ## CI report: * 0345244193a2bcaef61a025e25435eb24ee9a3ce 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_r425078522 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedSequenceNumberingViewReader.java ## @@ -163,8 +172,15

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

danny0405 opened a new pull request #12150: URL: https://github.com/apache/flink/pull/12150 …ty keys ## What is the purpose of the change This patch add a new table factory for new connector properties based on FLIP-122 and new source sink based on FLIP-95. ## Brief

[jira] [Updated] (FLINK-17026) Introduce a new Kafka connector with new property keys

[ https://issues.apache.org/jira/browse/FLINK-17026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17026: --- Labels: pull-request-available (was: ) > Introduce a new Kafka connector with new property

[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: * 10deae9993244cb215af6f0bb3bd6a9b0f9ef9fd 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] JingsongLi commented on a change in pull request #12134: [FLINK-17594][filesystem] Support Hadoop path-based part-file writer.

JingsongLi commented on a change in pull request #12134: URL: https://github.com/apache/flink/pull/12134#discussion_r425002427 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HadoopPathBasedBulkWriterFactory.java ## @@

[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_r425072084 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java ## @@ -328,4 +325,67 @@ public void

[jira] [Commented] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

[ https://issues.apache.org/jira/browse/FLINK-17378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107232#comment-17107232 ] Dian Fu commented on FLINK-17378: - Another instance:

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r425073734 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningWrapper.java ## @@ -82,187 +94,171 @@

[jira] [Comment Edited] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107228#comment-17107228 ] JinxinTang edited comment on FLINK-17657 at 5/14/20, 11:42 AM: ---   hi,

[jira] [Commented] (FLINK-17657) jdbc not support read BIGINT UNSIGNED field

[ https://issues.apache.org/jira/browse/FLINK-17657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107228#comment-17107228 ] JinxinTang commented on FLINK-17657:   hi, [~zhanglun], Could you please provide code detail to

[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=17107225#comment-17107225 ] Aljoscha Krettek commented on FLINK-16383: -- I doubt it's FLINK-17307 because

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r425069312 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.java ##

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r425068399 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.java ##

[GitHub] [flink] wuchong commented on pull request #12140: [FLINK-17629] Implement format factory for JSON serialization and des…

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

[GitHub] [flink] rkhachatryan commented on a change in pull request #12120: [FLINK-17547] Support unaligned checkpoints for records spilled to files

rkhachatryan commented on a change in pull request #12120: URL: https://github.com/apache/flink/pull/12120#discussion_r425065870 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/NonSpanningWrapper.java ## @@ -290,4 +313,55 @@

[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=17107219#comment-17107219 ] Aljoscha Krettek commented on FLINK-16383: -- I started looking into this and trying to reproduce

[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-628566854 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] pnowojski commented on a change in pull request #11948: [FLINK-17467] Align channels on savepoint in UC mode

pnowojski commented on a change in pull request #11948: URL: https://github.com/apache/flink/pull/11948#discussion_r425059502 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/AlternatingCheckpointBarrierHandlerTest.java ## @@ -0,0 +1,212

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

twalthr commented on pull request #12130: URL: https://github.com/apache/flink/pull/12130#issuecomment-628565405 Thanks for sharing your benchmark results @wuchong. I also performed additional benchmarks. What I didn't like in your branch is the little data size, I don't know if the JIT

[GitHub] [flink] rmetzger commented on pull request #12008: [FLINK-14881] [s3|kinesis] Add support for IAM Roles for Service Accounts on AWS EKS

rmetzger commented on pull request #12008: URL: https://github.com/apache/flink/pull/12008#issuecomment-628564448 Actually, I managed to get a debian based docker image. I still have the mentioned exception though. This is

[jira] [Updated] (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:all-tabpanel ] Piotr Nowojski updated FLINK-16383: --- Affects Version/s: (was: 1.11.0) > KafkaProducerExactlyOnceITCase.

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-16364] [table-planner-blink] supports projection push down on new table source interface in blink planner

flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * ba9ee6228cf9eea60df403e37b41b907fef21a28 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: * 7d395370c88ba5e059f18ad634429d14fd44dc9a Azure:

[jira] [Comment Edited] (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=17107207#comment-17107207 ] Piotr Nowojski edited comment on FLINK-16383 at 5/14/20, 11:10 AM: ---

[GitHub] [flink] flinkbot edited a comment on pull request #12147: [FLINK-17653] FLIP-126: Unify (and separate) Watermark Assigners

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

[GitHub] [flink] flinkbot edited a comment on pull request #12148: [FLINK-13811][python] Support converting flink Table to pandas DataFrame

flinkbot edited a comment on pull request #12148: URL: https://github.com/apache/flink/pull/12148#issuecomment-628530225 ## CI report: * 634970c61d1579a1456f36d9374230f5b93098c2 Azure:

[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] 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_r425056693 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/ArrayData.java ## @@ -215,4 +226,103 @@ static Object

[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=17107207#comment-17107207 ] Piotr Nowojski commented on FLINK-16383: I'm starting to suspect that maybe something here

[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 #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: * 758dc40f4989cf032ffb1207ecd6b26e345a6a29 UNKNOWN * e0424357b5bdcdef98752a9b4a08f2557981e23e 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 #12104: [FLINK-15138][e2e][python] Add PyFlink e2e tests.

flinkbot edited a comment on pull request #12104: URL: https://github.com/apache/flink/pull/12104#issuecomment-627708665 ## CI report: * 76737cc17ae639a100387e11b17f3b84fc13ca76 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12092: [FLINK-17596][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: * a9c696fd00358fc2e142f0546524ce5d30d8f7e8 UNKNOWN * c15428a5630795ec0e7e23d7a4d5c27367ea7e34 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: * 62f441198c518458511ce8b6b013e878c3e9f156 Azure:

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

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

[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 #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: * 041714738531dd2a7247fa27e98c2a0202f497ac Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/165501981) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12008: [FLINK-14881] [s3|kinesis] Add support for IAM Roles for Service Accounts on AWS EKS

flinkbot edited a comment on pull request #12008: URL: https://github.com/apache/flink/pull/12008#issuecomment-624669036 ## CI report: * 0345244193a2bcaef61a025e25435eb24ee9a3ce Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * 3d1878cdf4c0a955e56b68d02bb743e5d6b78317 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12019: [FLINK-17522][tests] Add details on how to run Jepsen tests

flinkbot edited a comment on pull request #12019: URL: https://github.com/apache/flink/pull/12019#issuecomment-625150097 ## CI report: * 1d91dd65362a1932a6663a437e6a30266dea8319 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: * 3591a7e419816e0dc6a13110e180df331726fa44 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 #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: * 10deae9993244cb215af6f0bb3bd6a9b0f9ef9fd 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 commented on pull request #12149: [FLINK-17681] Correct type when converting Row, Map, Array to RexNodes

flinkbot commented on pull request #12149: URL: https://github.com/apache/flink/pull/12149#issuecomment-628557603 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] lirui-apache commented on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

lirui-apache commented on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-628555942 The azure build passed for my personal repo: https://dev.azure.com/lirui-apache/flink/_build/results?buildId=35=results

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

liuyongvs removed a comment on pull request #12144: URL: https://github.com/apache/flink/pull/12144#issuecomment-628549495 hi @rmetzger , why you cancelled my job This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-17688) Support consuming Kinesis' enhanced fanout for flink-connector-kinesis

[ https://issues.apache.org/jira/browse/FLINK-17688?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] roland updated FLINK-17688: --- Description: AWS Kinesis enhanced fanout is a feature that allows consumers to consume a separated

[GitHub] [flink] curcur commented on a change in pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

curcur commented on a change in pull request #11725: URL: https://github.com/apache/flink/pull/11725#discussion_r425044068 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java ##

[jira] [Closed] (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 ] Zhijiang closed FLINK-17665. Resolution: Fixed Merged in master: 3bb18bb2122147162fbd05f3636255b6e5736906 > Serialize DataType of

[jira] [Assigned] (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 ] Zhijiang reassigned FLINK-17665: Assignee: Yingjie Cao > Serialize DataType of Buffer into BufferResponse >

<    2   3   4   5   6   7   8   9   10   >