[GitHub] [flink] flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

flinkbot edited a comment on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-531697778 ## CI report: * ba87beba470b132b99ed606411ffc43847a72d8f : SUCCESS

[GitHub] [flink] flinkbot commented on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

flinkbot commented on issue #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712#issuecomment-532978281 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-13656) Upgrade Calcite dependency to 1.21

[ https://issues.apache.org/jira/browse/FLINK-13656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13656: --- Labels: pull-request-available (was: ) > Upgrade Calcite dependency to 1.21 >

[GitHub] [flink] liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-532977900 @aljoscha @TisonKun I find it's hard to make the classloader outside the packagedProgram, there are

[GitHub] [flink] danny0405 opened a new pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0

danny0405 opened a new pull request #9712: [FLINK-13656] [sql-parser][table-planner][table-planner-blink] Bump Calcite dependency to 1.21.0 URL: https://github.com/apache/flink/pull/9712 ### SQL Parser Some refactoring in flink-sql-parser ### Flink Planner -

[GitHub] [flink] flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster

flinkbot edited a comment on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678 ## CI report: * 2011905b5abe4cb332a60bc3f70378c777482924 : PENDING

[GitHub] [flink] flinkbot commented on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster

flinkbot commented on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711#issuecomment-532971678 ## CI report: * 2011905b5abe4cb332a60bc3f70378c777482924 : UNKNOWN

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933057#comment-16933057 ] Zhenqiu Huang commented on FLINK-14033: --- [~trohrmann][~fly_in_gis] Would you please take a look at

[GitHub] [flink] flinkbot commented on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster

flinkbot commented on issue #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711#issuecomment-532968944 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[jira] [Updated] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14033: --- Labels: pull-request-available (was: ) > Distributed caches are not registered in Yarn Per

[GitHub] [flink] HuangZhenQiu opened a new pull request #9711: [FLINK-14033] upload user artifacts for yarn job cluster

HuangZhenQiu opened a new pull request #9711: [FLINK-14033] upload user artifacts for yarn job cluster URL: https://github.com/apache/flink/pull/9711 ## What is the purpose of the change Upload user artifacts that registered in distributed caches for yarn job clusters. Currently,

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325990356 ## File path:

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

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

[GitHub] [flink] flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot edited a comment on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713 ## CI report: *

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325987134 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325986596 ## File path:

[GitHub] [flink] flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532961713 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

flinkbot commented on issue #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710#issuecomment-532959252 Thanks a lot for your contribution to the Apache Flink project.

[jira] [Updated] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

[ https://issues.apache.org/jira/browse/FLINK-11859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yingjie Cao updated FLINK-11859: Fix Version/s: 1.10.0 > Improve SpanningRecordSerializer performance by serializing record length

[jira] [Updated] (FLINK-11859) Improve SpanningRecordSerializer performance by serializing record length to serialization buffer directly

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

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

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

[GitHub] [flink] wsry opened a new pull request #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly.

wsry opened a new pull request #9710: [FLINK-11859][runtime]Improve SpanningRecordSerializer performance by serializing record length to data buffer directly. URL: https://github.com/apache/flink/pull/9710 ## What is the purpose of the change The purpose of this pr is to improve

[GitHub] [flink] gaoyunhaii commented on a change in pull request #9679: [hotfix] Fix the comments related to side output.

gaoyunhaii commented on a change in pull request #9679: [hotfix] Fix the comments related to side output. URL: https://github.com/apache/flink/pull/9679#discussion_r325982849 ## File path:

[GitHub] [flink] AT-Fieldless opened a new pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless opened a new pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350 ## What is the purpose of the change Translate "Table API Example Walkthrough" page

[GitHub] [flink] KarmaGYZ commented on a change in pull request #9679: [hotfix] Fix the comments related to side output.

KarmaGYZ commented on a change in pull request #9679: [hotfix] Fix the comments related to side output. URL: https://github.com/apache/flink/pull/9679#discussion_r325982247 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java

[GitHub] [flink] xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api

xuyang1706 commented on a change in pull request #9184: [FLINK-13339][ml] Add an implementation of pipeline's api URL: https://github.com/apache/flink/pull/9184#discussion_r325981768 ## File path:

[GitHub] [flink] carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

carp84 commented on a change in pull request #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#discussion_r325980641 ## File path:

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

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

[GitHub] [flink] liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/…

liupc commented on issue #9683: [FLINK-14037]Use same userCodeClassLoader as jobManager in jobClient to fix input/… URL: https://github.com/apache/flink/pull/9683#issuecomment-532955334 @TisonKun @aljoscha Thanks for reply, I will update as commented.

[GitHub] [flink] zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment

zzsmdfj commented on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-532953571 > Thanks for the hotfix, but IMO removed comment is not useless. > -1 for this pr. that comment is just meaning for "session windows

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

KurtYoung commented on issue #8468: [FLINK-12399][table][table-planner] Fix FilterableTableSource does not change after applyPredicate URL: https://github.com/apache/flink/pull/8468#issuecomment-532953494 Never mind, it's me didn't explain my thought clear enough.

[GitHub] [flink] KarmaGYZ commented on issue #9705: [hotfix][comment]remove useless comment

KarmaGYZ commented on issue #9705: [hotfix][comment]remove useless comment URL: https://github.com/apache/flink/pull/9705#issuecomment-532950384 Thanks for the hotfix, but IMO removed comment is not useless. -1 for this pr.

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933030#comment-16933030 ] TisonKun commented on FLINK-14010: -- [~trohrmann] Technically I agree that it is a valid solution. Give

[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=16933023#comment-16933023 ] Jark Wu commented on FLINK-14118: - Is it only affect to 1.9? Should we also fix this in 1.8 and 1.7

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933022#comment-16933022 ] TisonKun commented on FLINK-14112: -- I agree with [~trohrmann]'s comments. Another question I notice is

[GitHub] [flink] HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl

HuangZhenQiu commented on issue #9689: [FLINK-7151] add a basic function ddl URL: https://github.com/apache/flink/pull/9689#issuecomment-532946316 @suez1224 @fhueske @danny0405 Would you please take a look the PR? This is an

[GitHub] [flink] AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-532942135 > Hi @AT-Fieldless , do you have time to update this PR? Yes, I will create a

[GitHub] [flink] AT-Fieldless removed a comment on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless removed a comment on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-532941960 > Hi @AT-Fieldless , do you have time to update this PR?

[GitHub] [flink] AT-Fieldless closed pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless closed pull request #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350 This is an automated message from the

[GitHub] [flink] AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese

AT-Fieldless commented on issue #9350: [FLINK-13485] [chinese-translation] Translate "Table API Example Walkthrough" page into Chinese URL: https://github.com/apache/flink/pull/9350#issuecomment-532941960 > Hi @AT-Fieldless , do you have time to update this PR?

[jira] [Comment Edited] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933009#comment-16933009 ] Zijie Lu edited comment on FLINK-14099 at 9/19/19 2:44 AM: --- I have tried what

[jira] [Commented] (FLINK-14099) SQL supports timestamp in Long

[ https://issues.apache.org/jira/browse/FLINK-14099?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933009#comment-16933009 ] Zijie Lu commented on FLINK-14099: -- I have tried what you mentioned, but it seems that the timestamp

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

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

[jira] [Commented] (FLINK-14093) Java8 lambdas and exceptions lead to compile error

[ https://issues.apache.org/jira/browse/FLINK-14093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932996#comment-16932996 ] zzsmdfj commented on FLINK-14093: - [~Tison]  yes, you are right. I will start a discussion on dev

[jira] [Commented] (FLINK-14033) Distributed caches are not registered in Yarn Per Job Cluster Mode

[ https://issues.apache.org/jira/browse/FLINK-14033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932995#comment-16932995 ] Yang Wang commented on FLINK-14033: --- [~ZhenqiuHuang] Yeah, even many users are using -yt to distribute

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

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

[jira] [Updated] (FLINK-13993) Using FlinkUserCodeClassLoaders to load the user class in the perjob mode

[ https://issues.apache.org/jira/browse/FLINK-13993?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guowei Ma updated FLINK-13993: -- Remaining Estimate: 168h Original Estimate: 168h > Using FlinkUserCodeClassLoaders to load the

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325963191 ## File path:

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325963126 ## File path:

[jira] [Updated] (FLINK-14119) Clean idle state for RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14119: Affects Version/s: 1.9.0 > Clean idle state for RetractableTopNFunction >

[jira] [Commented] (FLINK-14119) Clean idle state for RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932988#comment-16932988 ] Jark Wu commented on FLINK-14119: - Yes. We need to cleanup the idle state in {{onTimer()}} callback,

[jira] [Assigned] (FLINK-14119) Clean idle state for RetractableTopNFunction

[ https://issues.apache.org/jira/browse/FLINK-14119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14119: --- Assignee: ALEC CHEN > Clean idle state for RetractableTopNFunction >

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325960076 ## File path:

[jira] [Commented] (FLINK-14038) ExecutionGraph deploy failed due to akka timeout

[ https://issues.apache.org/jira/browse/FLINK-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932982#comment-16932982 ] liupengcheng commented on FLINK-14038: -- [~zhuzh] [~trohrmann] This PR not only provide gc logs, but

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325958937 ## File path:

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325959037 ## File path:

[GitHub] [flink] docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of…

docete commented on a change in pull request #8706: [FLINK-12814][sql-client] Support a traditional and scrolling view of… URL: https://github.com/apache/flink/pull/8706#discussion_r325958597 ## File path:

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

Seth Wiesman created FLINK-14122: Summary: Extend State Processor API to read ListCheckpointed operator state Key: FLINK-14122 URL: https://issues.apache.org/jira/browse/FLINK-14122 Project: Flink

[GitHub] [flink] TisonKun commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics

TisonKun commented on issue #9684: [FLINK-13992][coordination] Refactor Optional parameter in InputGateWithMetrics#updateMetrics URL: https://github.com/apache/flink/pull/9684#issuecomment-532922137 ping @azagrebin as a reminder :-)

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932959#comment-16932959 ] TisonKun commented on FLINK-14109: -- [~bremac] aha, nice to hear :-) > Improve javadocs and tests for

[GitHub] [flink] tweise merged pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise merged pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708 This is an automated message from the Apache Git

[GitHub] [flink] tweise commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532910734 unrelated test failure This is an

[GitHub] [flink] tweise commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532910374 unrelated test failure This is an

[GitHub] [flink] tweise merged pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise merged pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709 This is an automated message from the Apache Git

[GitHub] [flink] flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597 ## CI report: * adf5d969d37c127653d77821bfa5fe48cf212a6d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619 ## CI report: * 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619 ## CI report: * 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597 ## CI report: * adf5d969d37c127653d77821bfa5fe48cf212a6d : PENDING

[GitHub] [flink] flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532891597 ## CI report: * adf5d969d37c127653d77821bfa5fe48cf212a6d : UNKNOWN

[GitHub] [flink] flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532891619 ## CI report: * 02a0e0ea41b1dc31f233ca4d25434b5370451d1a : UNKNOWN

[jira] [Resolved] (FLINK-14107) Kinesis consumer record emitter deadlock under event time alignment

[ https://issues.apache.org/jira/browse/FLINK-14107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved FLINK-14107. -- Fix Version/s: 1.10.0 Resolution: Fixed > Kinesis consumer record emitter deadlock

[GitHub] [flink] flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709#issuecomment-532888105 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] tweise opened a new pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise opened a new pull request #9709: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9709 backport from master This is an automated message

[GitHub] [flink] flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot commented on issue #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708#issuecomment-532887432 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] tweise opened a new pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise opened a new pull request #9708: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9708 backport from master This is an automated message

[GitHub] [flink] tweise merged pull request #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

tweise merged pull request #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932792#comment-16932792 ] Till Rohrmann commented on FLINK-14112: --- You are right Stephan. For leader election it should not

[jira] [Comment Edited] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932778#comment-16932778 ] Anatolii Siuniaev edited comment on FLINK-14120 at 9/18/19 8:10 PM:

[jira] [Commented] (FLINK-14120) SystemProcessingTimeServiceTest.testImmediateShutdown failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932778#comment-16932778 ] Anatolii Siuniaev commented on FLINK-14120: --- I'd like to look into this issue. Could you

[jira] [Comment Edited] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932737#comment-16932737 ] Jeffrey Martin edited comment on FLINK-14076 at 9/18/19 6:47 PM: - Two

[jira] [Comment Edited] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932737#comment-16932737 ] Jeffrey Martin edited comment on FLINK-14076 at 9/18/19 6:38 PM: - Two

[jira] [Commented] (FLINK-14076) 'ClassNotFoundException: KafkaException' on Flink v1.9 w/ checkpointing

[ https://issues.apache.org/jira/browse/FLINK-14076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932737#comment-16932737 ] Jeffrey Martin commented on FLINK-14076: Two steps to get the JobManager to stay up: # add

[jira] [Commented] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932735#comment-16932735 ] Brendan MacDonell commented on FLINK-14109: --- Thanks. I'll try to send an initial PR to address

[jira] [Updated] (FLINK-14109) Improve javadocs and tests for high-availability backend

[ https://issues.apache.org/jira/browse/FLINK-14109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brendan MacDonell updated FLINK-14109: -- Description: My team at Sight Machine just finished building a custom HA backend for

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932720#comment-16932720 ] Stephan Ewen commented on FLINK-14112: -- >From the RM / JM side (leader contender) can we treat the

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[jira] [Commented] (FLINK-14010) Dispatcher & JobManagers don't give up leadership when AM is shut down

[ https://issues.apache.org/jira/browse/FLINK-14010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932676#comment-16932676 ] Till Rohrmann commented on FLINK-14010: --- Can't we say that we always complete

[jira] [Commented] (FLINK-14110) Deleting state.backend.rocksdb.localdir causes silent failure

[ https://issues.apache.org/jira/browse/FLINK-14110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932672#comment-16932672 ] Aaron Levin commented on FLINK-14110: - [~carp84] [~klion26] I have not made a patch. I would be

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[jira] [Closed] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aaron Levin closed FLINK-14111. --- Resolution: Duplicate Closing in favour of: https://issues.apache.org/jira/browse/FLINK-10052 >

[jira] [Commented] (FLINK-14112) Removing zookeeper state should cause the task manager and job managers to restart

[ https://issues.apache.org/jira/browse/FLINK-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932660#comment-16932660 ] Aaron Levin commented on FLINK-14112: - [~Tison] [~till.rohrmann] thanks for responding so quickly! I

[jira] [Commented] (FLINK-14111) Flink should be robust to a non-leader Zookeeper host going down

[ https://issues.apache.org/jira/browse/FLINK-14111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932661#comment-16932661 ] Aaron Levin commented on FLINK-14111: - [~elevy] [~Tison] yes, duplicate! My apologies for the noise.

[GitHub] [flink] flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend

flinkbot edited a comment on issue #9501: [FLINK-12697] [State Backends] Support on-disk state storage for spill-able heap backend URL: https://github.com/apache/flink/pull/9501#issuecomment-523769032 ## CI report: * 6107a00876759dcef075592c8bfa56764f66b6fa : FAILURE

[jira] [Closed] (FLINK-14073) CalcITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-14073. - Resolution: Cannot Reproduce > CalcITCase failed on Travis > --- > >

[jira] [Commented] (FLINK-14073) CalcITCase failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-14073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932639#comment-16932639 ] Till Rohrmann commented on FLINK-14073: --- Then I would suggest to close the issue for the moment

[jira] [Commented] (FLINK-14074) MesosResourceManager can't create new taskmanagers in Session Cluster Mode.

[ https://issues.apache.org/jira/browse/FLINK-14074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932634#comment-16932634 ] Till Rohrmann commented on FLINK-14074: --- Thanks a lot for looking into the problem in more depth

[jira] [Commented] (FLINK-13746) Elasticsearch (v2.3.5) sink end-to-end test fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932637#comment-16932637 ] Till Rohrmann commented on FLINK-13746: --- Yes, this should work. Please also test whether it is

[GitHub] [flink] flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

flinkbot edited a comment on issue #9702: [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock URL: https://github.com/apache/flink/pull/9702#issuecomment-532344762 ## CI report: * b5d14cefce1ec689f991fcc0e02bb229195f4418 : SUCCESS

[jira] [Created] (FLINK-14121) upgrade tocommons-compress:1.19 due to CVE

John Lonergan created FLINK-14121: - Summary: upgrade tocommons-compress:1.19 due to CVE Key: FLINK-14121 URL: https://issues.apache.org/jira/browse/FLINK-14121 Project: Flink Issue Type:

  1   2   3   4   >