[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327147478 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections

tillrohrmann commented on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections URL: https://github.com/apache/flink/pull/9158#issuecomment-534127456 I'd prefer to split the version bump and the functional change into two PRs @lamber-ken.

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327150696 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED

[jira] [Updated] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

[ https://issues.apache.org/jira/browse/FLINK-14172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-14172: -- Parent: FLINK-9953 Issue Type: Sub-task (was: New Feature) > Implement KubeClient with

[GitHub] [flink] flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support

flinkbot edited a comment on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-533110106 ## CI report: * d9c1dd529ef235649909d067cc78099179656e62 : FAILURE

[jira] [Reopened] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reopened FLINK-12576: To reproduce, git clone --branch backpressure-with-2-TMs

[GitHub] [flink] flinkbot commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534140505 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483#issuecomment-522602263 ## CI report: * 5d079442de5815edf896b85fa7aa3ca599975bb0 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#issuecomment-533791202 ## CI report: * 511ae6ef82ec45f34e0270c4c534d64de2856107 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#issuecomment-533791202 ## CI report: * 511ae6ef82ec45f34e0270c4c534d64de2856107 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED

[jira] [Commented] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

[ https://issues.apache.org/jira/browse/FLINK-14170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935904#comment-16935904 ] John Lonergan commented on FLINK-14170: --- Yep it's unnecessarily restrictive and actually breaks

[GitHub] [flink] gaofeilong198810 opened a new pull request #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

gaofeilong198810 opened a new pull request #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749 ## What is the purpose of the change Translate DataStream Code Walkthrough to Chinese ## Brief

[GitHub] [flink] flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#issuecomment-533791202 ## CI report: * 511ae6ef82ec45f34e0270c4c534d64de2856107 : SUCCESS

[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=16935947#comment-16935947 ] Yingjie Cao commented on FLINK-14118: - [~pnowojski] You are right. High data skew can reproduce the

[GitHub] [flink] flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot edited a comment on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483#issuecomment-522602263 ## CI report: * 5d079442de5815edf896b85fa7aa3ca599975bb0 : FAILURE

[jira] [Created] (FLINK-14173) ANSI-style JOIN with Temporal Table Function fails

Benoît Paris created FLINK-14173: Summary: ANSI-style JOIN with Temporal Table Function fails Key: FLINK-14173 URL: https://issues.apache.org/jira/browse/FLINK-14173 Project: Flink Issue

[jira] [Updated] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese

[ https://issues.apache.org/jira/browse/FLINK-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14115: --- Labels: pull-request-available (was: ) > Translate DataStream Code Walkthrough to Chinese

[jira] [Commented] (FLINK-14115) Translate DataStream Code Walkthrough to Chinese

[ https://issues.apache.org/jira/browse/FLINK-14115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935942#comment-16935942 ] gaofeilong commented on FLINK-14115: Hi [~fhueske], I have done this work and made a PR. please have

[jira] [Comment Edited] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935937#comment-16935937 ] David Anderson edited comment on FLINK-12576 at 9/23/19 3:07 PM: - To

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327175478 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Comment Edited] (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=16935947#comment-16935947 ] Yingjie Cao edited comment on FLINK-14118 at 9/23/19 3:17 PM: -- [~pnowojski] 

[GitHub] [flink] flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-524181331 ## CI report: * 512499aae1ab33c5ae96c8a2100016e40d83b654 : CANCELED

[jira] [Resolved] (FLINK-14094) Fix OperatorIOMetricGroup repeat register problem

[ https://issues.apache.org/jira/browse/FLINK-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-14094. --- Resolution: Fixed Fixed via 627e7cb1f265e8cf8e953c17ee492ad957539f2f > Fix

[GitHub] [flink] tillrohrmann closed pull request #9697: [FLINK-14094] [runtime] [metric] Fix OperatorIOMetricGroup repeat register problem

tillrohrmann closed pull request #9697: [FLINK-14094] [runtime] [metric] Fix OperatorIOMetricGroup repeat register problem URL: https://github.com/apache/flink/pull/9697 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

flinkbot edited a comment on issue #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#issuecomment-529930381 ## CI report: * 5bfec29d38218b1bd5236163a7f2dd2571afa8b2 : CANCELED

[jira] [Updated] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson updated FLINK-12576: --- Affects Version/s: 1.9.0 > inputQueueLength metric does not work for LocalInputChannels >

[jira] [Comment Edited] (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=16935947#comment-16935947 ] Yingjie Cao edited comment on FLINK-14118 at 9/23/19 3:13 PM: -- [~pnowojski] 

[GitHub] [flink] AlecCh0402 commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

AlecCh0402 commented on a change in pull request #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#discussion_r327182330 ## File path:

[GitHub] [flink] Johnlon commented on a change in pull request #4663: [FLINK-6549] [DataStream API] Improve error message for type mismatches with side outputs

Johnlon commented on a change in pull request #4663: [FLINK-6549] [DataStream API] Improve error message for type mismatches with side outputs URL: https://github.com/apache/flink/pull/4663#discussion_r327226943 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS

[jira] [Created] (FLINK-14174) Don't swallow exception when rethrowing type mismatches with side outputs

John Lonergan created FLINK-14174: - Summary: Don't swallow exception when rethrowing type mismatches with side outputs Key: FLINK-14174 URL: https://issues.apache.org/jira/browse/FLINK-14174 Project:

[jira] [Created] (FLINK-14172) Implement KubeClient with official Java client library for kubernetes

Yang Wang created FLINK-14172: - Summary: Implement KubeClient with official Java client library for kubernetes Key: FLINK-14172 URL: https://issues.apache.org/jira/browse/FLINK-14172 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction

flinkbot edited a comment on issue #9741: [FLINK-14119][table] Clean idle state for RetractableTopNFunction URL: https://github.com/apache/flink/pull/9741#issuecomment-533791202 ## CI report: * 511ae6ef82ec45f34e0270c4c534d64de2856107 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

flinkbot edited a comment on issue #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#issuecomment-524181331 ## CI report: * 512499aae1ab33c5ae96c8a2100016e40d83b654 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus

flinkbot edited a comment on issue #9483: [FLINK-13767][task] Refactor StreamInputProcessor#processInput based on InputStatus URL: https://github.com/apache/flink/pull/9483#issuecomment-522602263 ## CI report: * 5d079442de5815edf896b85fa7aa3ca599975bb0 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli…

flinkbot edited a comment on issue #9468: [FLINK-13689] [Connectors/ElasticSearch] Fix thread leak when elasticsearch6 rest high level cli… URL: https://github.com/apache/flink/pull/9468#issuecomment-522106295 ## CI report: * 78654e8f80aa0b1a01654e7684f4610eb1d3aff4 : SUCCESS

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327145413 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java

[GitHub] [flink] lamber-ken commented on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections

lamber-ken commented on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections URL: https://github.com/apache/flink/pull/9158#issuecomment-534131656 > I'd prefer to split the version bump and the functional change into two PRs @lamber-ken. Hi,

[GitHub] [flink] lamber-ken closed pull request #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections

lamber-ken closed pull request #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections URL: https://github.com/apache/flink/pull/9158 This is an automated message from the Apache Git Service.

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327163946 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[jira] [Comment Edited] (FLINK-12576) inputQueueLength metric does not work for LocalInputChannels

[ https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935937#comment-16935937 ] David Anderson edited comment on FLINK-12576 at 9/23/19 2:58 PM: - To

[GitHub] [flink] lamber-ken edited a comment on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections

lamber-ken edited a comment on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections URL: https://github.com/apache/flink/pull/9158#issuecomment-534131656 > I'd prefer to split the version bump and the functional change into two PRs @lamber-ken.

[GitHub] [flink] lamber-ken opened a new pull request #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections

lamber-ken opened a new pull request #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections URL: https://github.com/apache/flink/pull/9158 ## What is the purpose of the change ### Desc The `ZooKeeperLeaderElectionService` uses the LeaderLatch Curator

[GitHub] [flink] lamber-ken edited a comment on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections

lamber-ken edited a comment on issue #9158: [FLINK-10052][coordination] Tolerate temporarily suspended ZooKeeper connections URL: https://github.com/apache/flink/pull/9158#issuecomment-534131656 > I'd prefer to split the version bump and the functional change into two PRs @lamber-ken.

[GitHub] [flink] flinkbot commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese

flinkbot commented on issue #9749: [FLINK-14115][docs-zh] Translate DataStream Code Walkthrough to Chinese URL: https://github.com/apache/flink/pull/9749#issuecomment-534149758 ## CI report: * 141eb6db531af4b12a9506489f280f180c02a408 : UNKNOWN

[jira] [Created] (FLINK-14166) Reuse cache from previous history server run

David Moravek created FLINK-14166: - Summary: Reuse cache from previous history server run Key: FLINK-14166 URL: https://issues.apache.org/jira/browse/FLINK-14166 Project: Flink Issue Type:

[GitHub] [flink] sunhaibotb edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

sunhaibotb edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11 URL: https://github.com/apache/flink/pull/9744#issuecomment-533994120 Can you review this PR for me @tillrohrmann @zentol ? Thanks.

[GitHub] [flink] zhuzhurk opened a new pull request #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

zhuzhurk opened a new pull request #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745 ## What is the purpose of the change *TimeUtils now can parse all duration configs supported by scala

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a :

[jira] [Created] (FLINK-14170) Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder

Bhagavan created FLINK-14170: Summary: Support hadoop < 2.7 with StreamingFileSink.BulkFormatBuilder Key: FLINK-14170 URL: https://issues.apache.org/jira/browse/FLINK-14170 Project: Flink Issue

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327055566 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DeploymentHandle.java

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327057723 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r327057591 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327062898 ## File path:

[GitHub] [flink] flinkbot commented on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

flinkbot commented on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11 URL: https://github.com/apache/flink/pull/9744#issuecomment-533988291 ## CI report: * 8210403a33cf3a6908980378fae9ee8d567afdb1 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors

flinkbot edited a comment on issue #9743: [hotfix][coordination] Wait for completion of MiniCluster#terminateExecutors URL: https://github.com/apache/flink/pull/9743#issuecomment-533978420 ## CI report: * 0ff3661a4946c47acc4ea362a869b9885e5712b6 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager

flinkbot edited a comment on issue #9742: [FLINK-14076] Ensure CheckpointException can always be deserialized on JobManager URL: https://github.com/apache/flink/pull/9742#issuecomment-533957111 ## CI report: * b1c025876fff8d6c7807e55613aabefef891ed59 : CANCELED

[GitHub] [flink] gyfora commented on issue #9727: [FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint

gyfora commented on issue #9727: [FLINK-14145] Fix getLatestCheckpoint(true) returns wrong checkpoint URL: https://github.com/apache/flink/pull/9727#issuecomment-53399 If no objections I will merge this later today :)

[GitHub] [flink] flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11 URL: https://github.com/apache/flink/pull/9744#issuecomment-533988291 ## CI report: * 8210403a33cf3a6908980378fae9ee8d567afdb1 : PENDING

[jira] [Commented] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935625#comment-16935625 ] Wei Zhong commented on FLINK-14167: --- I'd be glad to take this Jira and create PR for it. ;)

[jira] [Assigned] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14167: --- Assignee: Wei Zhong > Move python-related scripts in flink-dist to flink-python >

[GitHub] [flink] flinkbot commented on issue #9746: [FLINK-14167][python] Move python-related scripts in flink-dist to flink-python.

flinkbot commented on issue #9746: [FLINK-14167][python] Move python-related scripts in flink-dist to flink-python. URL: https://github.com/apache/flink/pull/9746#issuecomment-534027994 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14167: --- Labels: pull-request-available (was: ) > Move python-related scripts in flink-dist to

[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935691#comment-16935691 ] Zhu Zhu commented on FLINK-14164: - [~wind_ljy] Thanks for offering to do this. I think this requires

[jira] [Created] (FLINK-14168) Remove unused BootstrapTools#generateTaskManagerConfiguration

Zhu Zhu created FLINK-14168: --- Summary: Remove unused BootstrapTools#generateTaskManagerConfiguration Key: FLINK-14168 URL: https://issues.apache.org/jira/browse/FLINK-14168 Project: Flink Issue

[jira] [Commented] (FLINK-14098) Support multiple statements for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935715#comment-16935715 ] Jark Wu commented on FLINK-14098: - Yes. You are right. [~felixzheng] > Support multiple statements for

[GitHub] [flink] flinkbot edited a comment on issue #9746: [FLINK-14167][python] Move python-related scripts in flink-dist to flink-python.

flinkbot edited a comment on issue #9746: [FLINK-14167][python] Move python-related scripts in flink-dist to flink-python. URL: https://github.com/apache/flink/pull/9746#issuecomment-534031921 ## CI report: * dd8bee73f70747407778136f85914b5d21001d1f : FAILURE

[GitHub] [flink] AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327062516 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327062444 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327062031 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a :

[GitHub] [flink] flinkbot commented on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot commented on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534004353 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot edited a comment on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534005398 ## CI report: * d4ab076561b7d4d88347d55a1764d2a6d57507c3 : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a :

[jira] [Commented] (FLINK-13734) Support DDL in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-13734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935694#comment-16935694 ] Canbin Zheng commented on FLINK-13734: -- +1 for this feature, seems to be a subtask of

[jira] [Closed] (FLINK-13864) StreamingFileSink: Allow inherited classes to extend StreamingFileSink correctly

[ https://issues.apache.org/jira/browse/FLINK-13864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas closed FLINK-13864. -- Fix Version/s: 1.10.0 Assignee: Ying Xu Resolution: Fixed Merged on master

[GitHub] [flink] kl0u closed pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

kl0u closed pull request #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581 This is an

[GitHub] [flink] kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink

kl0u commented on issue #9581: [FLINK-13864][streaming]: Modify the StreamingFileSink Builder interface to allow for easier subclassing of StreamingFileSink URL: https://github.com/apache/flink/pull/9581#issuecomment-534029845 Merged

[GitHub] [flink-playgrounds] asfgit closed pull request #4: [FLINK-14160] Add --backpressure option to the ops playground

asfgit closed pull request #4: [FLINK-14160] Add --backpressure option to the ops playground URL: https://github.com/apache/flink-playgrounds/pull/4 This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-14169) Cleanup expired jobs from history server

[ https://issues.apache.org/jira/browse/FLINK-14169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935722#comment-16935722 ] David Moravek commented on FLINK-14169: --- Can you please assign this to [~david.hrbacek]? We have

[GitHub] [flink] aljoscha commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support

aljoscha commented on issue #9720: [FLINK-13025] Elasticsearch 7.x support URL: https://github.com/apache/flink/pull/9720#issuecomment-534041797 I had a cursory glance at this. The code seems fine, because it's basically the ES 6 code. I have some general comments: - I don't think

[GitHub] [flink] pnowojski merged pull request #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

pnowojski merged pull request #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478 This is an automated message from

[GitHub] [flink] pnowojski commented on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext

pnowojski commented on issue #9478: [FLINK-13766][task] Refactor the implementation of StreamInputProcessor based on StreamTaskInput#emitNext URL: https://github.com/apache/flink/pull/9478#issuecomment-534046669 Benchmark request shown some potential regressions in pure network

[GitHub] [flink] flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions

flinkbot edited a comment on issue #9707: [FLINK-14015][python] Introduces PythonScalarFunctionOperator to execute Python user-defined functions URL: https://github.com/apache/flink/pull/9707#issuecomment-532703153 ## CI report: * 4709beb04e69d94956ce9a823553efd67fefb29a :

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326977860 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

zhuzhurk commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326982305 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java

[GitHub] [flink] flinkbot commented on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime

flinkbot commented on issue #9745: [FLINK-14070] [runtime] Use TimeUtils to parse duration configs in flink-runtime URL: https://github.com/apache/flink/pull/9745#issuecomment-534005398 ## CI report: * d4ab076561b7d4d88347d55a1764d2a6d57507c3 : UNKNOWN

[GitHub] [flink] flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11

flinkbot edited a comment on issue #9744: [FLINK-13515][test] Fix ClassLoaderITCase fails on Java 11 URL: https://github.com/apache/flink/pull/9744#issuecomment-533988291 ## CI report: * 8210403a33cf3a6908980378fae9ee8d567afdb1 : SUCCESS

[GitHub] [flink] GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub

GJL commented on a change in pull request #9663: [WIP][FLINK-12433][runtime] Implement DefaultScheduler stub URL: https://github.com/apache/flink/pull/9663#discussion_r326999686 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java

[GitHub] [flink] WeiZhong94 opened a new pull request #9746: [FLINK-14167][python] Move python-related scripts in flink-dist to flink-python.

WeiZhong94 opened a new pull request #9746: [FLINK-14167][python] Move python-related scripts in flink-dist to flink-python. URL: https://github.com/apache/flink/pull/9746 ## What is the purpose of the change *This pull request moves python-related scripts in flink-dist to

[jira] [Updated] (FLINK-14098) Support multiple statements for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14098: - Summary: Support multiple statements for TableEnvironment (was: Support multiple statements

[jira] [Updated] (FLINK-14098) Support multiple statements splitting for TableEnvironment

[ https://issues.apache.org/jira/browse/FLINK-14098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-14098: - Summary: Support multiple statements splitting for TableEnvironment (was: Support multiple sql

[jira] [Comment Edited] (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=16935713#comment-16935713 ] Piotr Nowojski edited comment on FLINK-14118 at 9/23/19 10:06 AM: -- Yes,

[GitHub] [flink] AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode

AHeise commented on a change in pull request #7713: [FLINK-10995][runtime] Copy intermediate serialization results only once for broadcast mode URL: https://github.com/apache/flink/pull/7713#discussion_r327059906 ## File path:

[jira] [Created] (FLINK-14165) HadoopRecoverableWriter do not support viewfs scheme

haoyuwen created FLINK-14165: Summary: HadoopRecoverableWriter do not support viewfs scheme Key: FLINK-14165 URL: https://issues.apache.org/jira/browse/FLINK-14165 Project: Flink Issue Type: Bug

  1   2   3   4   >