[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

[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

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

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

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

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

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

[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

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

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

[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

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

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

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

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

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

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

[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

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

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

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

[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

[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

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

[GitHub] [flink] zjuwangg opened a new pull request #10149: [FLINK-14689]Add catalog related DDLs support in SQL Parser

zjuwangg opened a new pull request #10149: [FLINK-14689]Add catalog related DDLs support in SQL Parser URL: https://github.com/apache/flink/pull/10149 ## What is the purpose of the change * Add catalog related DDLs support in SQL Parser * - SHOW CATALOGS - DESCRIBE CATALOG

[jira] [Updated] (FLINK-14689) Add catalog related DDLs support in SQL Parser

[ https://issues.apache.org/jira/browse/FLINK-14689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14689: --- Labels: pull-request-available (was: ) > Add catalog related DDLs support in SQL Parser >

[GitHub] [flink] zjuwangg commented on issue #10149: [FLINK-14689]Add catalog related DDLs support in SQL Parser

zjuwangg commented on issue #10149: [FLINK-14689]Add catalog related DDLs support in SQL Parser URL: https://github.com/apache/flink/pull/10149#issuecomment-552423879 cc @xuefuz @bowenli86 @lirui-apache to have a review

[GitHub] [flink] zhuzhurk opened a new pull request #10150: [FLINK-14164][runtime] Make ‘fullRestarts’ compatible for NG scheduler

zhuzhurk opened a new pull request #10150: [FLINK-14164][runtime] Make ‘fullRestarts’ compatible for NG scheduler URL: https://github.com/apache/flink/pull/10150 ## What is the purpose of the change This PR is to make ‘fullRestarts’ compatible for NG scheduler. This is needed

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

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

[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

[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

[jira] [Updated] (FLINK-14693) python tox checks fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14693: --- Labels: pull-request-available (was: ) > python tox checks fails on travis >

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

[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

[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

[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=16971408#comment-16971408 ] Jingsong Lee commented on FLINK-14676: -- Hi [~jark], the parallelism of StreamTableSource need be

[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=16971413#comment-16971413 ] Zhu Zhu commented on FLINK-14164: - I misunderstood the new problem. [~gjy] You are right. We should also

[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

[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] 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-552420971 Can we put nanos of `SqlTimestamp` to the fixed-length part in `BinaryRow`? In this way:

[GitHub] [flink] flinkbot commented on issue #10148: [FLINK-14693][hotfix][python] Python tox checks fails on travis

flinkbot commented on issue #10148: [FLINK-14693][hotfix][python] Python tox checks fails on travis URL: https://github.com/apache/flink/pull/10148#issuecomment-552420959 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[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

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

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

[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

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

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

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

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

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

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

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

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

[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

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

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

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

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

[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

[GitHub] [flink] flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create…

flinkbot edited a comment on issue #10123: [FLINK-14665][table-planner-blink] Support computed column for create… URL: https://github.com/apache/flink/pull/10123#issuecomment-551369912 ## CI report: * 102bce9b12cb5853f0fe2b53ae4120434813d7c2 : CANCELED

[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

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

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

[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

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

[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

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

[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

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

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

[GitHub] [flink] flinkbot commented on issue #10149: [FLINK-14689]Add catalog related DDLs support in SQL Parser

flinkbot commented on issue #10149: [FLINK-14689]Add catalog related DDLs support in SQL Parser URL: https://github.com/apache/flink/pull/10149#issuecomment-552423186 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] GJL commented on a change in pull request #10150: [FLINK-14164][runtime] Make ‘fullRestarts’ compatible for NG scheduler

GJL commented on a change in pull request #10150: [FLINK-14164][runtime] Make ‘fullRestarts’ compatible for NG scheduler URL: https://github.com/apache/flink/pull/10150#discussion_r344691765 ## File path: docs/monitoring/metrics.md ## @@ -1253,7 +1253,7 @@ Metrics related

[GitHub] [flink] flinkbot commented on issue #10150: [FLINK-14164][runtime] Make ‘fullRestarts’ compatible for NG scheduler

flinkbot commented on issue #10150: [FLINK-14164][runtime] Make ‘fullRestarts’ compatible for NG scheduler URL: https://github.com/apache/flink/pull/10150#issuecomment-552428596 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#discussion_r344688121 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#discussion_r344685254 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn

pnowojski commented on a change in pull request #10084: [FLINK-14382][yarn] Incorrect handling of FLINK_PLUGINS_DIR on Yarn URL: https://github.com/apache/flink/pull/10084#discussion_r344683007 ## File path:

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

[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

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

[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

[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

[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=16971446#comment-16971446 ] Gary Yao commented on FLINK-14164: -- Ok sounds good. > Add a metric to show failover count regarding

[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

[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

[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

[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] flinkbot edited a comment on issue #10147: [FLINK-14676][table-planner-blink] Introduce parallelism inference for InputFormatTableSource

flinkbot edited a comment 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 : PENDING

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

  1   2   3   4   >