[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015258#comment-17015258 ] Till Rohrmann commented on FLINK-12122: --- At the moment, the behaviour you are describing is not

[GitHub] [flink] tillrohrmann commented on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

tillrohrmann commented on issue #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#issuecomment-574298374 Just another thought: Maybe one could add the prefix for suffix options as a non visible attribute to

[GitHub] [flink] tillrohrmann commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options

tillrohrmann commented on a change in pull request #10748: [FLINK-15458][conf][docs] Add support for whitelisting ambiguous options URL: https://github.com/apache/flink/pull/10748#discussion_r366484125 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

tillrohrmann commented on issue #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830#issuecomment-574294921 Sounds good to me. Thanks for looking into the changes so deeply.

[GitHub] [flink] tillrohrmann commented on a change in pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

tillrohrmann commented on a change in pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829#discussion_r366474018 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

tillrohrmann commented on a change in pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829#discussion_r366473104 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

tillrohrmann commented on a change in pull request #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829#discussion_r366472877 ## File path:

[GitHub] [flink] flinkbot commented on issue #10855: [FLINK-15587][container] Initial container for OpenShift.

flinkbot commented on issue #10855: [FLINK-15587][container] Initial container for OpenShift. URL: https://github.com/apache/flink/pull/10855#issuecomment-574290460 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574189442 ## CI report: * 8a356409214adf359c470c223bdfced819f7256a

[jira] [Updated] (FLINK-15587) Flink image does not run on OpenShift

[ https://issues.apache.org/jira/browse/FLINK-15587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15587: --- Labels: pull-request-available (was: ) > Flink image does not run on OpenShift >

[GitHub] [flink] abergmeier opened a new pull request #10855: [FLINK-15587][container] Initial container for OpenShift.

abergmeier opened a new pull request #10855: [FLINK-15587][container] Initial container for OpenShift. URL: https://github.com/apache/flink/pull/10855 ## What is the purpose of the change OpenShift needs a minimum set of file level rights to work. Thus use best-practise for

[GitHub] [flink] flinkbot edited a comment on issue #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

flinkbot edited a comment on issue #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#issuecomment-570453916 ## CI report: * 760a02385546fc92d8727c0643fd3dc3c1ca

[GitHub] [flink] BenoitHanotte commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

BenoitHanotte commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574277331 @flinkbot run travis

[GitHub] [flink] flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574091020 ## CI report: * 99fb99e8d24f04ecfe63c06456673ac78d28a118

[jira] [Created] (FLINK-15587) Flink image does not run on OpenShift

LCID Fire created FLINK-15587: - Summary: Flink image does not run on OpenShift Key: FLINK-15587 URL: https://issues.apache.org/jira/browse/FLINK-15587 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[GitHub] [flink] pnowojski commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

pnowojski commented on issue #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#issuecomment-574258190 I'm checking it again. Posted just a single comment as I had to interrupt the reviewing.

[GitHub] [flink] pnowojski commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages

pnowojski commented on a change in pull request #10332: [FLINK-13905][checkpointing] Separate checkpoint triggering into several asynchronous stages URL: https://github.com/apache/flink/pull/10332#discussion_r366429570 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[jira] [Commented] (FLINK-11899) Introduce vectorized parquet InputFormat for blink runtime

[ https://issues.apache.org/jira/browse/FLINK-11899?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015197#comment-17015197 ] Zhenqiu Huang commented on FLINK-11899: --- [~lzljs3620320] It looks like you already finished the

[GitHub] [flink] flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574091020 ## CI report: * 99fb99e8d24f04ecfe63c06456673ac78d28a118

[GitHub] [flink] flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574189442 ## CI report: * 8a356409214adf359c470c223bdfced819f7256a

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[jira] [Assigned] (FLINK-15278) Update StreamingFileSink documentation

[ https://issues.apache.org/jira/browse/FLINK-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-15278: -- Assignee: Kostas Kloudas > Update StreamingFileSink documentation >

[GitHub] [flink] TisonKun commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

TisonKun commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366406377 ## File path:

[GitHub] [flink] GJL commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e…

GJL commented on issue #10746: [FLINK-15417] Remove the docker volume or mount when starting Mesos e… URL: https://github.com/apache/flink/pull/10746#issuecomment-574229434 When we opened FLINK-15377, we discovered that that the mesos logs cannot be deleted due to permission problems

[GitHub] [flink] flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574189442 ## CI report: * 8a356409214adf359c470c223bdfced819f7256a

[GitHub] [flink] flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574091020 ## CI report: * 99fb99e8d24f04ecfe63c06456673ac78d28a118

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366394875 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[jira] [Commented] (FLINK-15581) SpillingResettableMutableObjectIterator data overflow

[ https://issues.apache.org/jira/browse/FLINK-15581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015141#comment-17015141 ] Piotr Nowojski commented on FLINK-15581: Yes, I've noticed that literally a minute after opening

[jira] [Commented] (FLINK-15575) Azure Filesystem Shades Wrong Package "httpcomponents"

[ https://issues.apache.org/jira/browse/FLINK-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015138#comment-17015138 ] Piotr Nowojski commented on FLINK-15575: [~knaufk] are you sure that it should be

[jira] [Comment Edited] (FLINK-15575) Azure Filesystem Shades Wrong Package "httpcomponents"

[ https://issues.apache.org/jira/browse/FLINK-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015138#comment-17015138 ] Piotr Nowojski edited comment on FLINK-15575 at 1/14/20 2:54 PM: -

[jira] [Closed] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-13590. Resolution: Duplicate > flink-on-yarn sometimes could create many little files that are >

[GitHub] [flink] flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

flinkbot edited a comment on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574189442 ## CI report: * 8a356409214adf359c470c223bdfced819f7256a

[GitHub] [flink] flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

flinkbot edited a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574091020 ## CI report: * 99fb99e8d24f04ecfe63c06456673ac78d28a118

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[GitHub] [flink] wangxlong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

wangxlong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#discussion_r366371055 ## File path:

[GitHub] [flink] wangxlong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

wangxlong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#discussion_r366370879 ## File path: flink-connectors/flink-jdbc/pom.xml ## @@ -54,6 +54,14 @@ under the

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366361654 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366360933 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366364492 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366360538 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366362475 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

tillrohrmann commented on a change in pull request #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#discussion_r366362147 ## File path:

[GitHub] [flink] StefanRRichter closed pull request #9170: [FLINK-13325][test] Add test to guard the fix for FLINK-13249

StefanRRichter closed pull request #9170: [FLINK-13325][test] Add test to guard the fix for FLINK-13249 URL: https://github.com/apache/flink/pull/9170 This is an automated message from the Apache Git Service. To respond to

[jira] [Created] (FLINK-15586) BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

Piotr Nowojski created FLINK-15586: -- Summary: BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem Key: FLINK-15586 URL: https://issues.apache.org/jira/browse/FLINK-15586

[GitHub] [flink] azagrebin commented on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

azagrebin commented on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574189913 Thanks for the reviews @tillrohrmann @xintongsong Indeed, now I also

[GitHub] [flink] flinkbot commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

flinkbot commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574189442 ## CI report: * 8a356409214adf359c470c223bdfced819f7256a UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11

flinkbot edited a comment on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11 URL: https://github.com/apache/flink/pull/10853#issuecomment-574146907 ## CI report: * 1e46fd22e65b11149a2a986900bd28ff13c83ade Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[jira] [Commented] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015098#comment-17015098 ] Benoit Hanotte commented on FLINK-15577: [~ykt836] I pushed the PR atr

[GitHub] [flink] flinkbot commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

flinkbot commented on issue #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854#issuecomment-574184703 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-15577) WindowAggregate RelNodes missing Window specs in digest

[ https://issues.apache.org/jira/browse/FLINK-15577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15577: --- Labels: pull-request-available (was: ) > WindowAggregate RelNodes missing Window specs in

[GitHub] [flink] BenoitHanotte opened a new pull request #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same

BenoitHanotte opened a new pull request #10854: [FLINK-15577][table-planner] Fix similar aggregations with different windows being considered the same URL: https://github.com/apache/flink/pull/10854 ## What is the purpose of the change The RelNode's digest is used by the Calcite

[jira] [Assigned] (FLINK-15575) Azure Filesystem Shades Wrong Package "httpcomponents"

[ https://issues.apache.org/jira/browse/FLINK-15575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-15575: Assignee: Konstantin Knauf > Azure Filesystem Shades Wrong Package "httpcomponents" >

[GitHub] [flink] flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs

flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs URL: https://github.com/apache/flink/pull/10850#issuecomment-574076308 ## CI report: * f902fd5c6cc693bac289427094b53d9e4274 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

flinkbot edited a comment on issue #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#issuecomment-573276729 ## CI report: * 5eb1599945f1bee35c342f762cc25684013d2d83 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis:

[GitHub] [flink] wuchong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

wuchong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#discussion_r366329915 ## File path: flink-connectors/flink-jdbc/pom.xml ## @@ -54,6 +54,14 @@ under the

[GitHub] [flink] wuchong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

wuchong commented on a change in pull request #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#discussion_r366329322 ## File path:

[jira] [Commented] (FLINK-15552) SQL Client can not correctly create kafka table using --library to indicate a kafka connector directory

[ https://issues.apache.org/jira/browse/FLINK-15552?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015072#comment-17015072 ] Jark Wu commented on FLINK-15552: - [~Leonard Xu] you can see

[jira] [Assigned] (FLINK-15585) Improve function identifier string in plan digest

[ https://issues.apache.org/jira/browse/FLINK-15585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-15585: --- Assignee: godfrey he > Improve function identifier string in plan digest >

[jira] [Created] (FLINK-15585) Improve function identifier string in plan digest

Jark Wu created FLINK-15585: --- Summary: Improve function identifier string in plan digest Key: FLINK-15585 URL: https://issues.apache.org/jira/browse/FLINK-15585 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11

flinkbot edited a comment on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11 URL: https://github.com/apache/flink/pull/10853#issuecomment-574146907 ## CI report: * 1e46fd22e65b11149a2a986900bd28ff13c83ade Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

flinkbot edited a comment on issue #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#issuecomment-570453916 ## CI report: * 760a02385546fc92d8727c0643fd3dc3c1ca

[jira] [Commented] (FLINK-15584) Give nested data type of ROWs in ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17015059#comment-17015059 ] Jingsong Lee commented on FLINK-15584: -- Thanks [~BenoitParis] for investigation. FLINK-15546 is a

[GitHub] [flink] flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs

flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs URL: https://github.com/apache/flink/pull/10850#issuecomment-574076308 ## CI report: * f902fd5c6cc693bac289427094b53d9e4274 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11

flinkbot commented on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11 URL: https://github.com/apache/flink/pull/10853#issuecomment-574146907 ## CI report: * 1e46fd22e65b11149a2a986900bd28ff13c83ade UNKNOWN Bot commands

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

flinkbot edited a comment on issue #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779#issuecomment-571250275 ## CI report: * b30a4d297496a904582cb24d036cbb4c5b647149 Travis:

[GitHub] [flink] xintongsong commented on issue #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible

xintongsong commented on issue #10829: [FLINK-14853][docs] Use higher granularity units in generated docs for Duration & MemorySize if possible URL: https://github.com/apache/flink/pull/10829#issuecomment-574142242 Thank you @dawidwys, It also sounds good to me that to print only the

[jira] [Updated] (FLINK-15584) Give nested data type of ROWs in ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15584: - Description: In  {code:java} INSERT INTO baz_sink SELECT   a, ROW(b, c) FROM foo_source{code}

[jira] [Updated] (FLINK-15584) Give nested data type of ROWs in ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15584: - Description: In  {code:java} INSERT INTO baz_sink SELECT   a, ROW(b, c) FROM foo_source{code}

[jira] [Updated] (FLINK-15584) Give nested data type of ROWs in ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15584: - Description: In  {code:java} INSERT INTO baz_sink SELECT   a, ROW(b, c) FROM foo_source{code}

[jira] [Updated] (FLINK-15584) Give nested data type of ROWs in ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15584: - Affects Version/s: 1.11.0 1.10.0 1.9.1 > Give

[jira] [Updated] (FLINK-15584) Give nested data type of ROWs in ValidationException

[ https://issues.apache.org/jira/browse/FLINK-15584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Benoît Paris updated FLINK-15584: - Priority: Minor (was: Major) > Give nested data type of ROWs in ValidationException >

[GitHub] [flink] flinkbot commented on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11

flinkbot commented on issue #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11 URL: https://github.com/apache/flink/pull/10853#issuecomment-574138585 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Created] (FLINK-15584) Give nested data type of ROWs in ValidationException

Benoît Paris created FLINK-15584: Summary: Give nested data type of ROWs in ValidationException Key: FLINK-15584 URL: https://issues.apache.org/jira/browse/FLINK-15584 Project: Flink Issue

[jira] [Assigned] (FLINK-15583) Scala walkthrough archetype does not compile on Java 11

[ https://issues.apache.org/jira/browse/FLINK-15583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-15583: -- Assignee: Arvid Heise > Scala walkthrough archetype does not compile on Java 11 >

[GitHub] [flink] AHeise opened a new pull request #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11

AHeise opened a new pull request #10853: [Flink-15583] Fixing scala walkthrough archetype does not compile on Java 11 URL: https://github.com/apache/flink/pull/10853 ## What is the purpose of the change This PR fixes scala walkthrough archetype does not compile on Java 11.

[GitHub] [flink] xintongsong removed a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

xintongsong removed a comment on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574133436 Found occurrences of "taskmanager.memory.shuffle.*" in

[GitHub] [flink] flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior

flinkbot edited a comment on issue #10852: [FLINK-15564][yarn][test] Fix YarnClusterDescriptorTest that failed to validate the original intended behavior URL: https://github.com/apache/flink/pull/10852#issuecomment-574107516 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs

flinkbot edited a comment on issue #10850: [FLINK-15519][configuration] Preserve logs from BashJavaUtils and make them part of TM logs URL: https://github.com/apache/flink/pull/10850#issuecomment-574076308 ## CI report: * f902fd5c6cc693bac289427094b53d9e4274 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml

flinkbot edited a comment on issue #10834: [FLINK-15530][dist] Replace process memory with flink memory for TMs in default flink-conf.yaml URL: https://github.com/apache/flink/pull/10834#issuecomment-573300994 ## CI report: * 78ce3aaf9f756bb27b20e1f51ff57d0ff4143b75 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource

flinkbot edited a comment on issue #10769: [FLINK-15479]Override explainSource method for JDBCTableSource URL: https://github.com/apache/flink/pull/10769#issuecomment-570920622 ## CI report: * 7fe9e7e4e4b53f839656fdb2b1a1079ec4de5b68 Travis:

[jira] [Comment Edited] (FLINK-13590) flink-on-yarn sometimes could create many little files that are xxx-taskmanager-conf.yaml

[ https://issues.apache.org/jira/browse/FLINK-13590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17014847#comment-17014847 ] Yang Wang edited comment on FLINK-13590 at 1/14/20 11:32 AM: - [~gjy] If we

[GitHub] [flink] flinkbot edited a comment on issue #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK

flinkbot edited a comment on issue #10754: [FLINK-14091][coordination] Allow updates to connection state when ZKCheckpointIDCounter reconnects to ZK URL: https://github.com/apache/flink/pull/10754#issuecomment-570453916 ## CI report: * 760a02385546fc92d8727c0643fd3dc3c1ca

[jira] [Updated] (FLINK-15174) FLINK security using PKI mutual auth needs certificate pinning or Private CA

[ https://issues.apache.org/jira/browse/FLINK-15174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-15174: - Fix Version/s: (was: 1.11.0) > FLINK security using PKI mutual auth needs certificate pinning or

[GitHub] [flink] xintongsong commented on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names

xintongsong commented on issue #10851: [FLINK-15517][Runtime][Configuration][Network] Use back 'network' in 'shuffle' memory config option names URL: https://github.com/apache/flink/pull/10851#issuecomment-574133436 Found occurrences of "taskmanager.memory.shuffle.*" in

<    1   2   3   4   >