[GitHub] [flink] GJL commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

GJL commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333526806 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/

[GitHub] [flink] GJL commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

GJL commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333506554 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/

[GitHub] [flink] GJL commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states

GJL commented on a change in pull request #9860: [FLINK-14331][runtime] Reset vertices right after they transition to terminated states URL: https://github.com/apache/flink/pull/9860#discussion_r333521329 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/

[GitHub] [flink] zentol commented on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

zentol commented on issue #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#issuecomment-540595411 > Reporters relying on now deprecated methods have been updated, **except for the JMX, Prometheus and InfluxDB reporters as they s

[GitHub] [flink] KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r333526670 ## File path: flink-table/flink-table-planner/src/main/sca

[GitHub] [flink] KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r333526438 ## File path: flink-table/flink-table-planner/src/main/sca

[GitHub] [flink] KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r333528734 ## File path: flink-table/flink-table-planner/src/test/sca

[GitHub] [flink] KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on a change in pull request #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#discussion_r333526838 ## File path: flink-table/flink-table-planner/src/main/sca

[GitHub] [flink] 1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r333477936 ## File path: flink-metrics/flink-metrics-core/src/main/java/org/apache/flink/metrics/MetricScope.java #

[GitHub] [flink] 1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r333474919 ## File path: flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpR

[GitHub] [flink] 1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r333497964 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/InternalMetricScope.java ##

[GitHub] [flink] 1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope

1u0 commented on a change in pull request #9870: [FLINK-14350][metrics] Introduce dedicated MetricScope URL: https://github.com/apache/flink/pull/9870#discussion_r333497397 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/InternalMetricScope.java ##

[GitHub] [flink] flinkbot edited a comment on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure

flinkbot edited a comment on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure URL: https://github.com/apache/flink/pull/9879#issuecomment-540569165 ## CI report: * d16648043176579cbc934051984f

[GitHub] [flink] flinkbot edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

flinkbot edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-534506161 ## CI report: * 028ca1a6dd16e5f9ac8e7090d5583f5b9a724cb2 : SUCCESS [Build]

[GitHub] [flink] flinkbot commented on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure

flinkbot commented on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure URL: https://github.com/apache/flink/pull/9879#issuecomment-540569165 ## CI report: * d16648043176579cbc934051984fceb4fd3f

