[
https://issues.apache.org/jira/browse/FLINK-13018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-13018:
Description:
Both {{build-docs.sh -i}} and {{build-docs.sh -p}} currently fail (also in the
docke
StefanRRichter commented on a change in pull request #8858: [hotfix][tests]
Change some StreamTask tests to create a test task in the task's thread
URL: https://github.com/apache/flink/pull/8858#discussion_r298187538
##
File path:
flink-streaming-java/src/test/java/org/apache/flink
afedulov commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r298187104
##
File path:
flink-connectors/flink-connector-gcp-pubsub/src
afedulov commented on a change in pull request #6594: [FLINK-9311] [pubsub]
Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#discussion_r298187104
##
File path:
flink-connectors/flink-connector-gcp-pubsub/src
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298180930
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298180130
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298179400
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTas
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298177791
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298176858
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/T
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298176939
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
###
StephanEwen commented on a change in pull request #8880: [FLINK-12986]
[network] Fix instability of BoundedBlockingSubpartition under memory pressure.
URL: https://github.com/apache/flink/pull/8880#discussion_r298173914
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298172674
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298171158
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298171158
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298171158
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298170569
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298170108
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
sjwiesman commented on a change in pull request #8903: [FLINK-12747][docs]
Getting Started - Table API Example Walkthrough
URL: https://github.com/apache/flink/pull/8903#discussion_r298169905
##
File path: pom.xml
##
@@ -82,11 +81,13 @@ under the License.
f
Andrey Zagrebin created FLINK-13019:
---
Summary: IT test for fine-grained recovery
Key: FLINK-13019
URL: https://issues.apache.org/jira/browse/FLINK-13019
Project: Flink
Issue Type: Sub-task
Nico Kruber created FLINK-13018:
---
Summary: Serving docs locally with jekyll fails with inotify limit
Key: FLINK-13018
URL: https://issues.apache.org/jira/browse/FLINK-13018
Project: Flink
Issue
wuchong commented on a change in pull request #8850: [FLINK-12954] Supports
create(drop) view grammar for sql parser
URL: https://github.com/apache/flink/pull/8850#discussion_r298160404
##
File path:
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCrea
wuchong commented on a change in pull request #8850: [FLINK-12954] Supports
create(drop) view grammar for sql parser
URL: https://github.com/apache/flink/pull/8850#discussion_r298130713
##
File path:
flink-table/flink-sql-parser/src/test/java/org/apache/flink/sql/parser/FlinkSqlPar
StefanRRichter commented on a change in pull request #8692: [FLINK-12804]
Introduce mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298162033
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTas
wuchong commented on a change in pull request #8850: [FLINK-12954] Supports
create(drop) view grammar for sql parser
URL: https://github.com/apache/flink/pull/8850#discussion_r298161597
##
File path:
flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl
##
lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build
to Travis
URL: https://github.com/apache/flink/pull/8911#issuecomment-506333942
cc @bowenli86 @xuefuz @zjuwangg
This is an automated message fro
lirui-apache commented on issue #8911: [FLINK-12995][hive] Add Hive-1.2.1 build
to Travis
URL: https://github.com/apache/flink/pull/8911#issuecomment-506333597
Here's [build
result](https://travis-ci.org/lirui-apache/flink/builds/551257514) of my own
repo. The connector_hive_1 failed as e
flinkbot commented on issue #8917: [FLINK-13017][docs] do not mount local $HOME
into docker
URL: https://github.com/apache/flink/pull/8917#issuecomment-506330683
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull r
NicoK opened a new pull request #8917: [FLINK-13017][docs] do not mount local
$HOME into docker
URL: https://github.com/apache/flink/pull/8917
## What is the purpose of the change
Remove the (writable!) mount of a user's $HOME into the dockerized
documentation build container in ord
[
https://issues.apache.org/jira/browse/FLINK-13017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13017:
---
Labels: pull-request-available (was: )
> Broken and irreproducible dockerized docs build
>
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298150038
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxE
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298146026
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298135855
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298130215
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
[
https://issues.apache.org/jira/browse/FLINK-13017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-13017:
Description:
The build tools around {{docs/docker}} seem broken and (on my machine) give
errors l
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298133778
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298148314
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298153219
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298125132
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
###
1u0 commented on a change in pull request #8692: [FLINK-12804] Introduce
mailbox-based ExecutorService
URL: https://github.com/apache/flink/pull/8692#discussion_r298128321
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProce
WeiZhong94 commented on issue #8910: [hotfix][python] Aligns with Java Table
API by removing methods exec_env and query_config
URL: https://github.com/apache/flink/pull/8910#issuecomment-506327614
LGTM, +1
This is an automate
flinkbot commented on issue #8916: [FLINK-12897][python][docs] Improve the
Python Table API docs by adding more examples
URL: https://github.com/apache/flink/pull/8916#issuecomment-506327371
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the commu
[
https://issues.apache.org/jira/browse/FLINK-12897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12897:
---
Labels: pull-request-available (was: )
> Improve the Python Table API docs by adding more e
flinkbot commented on issue #8915: [FLINK-13015][table-api-java] Create
validators, strategies and transformations required for porting logical
expressions
URL: https://github.com/apache/flink/pull/8915#issuecomment-506326938
Thanks a lot for your contribution to the Apache Flink project.
WeiZhong94 opened a new pull request #8916: [FLINK-12897][python][docs] Improve
the Python Table API docs by adding more examples
URL: https://github.com/apache/flink/pull/8916
## What is the purpose of the change
*This pull request add more Python Table API and relevant DataStream/D
[
https://issues.apache.org/jira/browse/FLINK-9728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-9728.
Resolution: Duplicate
> Wrong ruby version for building flink docs in docker container
> --
zentol merged pull request #8902: [hotfix][docs] fix wrong link in
streamfile_sink
URL: https://github.com/apache/flink/pull/8902
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/FLINK-13015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-13015:
---
Labels: pull-request-available (was: )
> Create validators, strategies and transformations
dawidwys opened a new pull request #8915: [FLINK-13015][table-api-java] Create
validators, strategies and transformations required for porting logical
expressions
URL: https://github.com/apache/flink/pull/8915
## What is the purpose of the change
Create validators, strategies and t
Nico Kruber created FLINK-13017:
---
Summary: Broken and irreproducible dockerized docs build
Key: FLINK-13017
URL: https://issues.apache.org/jira/browse/FLINK-13017
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-12980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-12980.
-
Resolution: Fixed
Fix Version/s: 1.9.0
Merged in master via e377bf669cb8a12fe9eec24123642
NicoK merged pull request #8873: [FLINK-12639] [docs] add "getting started"
section to documentation
URL: https://github.com/apache/flink/pull/8873
This is an automated message from the Apache Git Service.
To respond to the
sjwiesman commented on a change in pull request #8861:
[FLINK-12963][state-processor-api] Add savepoint writer for bootstrapping new
savepoints
URL: https://github.com/apache/flink/pull/8861#discussion_r298141523
##
File path:
flink-libraries/flink-state-processing-api/src/main/ja
NicoK commented on issue #8873: [FLINK-12639] [docs] add "getting started"
section to documentation
URL: https://github.com/apache/flink/pull/8873#issuecomment-506317642
@flinkbot approve all
This is an automated message from
sjwiesman commented on a change in pull request #8861:
[FLINK-12963][state-processor-api] Add savepoint writer for bootstrapping new
savepoints
URL: https://github.com/apache/flink/pull/8861#discussion_r298141103
##
File path:
flink-libraries/flink-state-processing-api/src/main/ja
azagrebin edited a comment on issue #8646: [FLINK-12735][network] Make shuffle
environment implementation independent with IOManager
URL: https://github.com/apache/flink/pull/8646#issuecomment-506313023
@StephanEwen Thanks for bringing this up.
As @zhijiangW already described, true,
azagrebin edited a comment on issue #8646: [FLINK-12735][network] Make shuffle
environment implementation independent with IOManager
URL: https://github.com/apache/flink/pull/8646#issuecomment-506313023
@StephanEwen Thanks for bringing this up.
As @zhijiangW already described, true,
azagrebin commented on issue #8646: [FLINK-12735][network] Make shuffle
environment implementation independent with IOManager
URL: https://github.com/apache/flink/pull/8646#issuecomment-506313023
@StephanEwen Thanks for bringing this up.
True, the idea was to drop `IOManager` depende
[
https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11662:
---
Labels: pull-request-available (was: )
> Discarded checkpoint can cause Tasks to fail
> ---
[
https://issues.apache.org/jira/browse/FLINK-11662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-11662.
--
Resolution: Fixed
Fix Version/s: 1.9.0
Merged in:
master: b760d55
> Discarded checkpoi
StefanRRichter merged pull request #8745: [FLINK-11662] Disable task to fail on
checkpoint errors
URL: https://github.com/apache/flink/pull/8745
This is an automated message from the Apache Git Service.
To respond to the mes
zhijiangW commented on issue #8646: [FLINK-12735][network] Make shuffle
environment implementation independent with IOManager
URL: https://github.com/apache/flink/pull/8646#issuecomment-506310994
@StephanEwen thanks for sharing the background and bringing this concern!
The abstract `
zhijiangW edited a comment on issue #8646: [FLINK-12735][network] Make shuffle
environment implementation independent with IOManager
URL: https://github.com/apache/flink/pull/8646#issuecomment-506310994
@StephanEwen thanks for sharing the background and bringing this concern!
The abs
Piotr Nowojski created FLINK-13016:
--
Summary: StreamTaskNetworkInput can linger records for longer
period of times
Key: FLINK-13016
URL: https://issues.apache.org/jira/browse/FLINK-13016
Project: Fli
flinkbot commented on issue #8914: [FLINK-12929] Pass TypeInformation in
addSource
URL: https://github.com/apache/flink/pull/8914#issuecomment-506309273
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull request. W
[
https://issues.apache.org/jira/browse/FLINK-12784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-12784.
-
Resolution: Fixed
Fix Version/s: 1.9.0
Merged in master via 0004056b494c42f5aa2b2cab5876e
[
https://issues.apache.org/jira/browse/FLINK-12929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12929:
---
Labels: pull-request-available (was: )
> scala.StreamExecutionEnvironment.addSource does no
lombarde opened a new pull request #8914: [FLINK-12929] Pass TypeInformation in
addSource
URL: https://github.com/apache/flink/pull/8914
Co-authored-by: Georg Rollinger
## What is the purpose of the change
Fixes https://issues.apache.org/jira/browse/FLINK-12929:
Ch
flinkbot commented on issue #8913: [FLINK-12968][table-common] Preparation for
more casting utilities
URL: https://github.com/apache/flink/pull/8913#issuecomment-506308460
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review y
NicoK merged pull request #8668: [FLINK-12784][metrics] Support retention
policy for InfluxDB metrics …
URL: https://github.com/apache/flink/pull/8668
This is an automated message from the Apache Git Service.
To respond to t
ifndef-SleePy edited a comment on issue #8870: [FLINK-12974][checkstyle] Bump
checkstyle to 8.14
URL: https://github.com/apache/flink/pull/8870#issuecomment-506306235
@hmcl You mean downgrade to an earlier version? I don't think it's a good
choice to use an older version. Because I believe
twalthr opened a new pull request #8913: [FLINK-12968][table-common]
Preparation for more casting utilities
URL: https://github.com/apache/flink/pull/8913
What is the purpose of the change
Adds some utilities for more casting utilities and fixes a bug.
## Brief change log
flinkbot commented on issue #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912#issuecomment-506306353
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I
ifndef-SleePy commented on issue #8870: [FLINK-12974][checkstyle] Bump
checkstyle to 8.14
URL: https://github.com/apache/flink/pull/8870#issuecomment-506306235
@hmcl You mean downgrade to an earlier version? I don't think it's a good
choice to use an older version. Because I believe 8.12 w
[
https://issues.apache.org/jira/browse/FLINK-12709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12709:
---
Labels: pull-request-available (was: )
> Implement RestartBackoffTimeStrategyFactoryLoader
zhuzhurk opened a new pull request #8912: [FLINK-12709] [runtime] Implement new
generation restart strategy loader which also respects legacy…
URL: https://github.com/apache/flink/pull/8912
… restart strategy configs
## What is the purpose of the change
*A loader is need to lo
asfgit closed pull request #8530: [FLINK-12611][table-planner-blink] Make time
indicator nullable in blink
URL: https://github.com/apache/flink/pull/8530
This is an automated message from the Apache Git Service.
To respond t
[
https://issues.apache.org/jira/browse/FLINK-12611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-12611.
---
Resolution: Fixed
Fix Version/s: 1.9.0
Fixed in 1.9.0: dac9f78658efda3339977e05591989cc363f3722
> Ma
Dawid Wysakowicz created FLINK-13015:
Summary: Create validators, strategies and transformations
required for porting logical expressions
Key: FLINK-13015
URL: https://issues.apache.org/jira/browse/FLINK-13015
[
https://issues.apache.org/jira/browse/FLINK-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-13014:
--
Description:
Log: [https://api.travis-ci.org/v3/job/551094138/log.txt]
07:12:52.246 [ERROR] Tests
Haibo Sun created FLINK-13014:
-
Summary: ChainBreakTest failed on Travis
Key: FLINK-13014
URL: https://issues.apache.org/jira/browse/FLINK-13014
Project: Flink
Issue Type: Bug
Reporte
StephanEwen commented on issue #8880: [FLINK-12986] [network] Fix instability
of BoundedBlockingSubpartition under memory pressure.
URL: https://github.com/apache/flink/pull/8880#issuecomment-506298639
@zhijiangW Thanks, these are very good comments. Some answers in line.
> Maybe we
[
https://issues.apache.org/jira/browse/FLINK-11774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873124#comment-16873124
]
Xulang Wan edited comment on FLINK-11774 at 6/27/19 10:55 AM:
[
https://issues.apache.org/jira/browse/FLINK-12996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-12996:
-
Affects Version/s: 1.9.0
> Add predefined type validators, strategies, and transformatio
[
https://issues.apache.org/jira/browse/FLINK-12996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz updated FLINK-12996:
-
Fix Version/s: 1.9.0
> Add predefined type validators, strategies, and transformations
>
mans2singh commented on a change in pull request #8668: [FLINK-12784][metrics]
Support retention policy for InfluxDB metrics …
URL: https://github.com/apache/flink/pull/8668#discussion_r298117923
##
File path:
flink-metrics/flink-metrics-influxdb/src/test/java/org/apache/flink/metr
[
https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873996#comment-16873996
]
Jark Wu edited comment on FLINK-12848 at 6/27/19 10:40 AM:
---
Th
StephanEwen commented on a change in pull request #8880: [FLINK-12986]
[network] Fix instability of BoundedBlockingSubpartition under memory pressure.
URL: https://github.com/apache/flink/pull/8880#discussion_r298114249
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
[
https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873996#comment-16873996
]
Jark Wu commented on FLINK-12848:
-
Thanks [~aloyszhang] for the debugging. So let's targ
StephanEwen commented on a change in pull request #8880: [FLINK-12986]
[network] Fix instability of BoundedBlockingSubpartition under memory pressure.
URL: https://github.com/apache/flink/pull/8880#discussion_r298113422
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
StephanEwen commented on a change in pull request #8880: [FLINK-12986]
[network] Fix instability of BoundedBlockingSubpartition under memory pressure.
URL: https://github.com/apache/flink/pull/8880#discussion_r298112193
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
StephanEwen commented on a change in pull request #8880: [FLINK-12986]
[network] Fix instability of BoundedBlockingSubpartition under memory pressure.
URL: https://github.com/apache/flink/pull/8880#discussion_r298111597
##
File path:
flink-runtime/src/main/java/org/apache/flink/run
[
https://issues.apache.org/jira/browse/FLINK-13004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873994#comment-16873994
]
Jark Wu commented on FLINK-13004:
-
[~yunta] (y)
> Correct the logic of needToCleanupSta
[
https://issues.apache.org/jira/browse/FLINK-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16873993#comment-16873993
]
Stephan Ewen commented on FLINK-12536:
--
Can you guys share why you believe this is
wuchong commented on a change in pull request #8909:
[FLINK-13004][table-runtime-blink] Correct the logic of needToCleanupState in
KeyedProcessFunctionWithCleanupState
URL: https://github.com/apache/flink/pull/8909#discussion_r298108636
##
File path:
flink-table/flink-table-runtim
zjuwangg commented on issue #8636: [FLINK-12237][hive]Support Hive table stats
related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8636#issuecomment-506284860
@bowenli86 Sorry a little late to update this pr, please review again when
you have time.
zjuwangg commented on issue #8636: [FLINK-12237][hive]Support Hive table stats
related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8636#issuecomment-506284600
rebase and force to push
This is an autom
StephanEwen commented on a change in pull request #8886: [FLINK-12987][metrics]
fix DescriptiveStatisticsHistogram#getCount() not returning the number of
elements seen
URL: https://github.com/apache/flink/pull/8886#discussion_r298101578
##
File path:
flink-runtime/src/main/java/or
[
https://issues.apache.org/jira/browse/FLINK-13013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-13013:
---
Description: Currently {{SingleInputGate}} requests partitions only on the
first attempt to
aljoscha commented on issue #8371: [FLINK-9679] - Add AvroSerializationSchema
URL: https://github.com/apache/flink/pull/8371#issuecomment-506282454
@Wosin could you please rebase and squash the various commits into some
commits that make sense, i.e. separate pre-requisites like version upgr
StephanEwen commented on issue #8877: [FLINK-12984][metrics] only call
Histogram#getStatistics() once where possible
URL: https://github.com/apache/flink/pull/8877#issuecomment-506281800
Looks good in general.
What is a bit strange is that the dropwizard metrics now have dependencies
201 - 300 of 372 matches
Mail list logo