[jira] [Created] (FLINK-14703) Port the Kafka SQL related tests.

Zheng Hu created FLINK-14703: Summary: Port the Kafka SQL related tests. Key: FLINK-14703 URL: https://issues.apache.org/jira/browse/FLINK-14703 Project: Flink Issue Type: Sub-task Re

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE [Build]

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344593616 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexec

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344596739 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ###

[GitHub] [flink] TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

TisonKun commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344598205 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDes

[GitHub] [flink] godfreyhe commented on a change in pull request #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl

godfreyhe commented on a change in pull request #10119: [FLINK-14656] [table-planner-blink] blink planner should also fetch catalog statistics for permanent CatalogTableImpl URL: https://github.com/apache/flink/pull/10119#discussion_r344598477 ## File path: flink-table/flink-table

[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : SUCCESS [Build](https://travis-ci.c

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344599761 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexec

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 : S

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE [Build]

[GitHub] [flink] TisonKun commented on a change in pull request #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

TisonKun commented on a change in pull request #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#discussion_r344602603 ## File path: flink-runtime/src/test/java/org/apache/flink/r

[GitHub] [flink] TisonKun commented on a change in pull request #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

TisonKun commented on a change in pull request #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#discussion_r344602714 ## File path: flink-runtime/src/test/java/org/apache/flink/r

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344602758 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344603009 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexec

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344603414 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexec

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344606115 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexec

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344606214 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/taskexec

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat

flinkbot edited a comment on issue #10022: [FLINK-14135][orc] Introduce OrcColumnarRowInputFormat URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] StephanEwen commented on issue #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests.

StephanEwen commented on issue #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests. URL: https://github.com/apache/flink/pull/10138#issuecomment-552349705 We can try putting the `KinesisPubsubClient` into a test jar and referencing that in the te

[jira] [Created] (FLINK-14704) Remove uesless SynchronousSavepointLatch

Yun Tang created FLINK-14704: Summary: Remove uesless SynchronousSavepointLatch Key: FLINK-14704 URL: https://issues.apache.org/jira/browse/FLINK-14704 Project: Flink Issue Type: Improvement

[GitHub] [flink] zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on a change in pull request #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#discussion_r344608730 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/testtask

[GitHub] [flink] zhijiangW commented on issue #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.

zhijiangW commented on issue #10083: [FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs. URL: https://github.com/apache/flink/pull/10083#issuecomment-552350262 Thanks for the updates @wsry . I finished the third review and the core codes are almost good now,

[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : SUCCESS [Build](https://travis-ci.c

[GitHub] [flink] StephanEwen closed pull request #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests.

StephanEwen closed pull request #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests. URL: https://github.com/apache/flink/pull/10138 This is an automated message from the Apache Gi

[GitHub] [flink] StephanEwen commented on issue #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests.

StephanEwen commented on issue #10138: [FLINK-14635][e2e tests] Use non-relocated imports for AWS SDK Kinesis classes in tests. URL: https://github.com/apache/flink/pull/10138#issuecomment-552354648 Closing this PR, will try and open a new one with Thomas' suggestion. -

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344606608 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344613465 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344609071 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344612583 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344613503 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344612950 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344613145 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344611623 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344613038 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344613879 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344614320 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

danny0405 commented on a change in pull request #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#discussion_r344612353 ## File path: flink-table/flink-table-planner-blink/src/test/resources/org/apache/fli

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS [Build](https://travi

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 : S

[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : SUCCESS [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE [Build]

[GitHub] [flink] yanghua commented on issue #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList

yanghua commented on issue #10116: [FLINK-14655] Change Type of Field jobStatusListeners from CopyOnWriteArrayList to ArrayList URL: https://github.com/apache/flink/pull/10116#issuecomment-552362765 cc @GJL This is an automa

[jira] [Commented] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16971408#comment-16971408 ] Jingsong Lee commented on FLINK-14676: -- Hi [~jark], the parallelism of StreamTableS

[jira] [Updated] (FLINK-14701) Slot leaks if SharedSlotOversubscribedException happens

[ https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14701: Priority: Critical (was: Blocker) > Slot leaks if SharedSlotOversubscribedException happens > ---

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16971413#comment-16971413 ] Zhu Zhu commented on FLINK-14164: - I misunderstood the new problem. [~gjy] You are right

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS [Build](https://travi

[GitHub] [flink] xintongsong commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

xintongsong commented on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552369136 Travis passed: https://travis-ci.org/xintongsong/flink/builds/610209263 -

[GitHub] [flink] openinx commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

openinx commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#discussion_r344626330 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlC

[GitHub] [flink] openinx commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

openinx commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#discussion_r344630390 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/

[GitHub] [flink] openinx commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient

openinx commented on a change in pull request #9981: [FLINK-13195][sql-client] Add create table support for SqlClient URL: https://github.com/apache/flink/pull/9981#discussion_r344626540 ## File path: flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/

[GitHub] [flink] AT-Fieldless commented on a change in pull request #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

AT-Fieldless commented on a change in pull request #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#discussion_r344631801 ## File path: flink-runtime/src/test/java/org/apache/fl

[GitHub] [flink] aljoscha commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

aljoscha commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-552372061 @TisonKun there is this one: https://github.com/apache/flink/pull/9683 -

[GitHub] [flink] aljoscha commented on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

aljoscha commented on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970#issuecomment-552376170 Yes, I merged this now. :ok_hand: -

[jira] [Closed] (FLINK-14395) Refactor ES 7 connectors to make them keep consistency with es 6 connectors

[ https://issues.apache.org/jira/browse/FLINK-14395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-14395. Fix Version/s: 1.10.0 Resolution: Fixed Fixed on master in 5aa00fb875b3a941b92e8c0a

[GitHub] [flink] aljoscha closed pull request #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

aljoscha closed pull request #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970 This is an automated message from the Apache Git Se

[GitHub] [flink] aljoscha commented on a change in pull request #9946: [FLINK-14468][docs] Update Kubernetes docs

aljoscha commented on a change in pull request #9946: [FLINK-14468][docs] Update Kubernetes docs URL: https://github.com/apache/flink/pull/9946#discussion_r344637038 ## File path: docs/ops/deployment/kubernetes.md ## @@ -230,6 +240,8 @@ spec: volumeMounts:

[GitHub] [flink] flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector

flinkbot edited a comment on issue #10022: [FLINK-14135][hive][orc] Introduce orc ColumnarRow reader for hive connector URL: https://github.com/apache/flink/pull/10022#issuecomment-547278354 ## CI report: * 73e9fbb7c4edb8628b93e9a5b17271e57a8b8f14 : SUCCESS [Build](https://travi

[GitHub] [flink] lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r344632735 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connecto

[GitHub] [flink] lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r344632446 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connecto

[GitHub] [flink] lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r344640831 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/fi

[GitHub] [flink] lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r344031968 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connecto

[GitHub] [flink] lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r344639097 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/fi

[GitHub] [flink] lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

lirui-apache commented on a change in pull request #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#discussion_r344640190 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/fi

[GitHub] [flink] flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#issuecomment-549322411 ## CI report: * 4807c59ae20273d5b4611395ca5467217d7d0ca3 : FAILURE [

[jira] [Assigned] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young reassigned FLINK-14676: -- Assignee: Jingsong Lee > Introduce parallelism inference for InputFormatTableSource > ---

[GitHub] [flink] flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot edited a comment on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550973543 ## CI report: * fd65bc500b5539da9560f364ab6e8b1b71b2c1a8 : SUCCESS [Build](https://travis-ci.c

[jira] [Updated] (FLINK-14704) Remove uesless SynchronousSavepointLatch

[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-14704: - Fix Version/s: (was: 1.11.0) 1.10.0 > Remove uesless SynchronousSavepointLatch >

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE [Build]

[GitHub] [flink] flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull

flinkbot edited a comment on issue #10074: [FLINK-14499][Runtime / Metrics]MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull URL: https://github.com/apache/flink/pull/10074#issuecomment-549322411 ## CI report: * 4807c59ae20273d5b4611395ca5467217d7d0ca3 : FAILURE [

[GitHub] [flink] aljoscha closed pull request #10137: Update FlinkKafkaProducer.java

aljoscha closed pull request #10137: Update FlinkKafkaProducer.java URL: https://github.com/apache/flink/pull/10137 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] aljoscha commented on issue #10137: Update FlinkKafkaProducer.java

aljoscha commented on issue #10137: Update FlinkKafkaProducer.java URL: https://github.com/apache/flink/pull/10137#issuecomment-552393271 Thanks, I merged this! This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile

flinkbot edited a comment on issue #10146: [FLINK-14188][runtime] TaskExecutor derive and register with default slot resource profile URL: https://github.com/apache/flink/pull/10146#issuecomment-552307115 ## CI report: * 25f9e4b87846e5a736aa329c834f82962e1f50c4 : FAILURE [Build]

[GitHub] [flink] aljoscha merged pull request #10028: [hotfix] Fixed word typo: environment and refactored load savepoint exception message

aljoscha merged pull request #10028: [hotfix] Fixed word typo: environment and refactored load savepoint exception message URL: https://github.com/apache/flink/pull/10028 This is an automated message from the Apache Git Serv

[GitHub] [flink] aljoscha merged pull request #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction

aljoscha merged pull request #10040: [hotfix] Rename TimeReaderFunction to TimerReaderFunction URL: https://github.com/apache/flink/pull/10040 This is an automated message from the Apache Git Service. To respond to the messa

[GitHub] [flink] aljoscha merged pull request #10026: [hotfix][JavaDocs] Correct docs in MemoryStateBackend

aljoscha merged pull request #10026: [hotfix][JavaDocs] Correct docs in MemoryStateBackend URL: https://github.com/apache/flink/pull/10026 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16971446#comment-16971446 ] Gary Yao commented on FLINK-14164: -- Ok sounds good. > Add a metric to show failover co

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344660476 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[jira] [Commented] (FLINK-14704) Remove uesless SynchronousSavepointLatch

[ https://issues.apache.org/jira/browse/FLINK-14704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16971449#comment-16971449 ] Yun Tang commented on FLINK-14704: -- [~pnowojski], what do you think of this? please ass

[GitHub] [flink] GJL commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

GJL commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#discussion_r344663558 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executio

[GitHub] [flink] GJL commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

GJL commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#discussion_r344663665 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executio

[GitHub] [flink] GJL commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

GJL commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#discussion_r344663939 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/executio

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344663861 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/clu

[GitHub] [flink] yanghua commented on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context

yanghua commented on issue #10041: [hotfix] Fix wrong Java doc comment of BroadcastStateBootstrapFunction.Context URL: https://github.com/apache/flink/pull/10041#issuecomment-552401412 cc @aljoscha This is an automated messa

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344664368 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/clu

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344665359 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] link3280 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

link3280 commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-552403390 Thanks for the comments. The PR is updated. Thi

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344666748 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] yanghua commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

yanghua commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#discussion_r344667325 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[GitHub] [flink] flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink

flinkbot edited a comment on issue #9434: [FLINK-13634][Formats]: added module to compress data using StreamingFileSink URL: https://github.com/apache/flink/pull/9434#issuecomment-521185651 ## CI report: * 05d6f916b6c732f7d0f30f96bad6f7b31d078311 : FAILURE [Build](https://travis

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344667974 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResou

[GitHub] [flink] JingsongLi opened a new pull request #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource

JingsongLi opened a new pull request #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource URL: https://github.com/apache/flink/pull/10147 ## What is the purpose of the change FLINK-12801 has introduce parallelism setting for table,

[jira] [Updated] (FLINK-14676) Introduce parallelism inference for InputFormatTableSource

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

[GitHub] [flink] JingsongLi commented on issue #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner

JingsongLi commented on issue #10105: [Flink-14599][table-planner-blink] Support precision of TimestampType in blink planner URL: https://github.com/apache/flink/pull/10105#issuecomment-552406534 Thanks @docete , I will review this these two days. --

[GitHub] [flink] wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread

wangyang0918 commented on a change in pull request #10143: [FLINK-13184]Starting a TaskExecutor blocks the YarnResourceManager's main thread URL: https://github.com/apache/flink/pull/10143#discussion_r344669915 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClust

[GitHub] [flink] flinkbot commented on issue #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource

flinkbot commented on issue #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource URL: https://github.com/apache/flink/pull/10147#issuecomment-552407067 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[GitHub] [flink] yanghua commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

yanghua commented on a change in pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#discussion_r344670963 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[GitHub] [flink] flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot edited a comment on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : FAILURE [Build](htt

[jira] [Created] (FLINK-14705) Remove nullables argument of BatchTestBase.registerCollection in blink planner

Danny Chen created FLINK-14705: -- Summary: Remove nullables argument of BatchTestBase.registerCollection in blink planner Key: FLINK-14705 URL: https://issues.apache.org/jira/browse/FLINK-14705 Project: F

[GitHub] [flink] flinkbot commented on issue #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource

flinkbot commented on issue #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource URL: https://github.com/apache/flink/pull/10147#issuecomment-552413390 ## CI report: * e8aafaa3f2056a18ea3a8c2f9894657e97489b05 : UNKNOWN B

[GitHub] [flink] HuangXingBo opened a new pull request #10148: [FLINK-14693][hotfix][python] Python tox checks fails on travis

HuangXingBo opened a new pull request #10148: [FLINK-14693][hotfix][python] Python tox checks fails on travis URL: https://github.com/apache/flink/pull/10148 ## What is the purpose of the change *This pr fix the tox wrong installation* ## Brief change log - *repla

  1   2   3   4   >