[GitHub] [flink] pnowojski commented on a change in pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

pnowojski commented on a change in pull request #11687: URL: https://github.com/apache/flink/pull/11687#discussion_r422086939 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractRecordReader.java ## @@ -63,6 +63,8 @@ protected

[jira] [Updated] (FLINK-14101) Introduce SqlServerDialect

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

[jira] [Updated] (FLINK-17577) SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter

[ https://issues.apache.org/jira/browse/FLINK-17577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-17577: Parent: FLINK-16987 Issue Type: Sub-task (was: Bug) > SinkFormat#createSinkFormat should use

[jira] [Closed] (FLINK-17256) Suppport keyword arguments in the PyFlink Descriptor API

[ https://issues.apache.org/jira/browse/FLINK-17256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-17256. --- Resolution: Resolved Merged to master via 0d1738bb15c19fb6c4efe4e7fef55543c33edcea > Suppport keyword

[GitHub] [flink] becketqin commented on pull request #12002: [FLINK-16845][connector/common] Add SourceOperator which runs the Source

becketqin commented on pull request #12002: URL: https://github.com/apache/flink/pull/12002#issuecomment-625776143 @StephanEwen Regarding "Injecting the OperatorEventGateway via setOperatorEventGateway(...)", while I am trying to update the patch, I realized it is not possible to pass the

[jira] [Commented] (FLINK-17494) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102506#comment-17102506 ] Monika Hristova commented on FLINK-17494: - We are experiencing exactly the same problem when we

[jira] [Updated] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

[ https://issues.apache.org/jira/browse/FLINK-17578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Wells updated FLINK-17578: -- Description: Strange behaviour when using union() to merge outputs of 2 DataStreams, where both are

[GitHub] [flink] fpompermaier commented on pull request #12036: [FLINK-17537][connectors / jdbc] Refactor flink-jdbc connector structure

fpompermaier commented on pull request #12036: URL: https://github.com/apache/flink/pull/12036#issuecomment-625783987 Just two notes: since you are refactoring the entire JDBC connector I have collected 2 observations from the other PR I have opened: - made by @aljoscha on pull

[GitHub] [flink] wangyang0918 opened a new pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

wangyang0918 opened a new pull request #12040: URL: https://github.com/apache/flink/pull/12040 ## What is the purpose of the change Currently, every time we start a flink cluster, flink lib jars need to be uploaded to hdfs and then register Yarn local resource so that it

[jira] [Updated] (FLINK-17568) Task may consume data after checkpoint barrier before performing checkpoint for unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-17568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17568: --- Labels: pull-request-available (was: ) > Task may consume data after checkpoint barrier

[GitHub] [flink] wsry opened a new pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed for unaligne

wsry opened a new pull request #12034: URL: https://github.com/apache/flink/pull/12034 ## What is the purpose of the change For unaligned checkpoint, task may consume data after the checkpoint barrier before performing checkpoint which lead to consumption of duplicated data and

[GitHub] [flink] dawidwys commented on pull request #12032: [FLINK-17570] Fix recursive call in BatchTableEnvironment#fromValues

dawidwys commented on pull request #12032: URL: https://github.com/apache/flink/pull/12032#issuecomment-625743562 Thank you for the review. Will merge once azure gives green. This is an automated message from the Apache Git

[jira] [Created] (FLINK-17574) Deduplicate the process execution logic in Flink

Yangze Guo created FLINK-17574: -- Summary: Deduplicate the process execution logic in Flink Key: FLINK-17574 URL: https://issues.apache.org/jira/browse/FLINK-17574 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on pull request #11666: [FLINK-17038][API/DataStream] Decouple resolving Type from creating TypeInformation process

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

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[jira] [Created] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

Dian Fu created FLINK-17576: --- Summary: HiveTableSinkTest and TableEnvHiveConnectorTest are instable Key: FLINK-17576 URL: https://issues.apache.org/jira/browse/FLINK-17576 Project: Flink Issue

[jira] [Updated] (FLINK-17576) HiveTableSinkTest and TableEnvHiveConnectorTest are instable

[ https://issues.apache.org/jira/browse/FLINK-17576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-17576: Labels: test-stability (was: ) > HiveTableSinkTest and TableEnvHiveConnectorTest are instable >

[GitHub] [flink] flinkbot commented on pull request #12039: [FLINK-17577] SinkFormat#createSinkFormat should use DynamicTableSink…

flinkbot commented on pull request #12039: URL: https://github.com/apache/flink/pull/12039#issuecomment-625772998 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] [Assigned] (FLINK-17577) SinkFormat#createSinkFormat should use DynamicTableSink.Context as the first parameter

[ https://issues.apache.org/jira/browse/FLINK-17577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-17577: --- Assignee: Danny Chen > SinkFormat#createSinkFormat should use DynamicTableSink.Context as the

[jira] [Updated] (FLINK-17578) Union of 2 SideOutputs behaviour incorrect

[ https://issues.apache.org/jira/browse/FLINK-17578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Wells updated FLINK-17578: -- Description: Strange behaviour when using union() to merge outputs of 2 DataStreams, where both are

[GitHub] [flink] flinkbot commented on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

flinkbot commented on pull request #12040: URL: https://github.com/apache/flink/pull/12040#issuecomment-625788237 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 #12036: [FLINK-17537][connectors / jdbc] Refactor flink-jdbc connector structure

wuchong commented on a change in pull request #12036: URL: https://github.com/apache/flink/pull/12036#discussion_r422091825 ## File path: flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCInputFormat.java ## @@ -0,0 +1,163 @@ +/* + *

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16548: --- Summary: Expose consistent environment variable to identify the component name and resource id of

[jira] [Updated] (FLINK-16548) Expose consistent environment variable to identify the component name and resource id of jm/tm

[ https://issues.apache.org/jira/browse/FLINK-16548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-16548: --- Description: We proposed to expose consistent e (was: Imagine that there is now

[GitHub] [flink] flinkbot edited a comment on pull request #11755: [FLINK-14257][Connectors / FileSystem]Integrate csv to FileSystemTableFactory

flinkbot edited a comment on pull request #11755: URL: https://github.com/apache/flink/pull/11755#issuecomment-614029227 ## CI report: * 64d407d3530d308b4504282ae8fadb1503955f99 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 #12042: [FLINK-16367] [table] Introduce TableEnvironment#createStatementSet api

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

[GitHub] [flink] flinkbot edited a comment on pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect

flinkbot edited a comment on pull request #12038: URL: https://github.com/apache/flink/pull/12038#issuecomment-625870866 ## CI report: * e8834d0894a5e50f0ba3e2e7c208624354577fb3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

flinkbot edited a comment on pull request #12041: URL: https://github.com/apache/flink/pull/12041#issuecomment-625871059 ## CI report: * d277caea34897278157174cdeda2e22c4f2dd1fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12033: [FLINK-17015]Fix NPE from NullAwareMapIterator

flinkbot edited a comment on pull request #12033: URL: https://github.com/apache/flink/pull/12033#issuecomment-625870561 ## CI report: * ad38204aa74eef633364b2a8d52045d85288cce7 Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #12001: [FLINK-17204][connectors/rabbitmq] Make RMQ queue declaration consistent between source and sink

rmetzger commented on a change in pull request #12001: URL: https://github.com/apache/flink/pull/12001#discussion_r422263699 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/Util.java ## @@ -0,0 +1,17 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * e13ca920f02c00cfc883bc55499d7c179b7a8564 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12002: [FLINK-16845][connector/common] Add SourceOperator which runs the Source

flinkbot edited a comment on pull request #12002: URL: https://github.com/apache/flink/pull/12002#issuecomment-624393131 ## CI report: * efcdef8b36fa74a5861a62dfe12e1425b81669be Azure:

[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-625922766 Thanks a lot for your contribution. I manually re-triggered the failed job on Azure: https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=721=results

[GitHub] [flink] austince commented on a change in pull request #12001: [FLINK-17204][connectors/rabbitmq] Make RMQ queue declaration consistent between source and sink

austince commented on a change in pull request #12001: URL: https://github.com/apache/flink/pull/12001#discussion_r422268851 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/Util.java ## @@ -0,0 +1,17 @@

[GitHub] [flink] rmetzger commented on a change in pull request #12001: [FLINK-17204][connectors/rabbitmq] Make RMQ queue declaration consistent between source and sink

rmetzger commented on a change in pull request #12001: URL: https://github.com/apache/flink/pull/12001#discussion_r422272895 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/Util.java ## @@ -0,0 +1,17 @@

[GitHub] [flink-docker] azagrebin commented on a change in pull request #20: [FLINK-17164] Add job-cluster support

azagrebin commented on a change in pull request #20: URL: https://github.com/apache/flink-docker/pull/20#discussion_r422275526 ## File path: docker-entrypoint.sh ## @@ -18,6 +18,8 @@ # limitations under the License.

[GitHub] [flink] austince commented on a change in pull request #12001: [FLINK-17204][connectors/rabbitmq] Make RMQ queue declaration consistent between source and sink

austince commented on a change in pull request #12001: URL: https://github.com/apache/flink/pull/12001#discussion_r422275241 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/Util.java ## @@ -0,0 +1,17 @@

[GitHub] [flink] flinkbot edited a comment on pull request #12042: [FLINK-16367] [table] Introduce TableEnvironment#createStatementSet api

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

[GitHub] [flink] flinkbot edited a comment on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

flinkbot edited a comment on pull request #12040: URL: https://github.com/apache/flink/pull/12040#issuecomment-625870998 ## CI report: * 5e0bf74fa324d9c8f69c6ccb1f639a17b78d0837 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed f

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

[GitHub] [flink] godfreyhe commented on a change in pull request #12042: [FLINK-16367] [table] Introduce TableEnvironment#createStatementSet api

godfreyhe commented on a change in pull request #12042: URL: https://github.com/apache/flink/pull/12042#discussion_r422232606 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java ## @@ -654,13 +655,39 @@

[jira] [Created] (FLINK-17580) NPE in unaligned checkpoint for EndOfPartition events

Arvid Heise created FLINK-17580: --- Summary: NPE in unaligned checkpoint for EndOfPartition events Key: FLINK-17580 URL: https://issues.apache.org/jira/browse/FLINK-17580 Project: Flink Issue

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[jira] [Commented] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102710#comment-17102710 ] Andrey Zagrebin commented on FLINK-17560: - I would also try the latest Flink 1.10 version, if

[jira] [Comment Edited] (FLINK-17560) No Slots available exception in Apache Flink Job Manager while Scheduling

[ https://issues.apache.org/jira/browse/FLINK-17560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102710#comment-17102710 ] Andrey Zagrebin edited comment on FLINK-17560 at 5/8/20, 4:25 PM: -- I

[GitHub] [flink] flinkbot edited a comment on pull request #11755: [FLINK-14257][Connectors / FileSystem]Integrate csv to FileSystemTableFactory

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

[GitHub] [flink] flinkbot edited a comment on pull request #12043: [hotfix][docs][s3] Clarify wording of S3 Filesystem support

flinkbot edited a comment on pull request #12043: URL: https://github.com/apache/flink/pull/12043#issuecomment-625888015 ## CI report: * 03c49433fe8f1af010c5137e99c70b73e62fd817 Azure:

[jira] [Commented] (FLINK-17574) Deduplicate the process execution logic in Flink

[ https://issues.apache.org/jira/browse/FLINK-17574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102720#comment-17102720 ] Andrey Zagrebin commented on FLINK-17574: - There are already some utility classes, like

[jira] [Updated] (FLINK-17574) Deduplicate the process execution logic in Flink

[ https://issues.apache.org/jira/browse/FLINK-17574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-17574: Component/s: (was: Runtime / Coordination) Tests > Deduplicate the

[jira] [Commented] (FLINK-17571) A better way to show the files used in currently checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102727#comment-17102727 ] Trystan commented on FLINK-17571: - [~klion26] thank you so much - I would be happy to help too! Although

[GitHub] [flink] sjwiesman commented on a change in pull request #12043: [hotfix][docs][s3] Clarify wording of S3 Filesystem support

sjwiesman commented on a change in pull request #12043: URL: https://github.com/apache/flink/pull/12043#discussion_r422252657 ## File path: docs/ops/filesystems/s3.md ## @@ -60,10 +60,15 @@ Flink provides two file systems to talk to Amazon S3, `flink-s3-fs-presto` and ` Both

[jira] [Created] (FLINK-17581) Update translation of S3 documentation

Robert Metzger created FLINK-17581: -- Summary: Update translation of S3 documentation Key: FLINK-17581 URL: https://issues.apache.org/jira/browse/FLINK-17581 Project: Flink Issue Type: Task

[GitHub] [flink] rmetzger commented on pull request #12043: [hotfix][docs][s3] Clarify wording of S3 Filesystem support

rmetzger commented on pull request #12043: URL: https://github.com/apache/flink/pull/12043#issuecomment-625916432 translation ticket: https://issues.apache.org/jira/browse/FLINK-17581 This is an automated message from the

[jira] [Commented] (FLINK-17493) Possible direct memory leak in cassandra sink

[ https://issues.apache.org/jira/browse/FLINK-17493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102665#comment-17102665 ] Monika Hristova commented on FLINK-17493: - We are experiencing exactly the same problem when we

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #12030: [FLINK-17567][python][release] Create a dedicated Python directory in release directory to place Python-related source and binary pac

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

[GitHub] [flink] flinkbot commented on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed for unal

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

[GitHub] [flink] flinkbot edited a comment on pull request #12031: [FLINK-17017] Implement Bulk Slot Allocation

flinkbot edited a comment on pull request #12031: URL: https://github.com/apache/flink/pull/12031#issuecomment-625706903 ## CI report: * 490fe2228a370527cc3db5431c8b066854a69ae8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12027: [FLINK-17564][checkpointing] Fix buffer disorder issue of RemoteInputChannel for unaligned checkpoint

flinkbot edited a comment on pull request #12027: URL: https://github.com/apache/flink/pull/12027#issuecomment-625644178 ## CI report: * 42f0a0401969ac05f42aa592a39c2431c9f3aed4 Azure:

[GitHub] [flink] flinkbot commented on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

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

[GitHub] [flink] flinkbot commented on pull request #12036: [FLINK-17537][connectors / jdbc] Refactor flink-jdbc connector structure

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

[GitHub] [flink] flinkbot edited a comment on pull request #12002: [FLINK-16845][connector/common] Add SourceOperator which runs the Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * c3958066f46822218c29a10c7bad1d4d699949f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11999: [FLINK-14100][jdbc] Added Oracle dialect

flinkbot edited a comment on pull request #11999: URL: https://github.com/apache/flink/pull/11999#issuecomment-624154294 ## CI report: * d86e75eb3bcafe6695ab845719196447d30b7e18 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12011: [FLINK-17542] Unify slot request timeout handling for streaming and batch tasks

flinkbot edited a comment on pull request #12011: URL: https://github.com/apache/flink/pull/12011#issuecomment-624791772 ## CI report: * 97efd201ad9b8f206e53c4e12998f68c9cc0159a UNKNOWN * 1addb70f0f971db762eba06c3ac4319c069a7dec 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: * f6933a873ba179bc9dba26843a44c2bc72f1d95f Azure:

[GitHub] [flink] flinkbot commented on pull request #12033: [FLINK-17015]Fix NPE from NullAwareMapIterator

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

[GitHub] [flink] flinkbot edited a comment on pull request #12032: [FLINK-17570] Fix recursive call in BatchTableEnvironment#fromValues

flinkbot edited a comment on pull request #12032: URL: https://github.com/apache/flink/pull/12032#issuecomment-625746734 ## CI report: * edd5c277f04e481d29db52167170a26bf71eb499 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11687: [FLINK-16536][network][checkpointing] Implement InputChannel state recovery for unaligned checkpoint

flinkbot edited a comment on pull request #11687: URL: https://github.com/apache/flink/pull/11687#issuecomment-611445542 ## CI report: * 5bad018f00f85a7359345187a12d7938aa510d25 UNKNOWN * d51ce7f47381d99b843278cd701dcff223761a0b UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN * d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis:

[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: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/164608033) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12034: [FLINK-17568][checkpointing] Fix the issue that task may consume input data after checkpoint barrier before checkpoint is performed f

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

[GitHub] [flink] flinkbot edited a comment on pull request #11999: [FLINK-14100][jdbc] Added Oracle dialect

flinkbot edited a comment on pull request #11999: URL: https://github.com/apache/flink/pull/11999#issuecomment-624154294 ## CI report: * d86e75eb3bcafe6695ab845719196447d30b7e18 Azure:

[GitHub] [flink] rmetzger commented on pull request #12043: [hotfix][docs][s3] Clarify wording of S3 Filesystem support

rmetzger commented on pull request #12043: URL: https://github.com/apache/flink/pull/12043#issuecomment-625915151 Thanks for the review. Merging. This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-17468) Provide more detailed metrics why asynchronous part of checkpoint is taking long time

[ https://issues.apache.org/jira/browse/FLINK-17468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102742#comment-17102742 ] Lu Niu commented on FLINK-17468: [~klion26] [~yunta] Thanks for reviewing! I think adding more

[jira] [Commented] (FLINK-17416) Flink-kubernetes doesn't work on java 8 8u252

[ https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17102637#comment-17102637 ] Robert Metzger commented on FLINK-17416: Side note: A user is affected by this as well:

[GitHub] [flink] flinkbot edited a comment on pull request #11950: [FLINK-17030] Add primary key syntax to DDL

flinkbot edited a comment on pull request #11950: URL: https://github.com/apache/flink/pull/11950#issuecomment-621585318 ## CI report: * 3788245663259c007512d23052af316fb11c984d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * 8808e39c0d3cb29cc88fd23ede27820e427e6a75 UNKNOWN * 85affedaf4bd2005f910870613a20387fb3a527e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11979: [FLINK-17291][docs] Translate 'docs/training/event_driven.zh.md' to C…

flinkbot edited a comment on pull request #11979: URL: https://github.com/apache/flink/pull/11979#issuecomment-623137252 ## CI report: * 51f00c041b126b54616f191f669750e819c733db Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * 85fca8f7c61ae63a48284830f7991a586c40ee73 Azure:

[GitHub] [flink] flinkbot commented on pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

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

[GitHub] [flink] flinkbot commented on pull request #12039: [FLINK-17577] SinkFormat#createSinkFormat should use DynamicTableSink…

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

[GitHub] [flink] flinkbot commented on pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect

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

[GitHub] [flink] flinkbot commented on pull request #12042: [FLINK-16367] [table] Introduce TableEnvironment#createStatementSet api

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

[GitHub] [flink] flinkbot commented on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

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

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

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

[GitHub] [flink] flinkbot edited a comment on pull request #12036: [FLINK-17537][connectors / jdbc] Refactor flink-jdbc connector structure

flinkbot edited a comment on pull request #12036: URL: https://github.com/apache/flink/pull/12036#issuecomment-625870744 ## CI report: * 173ded87a6bbdc639582e62245de653ce562e0ef Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12035: [FLINK-17569][FileSystemsems]support ViewFileSystem when wait lease revoke of hadoop filesystem

flinkbot edited a comment on pull request #12035: URL: https://github.com/apache/flink/pull/12035#issuecomment-625870674 ## CI report: * d07a0d67629303d83b2998ff1b43aa698c59c116 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12038: [FLINK-14101][jdbc] Added MS SQL-server dialect

flinkbot edited a comment on pull request #12038: URL: https://github.com/apache/flink/pull/12038#issuecomment-625870866 ## CI report: * e8834d0894a5e50f0ba3e2e7c208624354577fb3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12002: [FLINK-16845][connector/common] Add SourceOperator which runs the Source

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

[GitHub] [flink] flinkbot edited a comment on pull request #12041: [FLINK-17506][state-processor-api] SavepointEnvironment should honour 'io.tmp.dirs' property

flinkbot edited a comment on pull request #12041: URL: https://github.com/apache/flink/pull/12041#issuecomment-625871059 ## CI report: * d277caea34897278157174cdeda2e22c4f2dd1fa Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12039: [FLINK-17577] SinkFormat#createSinkFormat should use DynamicTableSink…

flinkbot edited a comment on pull request #12039: URL: https://github.com/apache/flink/pull/12039#issuecomment-625870930 ## CI report: * ced68bb246f87c0fd928a049ec93bbd18f43a9e7 Azure:

[GitHub] [flink] flinkbot commented on pull request #12043: [hotfix][docs][s3] Clarify wording of S3 Filesystem support

flinkbot commented on pull request #12043: URL: https://github.com/apache/flink/pull/12043#issuecomment-625879462 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 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: * ab6e6c99ed5727eb9cf8891dbf9cd1afcd6e31a8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12040: [FLINK-13938][yarn] Use provided lib dirs to accelerate flink submission

flinkbot edited a comment on pull request #12040: URL: https://github.com/apache/flink/pull/12040#issuecomment-625870998 ## CI report: * 5e0bf74fa324d9c8f69c6ccb1f639a17b78d0837 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11985: [FLINK-16989][table] Support ScanTableSource in blink planner

flinkbot edited a comment on pull request #11985: URL: https://github.com/apache/flink/pull/11985#issuecomment-623545781 ## CI report: * 8808e39c0d3cb29cc88fd23ede27820e427e6a75 UNKNOWN * 85affedaf4bd2005f910870613a20387fb3a527e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12042: [FLINK-16367] [table] Introduce TableEnvironment#createStatementSet api

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

[GitHub] [flink] flinkbot edited a comment on pull request #12010: [FLINK-17286][connectors / filesystem]Integrate json to file system connector

flinkbot edited a comment on pull request #12010: URL: https://github.com/apache/flink/pull/12010#issuecomment-624746999 ## CI report: * d7445e68ed77a6b1b88fdf0dac8638ff62ac8967 UNKNOWN * c3958066f46822218c29a10c7bad1d4d699949f8 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12033: [FLINK-17015]Fix NPE from NullAwareMapIterator

flinkbot edited a comment on pull request #12033: URL: https://github.com/apache/flink/pull/12033#issuecomment-625870561 ## CI report: * ad38204aa74eef633364b2a8d52045d85288cce7 Azure:

<    1   2   3   4   5   6   >