[GitHub] [flink] flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE [Build](https://travis

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE [Build](https://travis-

[jira] [Updated] (FLINK-14356) Introduce "single-field" format to (de)serialize message to a single field

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14356: Summary: Introduce "single-field" format to (de)serialize message to a single field (was: Support some sp

[GitHub] [flink] flinkbot edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

flinkbot edited a comment on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-534506161 ## CI report: * 028ca1a6dd16e5f9ac8e7090d5583f5b9a724cb2 : SUCCESS [Build]

[jira] [Commented] (FLINK-14356) Support some special RowDeserializationSchema and RowSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948557#comment-16948557 ] Jark Wu commented on FLINK-14356: - I'm also fine to call it {{single-value}}. [~hackergi

[GitHub] [flink] flinkbot commented on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure

flinkbot commented on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure URL: https://github.com/apache/flink/pull/9879#issuecomment-540555707 Thanks a lot for your contribution to the Apache Flink project.

[GitHub] [flink] pnowojski commented on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure

pnowojski commented on issue #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure URL: https://github.com/apache/flink/pull/9879#issuecomment-540555047 @aljoscha, do you think that it might be dangerous to make `

[GitHub] [flink] pnowojski opened a new pull request #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure

pnowojski opened a new pull request #9879: [FLINK-14300][runtime, test] Add test making sure that RecordWriter is properly closed in case of early StreamTask failure URL: https://github.com/apache/flink/pull/9879 This adds a missing test coverage for the previously merged https://github.c

[GitHub] [flink] flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

flinkbot edited a comment on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-539830457 ## CI report: * 5b6f4eb6008d7f2656fce8c2fbd7b43d7b8a0cf0 : FAILURE [Build](https://travis

[GitHub] [flink] wsry commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server.

wsry commented on issue #9758: [FLINK-14185][tests]Move unstable assertion statement out of close method of QS test server. URL: https://github.com/apache/flink/pull/9758#issuecomment-540551679 @zentol I have updated the pr according to your suggestion. Stats are not shared any more and a

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] HuangXingBo commented on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values

HuangXingBo commented on issue #9858: [FLINK-14208][python] Optimize Python UDFs with parameters of constant values URL: https://github.com/apache/flink/pull/9858#issuecomment-540542548 @dianfu Thanks for your review! I have addressed the comment in the latest commit. ---

[GitHub] [flink] flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540485113 ## CI report: * 868e6df849dceb88416e893aa168d5c649daf049 : SUCCESS [Build](https://travis-ci.com

[jira] [Commented] (FLINK-14355) Example code in state processor API docs doesn't compile

[ https://issues.apache.org/jira/browse/FLINK-14355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948508#comment-16948508 ] Timo Walther commented on FLINK-14355: -- CC [~sjwiesman] > Example code in state pr

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-524372146 ## CI report: * baae1632aabac35e6e08b402065857c4d67491f2 : FAILURE [

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese

KarmaGYZ commented on a change in pull request #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r333475021 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146 +25,138 @@ u

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese

KarmaGYZ commented on a change in pull request #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r333474608 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146 +25,138 @@ u

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese

KarmaGYZ commented on a change in pull request #9805: [FLINK-14227] translate dev/stream/state/checkpointing into Chinese URL: https://github.com/apache/flink/pull/9805#discussion_r333474818 ## File path: docs/dev/stream/state/checkpointing.zh.md ## @@ -25,146 +25,138 @@ u

[jira] [Assigned] (FLINK-14187) FLIP-56 Dynamic Slot Allocation

[ https://issues.apache.org/jira/browse/FLINK-14187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-14187: --- Assignee: Xintong Song > FLIP-56 Dynamic Slot Allocation >

[jira] [Assigned] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

[ https://issues.apache.org/jira/browse/FLINK-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-14189: --- Assignee: Xintong Song (was: Andrey Zagrebin) > Extend TaskExecutor to support dyn

[jira] [Assigned] (FLINK-14188) TaskExecutor derive and register with default slot resource profile

[ https://issues.apache.org/jira/browse/FLINK-14188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-14188: --- Assignee: Xintong Song > TaskExecutor derive and register with default slot resourc

[jira] [Assigned] (FLINK-14189) Extend TaskExecutor to support dynamic slot allocation

[ https://issues.apache.org/jira/browse/FLINK-14189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-14189: --- Assignee: Andrey Zagrebin > Extend TaskExecutor to support dynamic slot allocation

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948479#comment-16948479 ] Piotr Nowojski commented on FLINK-14306: Thanks [~hequn8128] and [~dianfu] for q

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] pnowojski commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

pnowojski commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r333470228 ## File path: flink-streaming-java/src/main/java/org/apache/f

[GitHub] [flink] flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests

flinkbot edited a comment on issue #9782: [FLINK-14241][test] Add ARM installation steps for flink e2e container tests URL: https://github.com/apache/flink/pull/9782#issuecomment-535826739 ## CI report: * d48b95539070679639d5e8c4e640b9a710d7 : FAILURE [Build](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540485113 ## CI report: * 868e6df849dceb88416e893aa168d5c649daf049 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FA

[GitHub] [flink] flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParam

flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-54030298

[GitHub] [flink] flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

flinkbot edited a comment on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-536416616 ## CI report: * 519051016f02b8257eb1e3d5834f36c315816266 : FAILURE [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FA

[GitHub] [flink] flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParam

flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-54030298

[GitHub] [flink] flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540485113 ## CI report: * 868e6df849dceb88416e893aa168d5c649daf049 : SUCCESS [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7 :

[GitHub] [flink] flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

flinkbot edited a comment on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-524372146 ## CI report: * baae1632aabac35e6e08b402065857c4d67491f2 : FAILURE [

[GitHub] [flink] zhijiangW commented on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

zhijiangW commented on issue #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#issuecomment-540512006 Thanks for the review @1u0 ! I have updated the codes for addressing the comment.

[jira] [Commented] (FLINK-14224) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948404#comment-16948404 ] Alex commented on FLINK-14224: -- I have difficulties to reproduce it on my local machine, ne

[jira] [Commented] (FLINK-14118) Reduce the unnecessary flushing when there is no data available for flush

[ https://issues.apache.org/jira/browse/FLINK-14118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948401#comment-16948401 ] Piotr Nowojski commented on FLINK-14118: Unfortunately the performance improveme

[jira] [Updated] (FLINK-14149) Introduce ZooKeeperLeaderElectionServiceNG

[ https://issues.apache.org/jira/browse/FLINK-14149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-14149: -- Description: Subsequent to the discussion in FLINK-10333, we reach a consensus that refactor ZK based

[GitHub] [flink] zhijiangW commented on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor

zhijiangW commented on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-540505424 Thanks for the further confirmation and pushing forward this work. I ag

[GitHub] [flink] twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlo

twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#discussion

[GitHub] [flink] twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlo

twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#discussion

[GitHub] [flink] twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlo

twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#discussion

[GitHub] [flink] twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlo

twalthr commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#discussion

[GitHub] [flink] flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor

flinkbot edited a comment on issue #9646: [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor URL: https://github.com/apache/flink/pull/9646#issuecomment-529229460 ## CI report: * 4f286e24aa0bb04d8e6cc81d64dc7e9ac642b012 : FA

[GitHub] [flink] flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParam

flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-54030298

[GitHub] [flink] flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841 ## CI report: * bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate

KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-540502058 @flinkbot run travis

[jira] [Created] (FLINK-14363) No need to cancel vertex when its version is outdated in scheduling (SchedulerNG)

Zhu Zhu created FLINK-14363: --- Summary: No need to cancel vertex when its version is outdated in scheduling (SchedulerNG) Key: FLINK-14363 URL: https://issues.apache.org/jira/browse/FLINK-14363 Project: Flin

[GitHub] [flink] flinkbot edited a comment on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs.

flinkbot edited a comment on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs. URL: https://github.com/apache/flink/pull/9877#issuecomment-540485056 ## CI report: * fdeaa9ae3a6e7f7f9ab22ca60d17bfae4cd24670 : FAILURE [Build](https://tr

[GitHub] [flink] flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot edited a comment on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540485113 ## CI report: * 868e6df849dceb88416e893aa168d5c649daf049 : PENDING [Build](https://travis-ci.com

[GitHub] [flink] flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParam

flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-54030298

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7 :

[GitHub] [flink] dianfu edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParamet

dianfu edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-540490737

[GitHub] [flink] dianfu commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) wh

dianfu commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-540490737

[jira] [Commented] (FLINK-14356) Support some special RowDeserializationSchema and RowSerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948355#comment-16948355 ] Timo Walther commented on FLINK-14356: -- +1 for this. It was also mentioned in some

[GitHub] [flink] flinkbot commented on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs.

flinkbot commented on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs. URL: https://github.com/apache/flink/pull/9877#issuecomment-540485056 ## CI report: * fdeaa9ae3a6e7f7f9ab22ca60d17bfae4cd24670 : UNKNOWN Bot commands

[GitHub] [flink] flinkbot commented on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot commented on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540485113 ## CI report: * 868e6df849dceb88416e893aa168d5c649daf049 : UNKNOWN Bot commands The @fli

[GitHub] [flink] flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParam

flinkbot edited a comment on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-54030298

[GitHub] [flink] flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841 ## CI report: * bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

flinkbot edited a comment on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-536253430 ## CI report: * 3b84408bb5ee764b1a64103b1f4df3e0ceacaba7 :

[GitHub] [flink] hequn8128 commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

hequn8128 commented on issue #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#issuecomment-540478877 Merging... This is an automated message from the

[GitHub] [flink] hequn8128 commented on a change in pull request #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

hequn8128 commented on a change in pull request #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#discussion_r333410587 ## File path: flink-python/pyflink/gen_protos.py ## @@ -120,10 +120,20 @@ def

[GitHub] [flink] hequn8128 commented on a change in pull request #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix

hequn8128 commented on a change in pull request #9851: [FLINK-14341]Fix flink-python builds failure: no such option: --prefix URL: https://github.com/apache/flink/pull/9851#discussion_r333410103 ## File path: flink-python/pyflink/gen_protos.py ## @@ -120,10 +120,20 @@ def

[jira] [Updated] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

[ https://issues.apache.org/jira/browse/FLINK-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shen Yinjie updated FLINK-14360: Component/s: Deployment / YARN > Flink on yarn should support obtain delegation tokens of multi hd

[GitHub] [flink] flinkbot commented on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

flinkbot commented on issue #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878#issuecomment-540478151 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[jira] [Updated] (FLINK-14149) Introduce ZooKeeperLeaderElectionServiceNG

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

[GitHub] [flink] TisonKun opened a new pull request #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG

TisonKun opened a new pull request #9878: [FLINK-14149][coordination] Implement ZooKeeperLeaderElectionServiceNG URL: https://github.com/apache/flink/pull/9878 ## What is the purpose of the change Based on [FLINK-10333](https://issues.apache.org/jira/browse/FLINK-10333), we reach a

[GitHub] [flink] KarmaGYZ commented on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs.

KarmaGYZ commented on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs. URL: https://github.com/apache/flink/pull/9877#issuecomment-540476373 Thanks for the contribution @asagjj . According to the [code contribution guide](https://flink.apach

[GitHub] [flink] WeiZhong94 commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters

WeiZhong94 commented on issue #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#issuecomment-540475679

[GitHub] [flink] WeiZhong94 commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#get

WeiZhong94 commented on a change in pull request #9874: [FLINK-14240][table] Merge table config parameters(TableConfig#getConfiguration) into global job parameters(ExecutionConfig#getGlobalJobParameters) when running with the legacy planner. URL: https://github.com/apache/flink/pull/9874#discuss

[GitHub] [flink] flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit

flinkbot edited a comment on issue #9876: [FLINK-14134][table] Introduce LimitableTableSource for optimizing limit URL: https://github.com/apache/flink/pull/9876#issuecomment-540462303 ## CI report: * 3eca02d54759452fdc285687c7aedbf2199a7b46 : FAILURE [Build](https://travis-ci.c

[GitHub] [flink] flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

flinkbot edited a comment on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-539919841 ## CI report: * bf1d566ea2f91d61c2f436bb92b5337088b7 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/

[GitHub] [flink] JingsongLi commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert

JingsongLi commented on issue #9796: [FLINK-14253][table-planner-blink] Add hash distribution and sort grouping only when dynamic partition insert URL: https://github.com/apache/flink/pull/9796#issuecomment-540474158 Thanks @docete for your review, updated.

[GitHub] [flink] flinkbot commented on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs.

flinkbot commented on issue #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs. URL: https://github.com/apache/flink/pull/9877#issuecomment-540473561 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-14360) Flink on yarn should support obtain delegation tokens of multi hdfs namespaces

[ https://issues.apache.org/jira/browse/FLINK-14360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14360: --- Labels: pull-request-available (was: ) > Flink on yarn should support obtain delegation tok

[GitHub] [flink] JingsongLi commented on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL

JingsongLi commented on issue #9802: [FLINK-13361][documention] Add documentation for JDBC connector for Table API & SQL URL: https://github.com/apache/flink/pull/9802#issuecomment-540472478 Thanks @wuchong for your review on HBase and JDBC documents. --

[GitHub] [flink] asagjj opened a new pull request #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs.

asagjj opened a new pull request #9877: [FLINK-14360][yarn] flink on yarn support obtain delegation token for multi hdfs. URL: https://github.com/apache/flink/pull/9877 ## What is the purpose of the change Provide a optional config ` cluster.fs-servers` to set a list of multi hdfs schem

[jira] [Created] (FLINK-14362) Change DefaultSchedulingResultPartition to return correct partition state

Zhu Zhu created FLINK-14362: --- Summary: Change DefaultSchedulingResultPartition to return correct partition state Key: FLINK-14362 URL: https://issues.apache.org/jira/browse/FLINK-14362 Project: Flink

[GitHub] [flink] 1u0 commented on a change in pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

1u0 commented on a change in pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#discussion_r97892 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[GitHub] [flink] 1u0 commented on a change in pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

1u0 commented on a change in pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#discussion_r329422367 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[GitHub] [flink] 1u0 commented on a change in pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes

1u0 commented on a change in pull request #9818: [FLINK-14289][runtime] Remove Optional fields from RecordWriter relevant classes URL: https://github.com/apache/flink/pull/9818#discussion_r329422968 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/

[GitHub] [flink] zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime, tests] Add test coverage to DefaultScheduler

zhuzhurk commented on a change in pull request #9872: [FLINK-14291][runtime,tests] Add test coverage to DefaultScheduler URL: https://github.com/apache/flink/pull/9872#discussion_r17197 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/TestExecutionSl

[GitHub] [flink] WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs.

WeiZhong94 commented on issue #9865: [FLINK-14212][python] Support no-argument Python UDFs. URL: https://github.com/apache/flink/pull/9865#issuecomment-540463353 @dianfu Thanks for your review! I have addressed the comment in the latest commit.

<    1   2   3   4   >