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
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]
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
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
###
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
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
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
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
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
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]
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
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
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
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
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
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
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
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
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
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
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
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,
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
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
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.
-
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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]
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
[
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
[
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
> ---
[
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
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
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
-
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
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/
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/
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
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
-
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:
-
[
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
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
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:
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
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
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
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
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
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
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
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
[
[
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
> ---
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
[
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
>
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]
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
[
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
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
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]
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
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
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,
[
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
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
[
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
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
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
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
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
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
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
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
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
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
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
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
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
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,
[
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
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.
--
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
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
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
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
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
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
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 - 100 of 362 matches
Mail list logo