[GitHub] [flink] zentol merged pull request #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2

zentol merged pull request #10830: [FLINK-15554][azure] Bump jetty-util to 3.1.2 URL: https://github.com/apache/flink/pull/10830 This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-15554) Bump jetty-util-ajax to 9.3.24

[ https://issues.apache.org/jira/browse/FLINK-15554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15554: --- Labels: pull-request-available (was: ) > Bump jetty-util-ajax to 9.3.24 > -

[jira] [Closed] (FLINK-15554) Bump jetty-util-ajax to 9.3.24

[ https://issues.apache.org/jira/browse/FLINK-15554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-15554. Resolution: Fixed master: a9411b7456a22ac7a658f45f2d11e23e5d2e94ce 1.10: 7c09f7084a93ad7e8

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] xintongsong commented on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

xintongsong commented on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574613727 Thanks for the review, @azagrebin. Comments addressed. -

[GitHub] [flink] xintongsong opened a new pull request #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure.

xintongsong opened a new pull request #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure. URL: https://github.com/apache/flink/pull/10863 ## What is the purpose of the change This PR removes memory validations and overwrites in Y

[jira] [Updated] (FLINK-15598) Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure.

[ https://issues.apache.org/jira/browse/FLINK-15598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-15598: --- Labels: pull-request-available (was: ) > Memory accuracy loss in YarnClusterDescriptor may

[GitHub] [flink] flinkbot commented on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure.

flinkbot commented on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure. URL: https://github.com/apache/flink/pull/10863#issuecomment-574617107 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[GitHub] [flink] flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink

flinkbot edited a comment on issue #10847: [FLINK-15578][connectors/jdbc] implement exactly once JDBC sink URL: https://github.com/apache/flink/pull/10847#issuecomment-573933799 ## CI report: * 1f19ab63df12c2a0cbc75644a34bcab26c08d7f6 Travis: [FAILURE](https://travis-ci.com/flin

[GitHub] [flink] flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574591065 ## CI report: * 5f9cd2224ef458e5068f3179aa5be025848f8723 Travis: [SUCCESS](https://t

[GitHub] [flink] flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574591161 ## CI report: * f4506ad0e9302a279940670fa90c305c240b3c12 Travis: [FAILURE](

[GitHub] [flink] flinkbot edited a comment on issue #10862: [FLINK-15597][runtime] Relax sanity check of JVM memory overhead to be within its min/max

flinkbot edited a comment on issue #10862: [FLINK-15597][runtime] Relax sanity check of JVM memory overhead to be within its min/max URL: https://github.com/apache/flink/pull/10862#issuecomment-574606585 ## CI report: * 9e5e952e448571968cca13475d221ce4a62689db Travis: [PENDING](

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r366830175 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r366830175 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r366830175 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[GitHub] [flink] yanghua opened a new pull request #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

yanghua opened a new pull request #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864 ## What is the purpose of the change *This pull request fixes doc typo for the java doc of MultiStateKeyIterato

[GitHub] [flink] curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

curcur commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r366830175 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/exec

[GitHub] [flink] flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

flinkbot edited a comment on issue #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#issuecomment-552442468 ## CI report: * c6d7f5e864076448dca590035a6a590dc5e25c

[GitHub] [flink] yanghua commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

yanghua commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864#issuecomment-574623219 cc @aljoscha This is an automated message fr

[GitHub] [flink] flinkbot commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

flinkbot commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864#issuecomment-574623622 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] GJL commented on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

GJL commented on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#issuecomment-574626118 I am fine with the name changes. This is an automated message

[GitHub] [flink] zhuzhurk commented on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy

zhuzhurk commented on issue #10848: [FLINK-15307][failover]Rename Subclasses of FailoverStrategy URL: https://github.com/apache/flink/pull/10848#issuecomment-574629419 Thanks for the feedback @GJL . Merging. This is an aut

[GitHub] [flink] flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector

flinkbot edited a comment on issue #10861: [FLINK-15558][Connector] Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7 connector URL: https://github.com/apache/flink/pull/10861#issuecomment-574591161 ## CI report: * f4506ad0e9302a279940670fa90c305c240b3c12 Travis: [FAILURE](

[GitHub] [flink] flinkbot commented on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure.

flinkbot commented on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure. URL: https://github.com/apache/flink/pull/10863#issuecomment-574631052 ## CI report: * cd199a2a3b3dba0c38c38df5db11278feabb544d UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574591065 ## CI report: * 5f9cd2224ef458e5068f3179aa5be025848f8723 Travis: [SUCCESS](https://t

[GitHub] [flink] flinkbot edited a comment on issue #10862: [FLINK-15597][runtime] Relax sanity check of JVM memory overhead to be within its min/max

flinkbot edited a comment on issue #10862: [FLINK-15597][runtime] Relax sanity check of JVM memory overhead to be within its min/max URL: https://github.com/apache/flink/pull/10862#issuecomment-574606585 ## CI report: * 9e5e952e448571968cca13475d221ce4a62689db Travis: [SUCCESS](

[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&focusedCommentId=17015892#comment-17015892 ] Xintong Song commented on FLINK-12122: -- [~trohrmann], Do you think the approach we

[GitHub] [flink] flinkbot commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

flinkbot commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864#issuecomment-574631141 ## CI report: * 7a949f5080dfb1a1727affbeffbc33864dd5f7d0 UNKNOWN Bot commands The @

[jira] [Comment Edited] (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&focusedCommentId=17015892#comment-17015892 ] Xintong Song edited comment on FLINK-12122 at 1/15/20 12:05 PM: --

[GitHub] [flink] zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions

zhuzhurk commented on a change in pull request #10832: [FLINK-14163][runtime]Enforce synchronous registration of Execution#producedPartitions URL: https://github.com/apache/flink/pull/10832#discussion_r366844097 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/ex

[jira] [Created] (FLINK-15601) Remove useless constant field NUM_STOP_CALL_TRIES in Execution

vinoyang created FLINK-15601: Summary: Remove useless constant field NUM_STOP_CALL_TRIES in Execution Key: FLINK-15601 URL: https://issues.apache.org/jira/browse/FLINK-15601 Project: Flink Issue

[jira] [Commented] (FLINK-15601) Remove useless constant field NUM_STOP_CALL_TRIES in Execution

[ https://issues.apache.org/jira/browse/FLINK-15601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015907#comment-17015907 ] vinoyang commented on FLINK-15601: -- [~trohrmann] WDYT? > Remove useless constant field

[GitHub] [flink] pnowojski merged pull request #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel.

pnowojski merged pull request #10779: [FLINK-15327][runtime] No warning of InterruptedException during cancel. URL: https://github.com/apache/flink/pull/10779 This is an automated message from the Apache Git Service. To resp

[jira] [Updated] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-15327: --- Affects Version/s: (was: 1.11.0) 1.10.0 > 'Walkthrough DataStream

[jira] [Commented] (FLINK-15573) Let Flink SQL PlannerExpressionParserImpl#FieldRefrence use Unicode as its default charset

[ https://issues.apache.org/jira/browse/FLINK-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015915#comment-17015915 ] Zili Chen commented on FLINK-15573: --- cc [~jark][~tiwalter] what do you think of this?

[GitHub] [flink] pnowojski closed pull request #10628: [FLINK-15327][walkthroughs] Replace InterruptedException by running flag

pnowojski closed pull request #10628: [FLINK-15327][walkthroughs] Replace InterruptedException by running flag URL: https://github.com/apache/flink/pull/10628 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] pnowojski commented on issue #10628: [FLINK-15327][walkthroughs] Replace InterruptedException by running flag

pnowojski commented on issue #10628: [FLINK-15327][walkthroughs] Replace InterruptedException by running flag URL: https://github.com/apache/flink/pull/10628#issuecomment-574638917 Superseded by https://github.com/apache/flink/pull/10779

[jira] [Closed] (FLINK-15327) 'Walkthrough DataStream Scala nightly' sometimes fails with InterruptedException

[ https://issues.apache.org/jira/browse/FLINK-15327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15327. -- Fix Version/s: 1.10.0 Assignee: Arvid Heise (was: Robert Metzger) Resolution:

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis: [FAILURE](https://travis-

[GitHub] [flink] flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49.

flinkbot edited a comment on issue #10860: [FLINK-15145][config] Change TM memory configuration default values for FLIP-49. URL: https://github.com/apache/flink/pull/10860#issuecomment-574591065 ## CI report: * 5f9cd2224ef458e5068f3179aa5be025848f8723 Travis: [SUCCESS](https://t

[GitHub] [flink] flinkbot edited a comment on issue #10862: [FLINK-15597][runtime] Relax sanity check of JVM memory overhead to be within its min/max

flinkbot edited a comment on issue #10862: [FLINK-15597][runtime] Relax sanity check of JVM memory overhead to be within its min/max URL: https://github.com/apache/flink/pull/10862#issuecomment-574606585 ## CI report: * 9e5e952e448571968cca13475d221ce4a62689db Travis: [SUCCESS](

[GitHub] [flink] flinkbot edited a comment on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure.

flinkbot edited a comment on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure. URL: https://github.com/apache/flink/pull/10863#issuecomment-574631052 ## CI report: * cd199a2a3b3dba0c38c38df5db11278feabb544d Travis: [P

[GitHub] [flink] flinkbot edited a comment on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

flinkbot edited a comment on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864#issuecomment-574631141 ## CI report: * 7a949f5080dfb1a1727affbeffbc33864dd5f7d0 Travis: [PENDING](https://travis-c

[GitHub] [flink] aljoscha merged pull request #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

aljoscha merged pull request #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864 This is an automated message from the Apache Git Service. To resp

[GitHub] [flink] aljoscha commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

aljoscha commented on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864#issuecomment-574644599 Thanks for taking the time to fix the typo!

[jira] [Created] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

Dawid Wysakowicz created FLINK-15602: Summary: Blink planner does not respect the precision when casting timestamp to varchar Key: FLINK-15602 URL: https://issues.apache.org/jira/browse/FLINK-15602

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

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015935#comment-17015935 ] Dawid Wysakowicz commented on FLINK-14505: -- Now it is caused by [FLINK-15602].

[jira] [Commented] (FLINK-14505) SQL Client end-to-end test for Kafka 0.10 nightly end-to-end test failed on travis

[ https://issues.apache.org/jira/browse/FLINK-14505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015936#comment-17015936 ] Dawid Wysakowicz commented on FLINK-14505: -- As a side note, I am not sure if re

[jira] [Commented] (FLINK-15602) Blink planner does not respect the precision when casting timestamp to varchar

[ https://issues.apache.org/jira/browse/FLINK-15602?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015940#comment-17015940 ] Dawid Wysakowicz commented on FLINK-15602: -- cc [~jark] [~docete] > Blink plann

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis: [FAILURE](https://travis-

[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: [FAILURE](https://travi

[jira] [Commented] (FLINK-15549) integer overflow in SpillingResettableMutableObjectIterator

[ https://issues.apache.org/jira/browse/FLINK-15549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17015944#comment-17015944 ] Piotr Nowojski commented on FLINK-15549: Yes, I can take care of reviewing/mergi

[GitHub] [flink] flinkbot edited a comment on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure.

flinkbot edited a comment on issue #10863: [FLINK-15598][yarn] Memory accuracy loss in YarnClusterDescriptor may lead to deployment failure. URL: https://github.com/apache/flink/pull/10863#issuecomment-574631052 ## CI report: * cd199a2a3b3dba0c38c38df5db11278feabb544d Travis: [S

[GitHub] [flink] flinkbot edited a comment on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest

flinkbot edited a comment on issue #10864: [hotfix][typo] Fix doc typo for the java doc of MultiStateKeyIteratorTest URL: https://github.com/apache/flink/pull/10864#issuecomment-574631141 ## CI report: * 7a949f5080dfb1a1727affbeffbc33864dd5f7d0 Travis: [CANCELED](https://travis-

[jira] [Created] (FLINK-15603) Show "barrier lag" in checkpoint statistics

Stephan Ewen created FLINK-15603: Summary: Show "barrier lag" in checkpoint statistics Key: FLINK-15603 URL: https://issues.apache.org/jira/browse/FLINK-15603 Project: Flink Issue Type: Impro

[jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policy's

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-11499: - Priority: Major (was: Minor) > Extend StreamingFileSink BulkFormats to support arbitrary roll p

[jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policy's

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-11499: - Labels: usability (was: ) > Extend StreamingFileSink BulkFormats to support arbitrary roll poli

[jira] [Closed] (FLINK-4464) Add docs about version upgrades

[ https://issues.apache.org/jira/browse/FLINK-4464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4464. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about version upgrades > --

[jira] [Updated] (FLINK-11499) Extend StreamingFileSink BulkFormats to support arbitrary roll policy's

[ https://issues.apache.org/jira/browse/FLINK-11499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-11499: - Fix Version/s: 1.11.0 > Extend StreamingFileSink BulkFormats to support arbitrary roll policy's

[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&focusedCommentId=17015958#comment-17015958 ] Piotr Nowojski commented on FLINK-15575: Thanks for the explanation. Yes, you ar

[jira] [Closed] (FLINK-4474) Add docs about Testing & Test Utilities

[ https://issues.apache.org/jira/browse/FLINK-4474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4474. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about Testing & Test Utilities > --

[jira] [Closed] (FLINK-4473) Add docs about end-to-end exactly once

[ https://issues.apache.org/jira/browse/FLINK-4473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4473. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about end-to-end exactly once > ---

[jira] [Closed] (FLINK-4475) Add docs about Debugging

[ https://issues.apache.org/jira/browse/FLINK-4475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4475. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about Debugging > > >

[jira] [Closed] (FLINK-4465) Add docs about system architecture

[ https://issues.apache.org/jira/browse/FLINK-4465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4465. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about system architecture > ---

[jira] [Closed] (FLINK-4467) Add docs about project structure

[ https://issues.apache.org/jira/browse/FLINK-4467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4467. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about project structure > -

[jira] [Closed] (FLINK-4470) Add docs about Failure and Recovery Model

[ https://issues.apache.org/jira/browse/FLINK-4470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4470. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about Failure and Recovery Model >

[jira] [Closed] (FLINK-4477) Add and consolidate existing docs about data types

[ https://issues.apache.org/jira/browse/FLINK-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4477. --- Resolution: Fixed Subsumed by FLIP-42 > Add and consolidate existing docs about data types > ---

[jira] [Closed] (FLINK-4468) Add docs about processing semantics

[ https://issues.apache.org/jira/browse/FLINK-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4468. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about processing semantics > --

[jira] [Closed] (FLINK-4476) Add docs about Tuning

[ https://issues.apache.org/jira/browse/FLINK-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4476. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about Tuning > - > >

[jira] [Closed] (FLINK-4472) Add docs about Security

[ https://issues.apache.org/jira/browse/FLINK-4472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4472. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about Security > --- > >

[jira] [Closed] (FLINK-4463) FLIP-3: Restructure Documentation

[ https://issues.apache.org/jira/browse/FLINK-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4463. --- Resolution: Fixed Subsumed by FLIP-42 > FLIP-3: Restructure Documentation >

[jira] [Updated] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-9407: Labels: pull-request-available usability (was: pull-request-available) > Support orc rolling sink

[jira] [Closed] (FLINK-4401) Add docs about ordering in streams

[ https://issues.apache.org/jira/browse/FLINK-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-4401. --- Resolution: Fixed Subsumed by FLIP-42 > Add docs about ordering in streams > ---

[jira] [Updated] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-9407: Fix Version/s: 1.11.0 > Support orc rolling sink writer > --- > >

[jira] [Assigned] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-9407: --- Assignee: (was: zhangminglei) > Support orc rolling sink writer > --

[GitHub] [flink] pnowojski commented on a change in pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed

pnowojski commented on a change in pull request #10824: [FLINK-15152][checkpointing] Restatrt CheckpointCoordinator if StopWithSavepoint failed URL: https://github.com/apache/flink/pull/10824#discussion_r366875446 ## File path: flink-tests/src/test/java/org/apache/flink/runtime/jo

[jira] [Closed] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-9407. --- Resolution: Incomplete > Support orc rolling sink writer > --- > >

[jira] [Reopened] (FLINK-9407) Support orc rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-9407: - > Support orc rolling sink writer > --- > > Key: FLINK-94

[jira] [Updated] (FLINK-15573) Let Flink SQL PlannerExpressionParserImpl#FieldRefrence use Unicode as its default charset

[ https://issues.apache.org/jira/browse/FLINK-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-15573: Description: Now I am talking about the `PlannerExpressionParserImpl`     For now  the fi

[jira] [Updated] (FLINK-15573) Let Flink SQL PlannerExpressionParserImpl#FieldRefrence use Unicode as its default charset

[ https://issues.apache.org/jira/browse/FLINK-15573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lsw_aka_laplace updated FLINK-15573: Attachment: image-2020-01-15-21-49-19-373.png > Let Flink SQL PlannerExpressionParserImpl#

[jira] [Assigned] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-11395: Assignee: (was: vinoyang) > Support for Avro StreamingFileSink >

[jira] [Updated] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-11395: - Labels: usability (was: ) > Support for Avro StreamingFileSink > --

[jira] [Updated] (FLINK-11395) Support for Avro StreamingFileSink

[ https://issues.apache.org/jira/browse/FLINK-11395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-11395: - Fix Version/s: 1.11.0 > Support for Avro StreamingFileSink > --

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5763: Fix Version/s: 1.11.0 > Make savepoints self-contained and relocatable > --

[jira] [Updated] (FLINK-5763) Make savepoints self-contained and relocatable

[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-5763: Labels: usability (was: ) > Make savepoints self-contained and relocatable > -

[jira] [Updated] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14942: - Labels: usability (was: ) > State Processing API: add an option to make deep copy > ---

[jira] [Updated] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14942: - Fix Version/s: 1.11.0 > State Processing API: add an option to make deep copy >

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

flinkbot edited a comment 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-573052559 ## CI report: * c289f16e336e54931105f5c3ec143f8a9fd69021 Trav

[jira] [Updated] (FLINK-14942) State Processing API: add an option to make deep copy

[ https://issues.apache.org/jira/browse/FLINK-14942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14942: - Affects Version/s: (was: 1.11.0) > State Processing API: add an option to make deep copy > -

[GitHub] [flink] flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist.

flinkbot edited a comment on issue #10845: [FLINK-15355][plugins]Classloader restricts access to parent to whitelist. URL: https://github.com/apache/flink/pull/10845#issuecomment-573736294 ## CI report: * 0942cb8b913ba50ecf8d7ca28832c4c92bf78e6c Travis: [FAILURE](https://travis-

[jira] [Updated] (FLINK-13095) Provide an easy way to read / bootstrap window state using the State Processor API

[ https://issues.apache.org/jira/browse/FLINK-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13095: - Fix Version/s: 1.11.0 > Provide an easy way to read / bootstrap window state using the State >

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14122: - Fix Version/s: 1.11.0 > Extend State Processor API to read ListCheckpointed operator state > ---

[jira] [Updated] (FLINK-13095) Provide an easy way to read / bootstrap window state using the State Processor API

[ https://issues.apache.org/jira/browse/FLINK-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-13095: - Labels: pull-request-available usability (was: pull-request-available) > Provide an easy way to

[jira] [Updated] (FLINK-14122) Extend State Processor API to read ListCheckpointed operator state

[ https://issues.apache.org/jira/browse/FLINK-14122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-14122: - Labels: usability (was: ) > Extend State Processor API to read ListCheckpointed operator state

[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: [FAILURE](https://travi

[jira] [Closed] (FLINK-13095) Provide an easy way to read / bootstrap window state using the State Processor API

[ https://issues.apache.org/jira/browse/FLINK-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13095. Resolution: Pending Closed > Provide an easy way to read / bootstrap window state using the State

[jira] [Reopened] (FLINK-13095) Provide an easy way to read / bootstrap window state using the State Processor API

[ https://issues.apache.org/jira/browse/FLINK-13095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reopened FLINK-13095: -- > Provide an easy way to read / bootstrap window state using the State > Processor API >

[GitHub] [flink] rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict

rkhachatryan commented on a change in pull request #10151: [FLINK-14231] Handle the pending processing-time timers to make endInput semantics on the operator chain strict URL: https://github.com/apache/flink/pull/10151#discussion_r366887139 ## File path: flink-streaming-java/src/m

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

AHeise 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-574672868 @flinkbot run travis This is an automated m

<    1   2   3   4   5   >