[GitHub] [flink] 1u0 commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

1u0 commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r309700136 ## File path:

[jira] [Assigned] (FLINK-13537) Changing Kafka producer pool size and scaling out may create overlapping transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-13537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13537: Assignee: (was: Jiangjie Qin) > Changing Kafka producer pool size and scaling out

[jira] [Updated] (FLINK-13537) Changing Kafka producer pool size and scaling out may create overlapping transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-13537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber updated FLINK-13537: Description: The Kafka producer's transaction IDs are only generated once when there was no

[jira] [Closed] (FLINK-10315) Let JDBCAppendTableSink be built with java.sql.Connection

[ https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] François Lacombe closed FLINK-10315. Resolution: Not A Problem See [~yanghua] explanation in comments, makes things clear and

[jira] [Updated] (FLINK-6571) InfiniteSource in SourceStreamOperatorTest should deal with InterruptedExceptions

[ https://issues.apache.org/jira/browse/FLINK-6571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6571: Fix Version/s: (was: 1.9.0) 1.10.0 > InfiniteSource in

[jira] [Commented] (FLINK-10315) Let JDBCAppendTableSink be built with java.sql.Connection

[ https://issues.apache.org/jira/browse/FLINK-10315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898092#comment-16898092 ] François Lacombe commented on FLINK-10315: -- Thank you [~yanghua] to make this clear to me. I

[jira] [Created] (FLINK-13537) Changing Kafka producer pool size and scaling out may create overlapping transaction IDs

Nico Kruber created FLINK-13537: --- Summary: Changing Kafka producer pool size and scaling out may create overlapping transaction IDs Key: FLINK-13537 URL: https://issues.apache.org/jira/browse/FLINK-13537

[jira] [Commented] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898091#comment-16898091 ] Jingsong Lee commented on FLINK-13534: -- you can try rebase the PR of 

[GitHub] [flink] flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT cas

flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-516364194 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517175361 ## CI report: * bf81288dc40cf5a3bee5ece840d21821ea903135 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

flinkbot edited a comment on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-515055909 ## CI report: * f3f92f7d9e74ae453502900b8efa80014f8dfc6f : FAILURE

[jira] [Resolved] (FLINK-13326) Support asynchronous writing to raw operator (and raw keyed) state

[ https://issues.apache.org/jira/browse/FLINK-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-13326. -- Resolution: Fixed Fixed in - 1.9.0 via c676eb42f151854b4e734f39e2d82565eda144b6 - master

[jira] [Closed] (FLINK-13326) Support asynchronous writing to raw operator (and raw keyed) state

[ https://issues.apache.org/jira/browse/FLINK-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-13326. > Support asynchronous writing to raw operator (and raw keyed) state >

[GitHub] [flink] carp84 commented on a change in pull request #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hb

carp84 commented on a change in pull request #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#discussion_r309693737 ## File path:

[GitHub] [flink] eskabetxe commented on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

eskabetxe commented on issue #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#issuecomment-517286099 @kl0u I've updated the PR. Please take a look and say if you are ok with it.

[jira] [Created] (FLINK-13536) Improve nullability handling in Types

François Lacombe created FLINK-13536: Summary: Improve nullability handling in Types Key: FLINK-13536 URL: https://issues.apache.org/jira/browse/FLINK-13536 Project: Flink Issue Type:

[GitHub] [flink] flinkbot edited a comment on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

flinkbot edited a comment on issue #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#issuecomment-511183558 ## CI report: * 25fc95f30720209e19bd010cdd517ff5e3c685d8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen

flinkbot edited a comment on issue #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen URL: https://github.com/apache/flink/pull/8886#issuecomment-517193351 ## CI report: * 33a116dc1d23b9f423385240859bf9b0b72822b1 :

[jira] [Updated] (FLINK-13457) Setup travis cron builds for Java 11

[ https://issues.apache.org/jira/browse/FLINK-13457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13457: - Description: Setup Jdk 11 cron builds, including updates to the dockerized tests to run

[GitHub] [flink] flinkbot edited a comment on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children

flinkbot edited a comment on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children URL: https://github.com/apache/flink/pull/9288#issuecomment-516728840 ## CI report: * 09b5fe381383979e6d7726d5ba54898d1e34282e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517175361 ## CI report: * bf81288dc40cf5a3bee5ece840d21821ea903135 : FAILURE

[GitHub] [flink] JingsongLi commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

JingsongLi commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-517280547 Maybe there are some stories why start cluster and shutdown cluster so quick in travis when

[jira] [Commented] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898069#comment-16898069 ] Rui Li commented on FLINK-13534: It seems in {{BatchTableSourceScan.translateToPlan}} the produced type

[jira] [Updated] (FLINK-13374) Scala compiler causes StackOverflowError

[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13374: - Summary: Scala compiler causes StackOverflowError (was: flink-table-planner-blink

[jira] [Closed] (FLINK-13374) flink-table-planner-blink compile failed for scala-2.12 on travis

[ https://issues.apache.org/jira/browse/FLINK-13374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13374. Resolution: Fixed master: 1dd64058985afd44cae6a5119c4843b2dd85873d 1.9:

[jira] [Commented] (FLINK-13525) Improve Expression validation test

[ https://issues.apache.org/jira/browse/FLINK-13525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898067#comment-16898067 ] Jark Wu commented on FLINK-13525: - Sure. > Improve Expression validation test >

[GitHub] [flink] flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT cas

flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-516364194 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible

flinkbot edited a comment on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible URL: https://github.com/apache/flink/pull/8877#issuecomment-517190869 ## CI report: * f183d69a6ba8fbd3b9bb3c5474b392950811dfa8 : FAILURE

[GitHub] [flink] tillrohrmann commented on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children

tillrohrmann commented on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children URL: https://github.com/apache/flink/pull/9288#issuecomment-517276870 I've updated the PR @zhuzhurk. Please take a look and say if you are ok with it.

[GitHub] [flink] zentol merged pull request #9315: [FLINK-13374][scala][build] Set -Xss2m when compiling scala

zentol merged pull request #9315: [FLINK-13374][scala][build] Set -Xss2m when compiling scala URL: https://github.com/apache/flink/pull/9315 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] TsReaper commented on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

TsReaper commented on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517275636 Oops. After modifying the default value of limit some plan validation tests failed. Let me fix it.

[GitHub] [flink] TsReaper commented on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

TsReaper commented on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517274394 > Very nice PR @TsReaper. I just had minor comments. One question that I have is how do we ensure that the result

[GitHub] [flink] sunjincheng121 commented on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner)

sunjincheng121 commented on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322#issuecomment-517273947 @flinkbot attention @JingsongLi @wuchong @aljoscha @hequn8128 I appreciate if you can have look

[GitHub] [flink] wuchong commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

wuchong commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-517273605 Thanks @zentol . @JingsongLi could you prepare another pull request with only enabling

[GitHub] [flink] flinkbot commented on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner)

flinkbot commented on issue #9322: [FLINK-13471][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322#issuecomment-517273321 ## CI report: * e3d5e780a11ddd27ab6721772925db730d95c75c : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9296: [FLINK-13476][coordination] Release pipelined partitions on vertex restart / job failure

flinkbot edited a comment on issue #9296: [FLINK-13476][coordination] Release pipelined partitions on vertex restart / job failure URL: https://github.com/apache/flink/pull/9296#issuecomment-516833551 ## CI report: * 53b55b57bf8f8359987bc775b91e650661924b7a : FAILURE

[GitHub] [flink] kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#discussion_r309677978 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#discussion_r309676818 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#discussion_r309676496 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#discussion_r309676438 ## File path:

[jira] [Comment Edited] (FLINK-12847) Update Kinesis Connectors to latest Apache licensed libraries

[ https://issues.apache.org/jira/browse/FLINK-12847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896847#comment-16896847 ] Dyana Rose edited comment on FLINK-12847 at 8/1/19 12:42 PM: - I've just seen

[GitHub] [flink] wuchong commented on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case

wuchong commented on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-517270220 As discussed with @twalthr , we would like

[GitHub] [flink] flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions

flinkbot edited a comment on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions URL: https://github.com/apache/flink/pull/9250#issuecomment-515772917 ## CI report: * 4e15048a256b338df18ad8f9d89e0a576ae06a27 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT cas

flinkbot edited a comment on issue #9275: [FLINK-13290][table-planner-blink][hbase] SinkCodeGenerator should not compare row type field names and enable blink planner for hbase IT case URL: https://github.com/apache/flink/pull/9275#issuecomment-516364194 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #9322: [Flink-13473][table] Add FlatAggregate support to stream Table API(blink planner)

flinkbot commented on issue #9322: [Flink-13473][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322#issuecomment-517269188 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Created] (FLINK-13535) Do not abort transactions twice during KafkaProducer startup

Nico Kruber created FLINK-13535: --- Summary: Do not abort transactions twice during KafkaProducer startup Key: FLINK-13535 URL: https://issues.apache.org/jira/browse/FLINK-13535 Project: Flink

[GitHub] [flink] sunjincheng121 opened a new pull request #9322: [Flink-13473][table] Add FlatAggregate support to stream Table API(blink planner)

sunjincheng121 opened a new pull request #9322: [Flink-13473][table] Add FlatAggregate support to stream Table API(blink planner) URL: https://github.com/apache/flink/pull/9322 ## What is the purpose of the change This pull request ports non-window flatAggregate from Flink planner to

[GitHub] [flink] kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#discussion_r309673362 ## File path:

[GitHub] [flink] kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable

kl0u commented on a change in pull request #9228: [FLINK-13428][Connectors / FileSystem] allow part file names to be configurable URL: https://github.com/apache/flink/pull/9228#discussion_r309673143 ## File path:

[jira] [Closed] (FLINK-13454) Bump japicmp jaxb dependencies

[ https://issues.apache.org/jira/browse/FLINK-13454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-13454. Resolution: Fixed Fix Version/s: 1.10.0 master:

[jira] [Updated] (FLINK-13454) Bump japicmp jaxb dependencies

[ https://issues.apache.org/jira/browse/FLINK-13454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13454: - Affects Version/s: (was: 1.10.0) > Bump japicmp jaxb dependencies >

[GitHub] [flink] zentol merged pull request #9295: [FLINK-13454][build] Bump japicmp jaxb dependencies

zentol merged pull request #9295: [FLINK-13454][build] Bump japicmp jaxb dependencies URL: https://github.com/apache/flink/pull/9295 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

flinkbot edited a comment on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#issuecomment-515390325 ## CI report: * 1135cc72f00606c7a230714838c938068887ce23

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-13534: --- Component/s: Connectors / Hive > Unable to query Hive table with decimal column >

[GitHub] [flink] flinkbot commented on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

flinkbot commented on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-517266286 ## CI report: * 8738fc7248be508edcf3e1c0dcea6578f7b35a7e : PENDING

[GitHub] [flink] flinkbot edited a comment on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value

flinkbot edited a comment on issue #9285: [FLINK-13433][table-planner-blink] Do not fetch data from LookupableTableSource if the JoinKey in left side of LookupJoin contains null value. URL: https://github.com/apache/flink/pull/9285#issuecomment-516712727 ## CI report: *

[jira] [Created] (FLINK-13534) Unable to query Hive table with decimal column

Rui Li created FLINK-13534: -- Summary: Unable to query Hive table with decimal column Key: FLINK-13534 URL: https://issues.apache.org/jira/browse/FLINK-13534 Project: Flink Issue Type: Bug

[GitHub] [flink] zentol commented on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions

zentol commented on issue #9250: [FLINK-13371][coordination] Prevent leaks of blocking partitions URL: https://github.com/apache/flink/pull/9250#issuecomment-517264916 @azagrebin I've rebased the PR. This is an automated

[GitHub] [flink] zentol commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

zentol commented on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-517264150 Well in any case we would be enabling it for the blink planner; be it by enabling fork reuse of

[GitHub] [flink] tillrohrmann edited a comment on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children

tillrohrmann edited a comment on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children URL: https://github.com/apache/flink/pull/9288#issuecomment-517262657 Thanks a lot @zhuzhurk. I think with your test case I was able to understand

[GitHub] [flink] zentol commented on a change in pull request #9178: Typo in `scala_api_quickstart.md`

zentol commented on a change in pull request #9178: Typo in `scala_api_quickstart.md` URL: https://github.com/apache/flink/pull/9178#discussion_r309668230 ## File path: docs/dev/projectsetup/scala_api_quickstart.md ## @@ -217,7 +217,7 @@ take a look at the [Stream

[GitHub] [flink] flinkbot edited a comment on issue #9301: [FLINK-13469][state] Ensure resource used by StateMapSnapshot will be…

flinkbot edited a comment on issue #9301: [FLINK-13469][state] Ensure resource used by StateMapSnapshot will be… URL: https://github.com/apache/flink/pull/9301#issuecomment-516855887 ## CI report: * dae038f150dbe42e451e9a42f5a6a060b162a5ef : FAILURE

[GitHub] [flink] tillrohrmann commented on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children

tillrohrmann commented on issue #9288: [FLINK-13421] [runtime] Do not allocate slots in a MultiTaskSlot when it’s releasing children URL: https://github.com/apache/flink/pull/9288#issuecomment-517262657 Thanks a lot @zhuzhurk. I think with your test case I was able to understand the

[GitHub] [flink] flinkbot commented on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

flinkbot commented on issue #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321#issuecomment-517261794 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-13486) AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis

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

[jira] [Assigned] (FLINK-13486) AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-13486: Assignee: Biao Liu > AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction

[GitHub] [flink] ifndef-SleePy opened a new pull request #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the …

ifndef-SleePy opened a new pull request #9321: [FLINK-13486][tests] Optimize AsyncDataStreamITCase to alleviate the … URL: https://github.com/apache/flink/pull/9321 …pain of timeout ## What is the purpose of the change * Alleviate the timeout problem of

[jira] [Comment Edited] (FLINK-13493) BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty

[ https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998 ] zhijiang edited comment on FLINK-13493 at 8/1/19 12:10 PM: --- Thanks for the

[jira] [Commented] (FLINK-13486) AsyncDataStreamITCase.testOrderedWaitUsingAnonymousFunction instable on Travis

[ https://issues.apache.org/jira/browse/FLINK-13486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898026#comment-16898026 ] Biao Liu commented on FLINK-13486: -- Hi [~tzulitai], I believe this issue is not caused by FLINK-13491.

[jira] [Comment Edited] (FLINK-13493) BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty

[ https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998 ] zhijiang edited comment on FLINK-13493 at 8/1/19 12:09 PM: --- Thanks for the

[jira] [Updated] (FLINK-13533) CassandraConnectorITCase fails on Java 11

[ https://issues.apache.org/jira/browse/FLINK-13533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-13533: - Description: The \{{CassandraConnectorITCase}} fails on Java 11 with an error. We may

[jira] [Comment Edited] (FLINK-13493) BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty

[ https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998 ] zhijiang edited comment on FLINK-13493 at 8/1/19 12:07 PM: --- Thanks for the

[jira] [Commented] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898018#comment-16898018 ] Chesnay Schepler commented on FLINK-11835: -- [~trohrm...@apache.org] Could this simply be a case

[GitHub] [flink] flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

flinkbot edited a comment on issue #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#issuecomment-517175361 ## CI report: * bf81288dc40cf5a3bee5ece840d21821ea903135 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

flinkbot edited a comment on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-516306550 ## CI report: * abb4ae6bde1f3d1eac787c850c04614e7c5ff907 : FAILURE

[GitHub] [flink] pnowojski commented on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

pnowojski commented on issue #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#issuecomment-517252861 Looks even better to me :) This is an

[jira] [Updated] (FLINK-13521) Allow setting configuration in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-13521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13521: Summary: Allow setting configuration in SQL CLI (was: Allow set configuration in SQL CLI) > Allow

[jira] [Closed] (FLINK-13435) Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

[ https://issues.apache.org/jira/browse/FLINK-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-13435. Resolution: Fixed Fixed in master : 6ce4e2b7ec958570068838491bd8f56f880c > Remove

[GitHub] [flink] GJL commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

GJL commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r309655776 ## File path:

[GitHub] [flink] zhijiangW commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#issuecomment-517249269 Unrelated python component failure in travis, merging.

[GitHub] [flink] zhijiangW merged pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW merged pull request #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272 This is an automated message from

[GitHub] [flink] 1u0 commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules.

1u0 commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules. URL: https://github.com/apache/flink/pull/9313#discussion_r309654152 ## File path: flink-table/flink-table-uber-blink/pom.xml ## @@ -103,7 +103,8 @@ under the

[GitHub] [flink] 1u0 commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules.

1u0 commented on a change in pull request #9313: [FLINK-13504][table] Fixed shading issues in table modules. URL: https://github.com/apache/flink/pull/9313#discussion_r309654152 ## File path: flink-table/flink-table-uber-blink/pom.xml ## @@ -103,7 +103,8 @@ under the

[jira] [Assigned] (FLINK-11835) ZooKeeperLeaderElectionITCase#testJobExecutionOnClusterWithLeaderChange failed

[ https://issues.apache.org/jira/browse/FLINK-11835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-11835: Assignee: Chesnay Schepler >

[GitHub] [flink] flinkbot edited a comment on issue #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect…

flinkbot edited a comment on issue #9221: [FLINK-13376][datastream] ContinuousFileReaderOperator should respect… URL: https://github.com/apache/flink/pull/9221#issuecomment-514645431 ## CI report: * 05fe281c79ab4bd2646ec949dcbbf0c2af9fec6e : SUCCESS

[GitHub] [flink] 1u0 commented on issue #9313: [FLINK-13504][table] Fixed shading issues in table modules.

1u0 commented on issue #9313: [FLINK-13504][table] Fixed shading issues in table modules. URL: https://github.com/apache/flink/pull/9313#issuecomment-517247129 `flink-table-planner*.jar` also looks fine. This is an

[GitHub] [flink] twalthr commented on a change in pull request #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests

twalthr commented on a change in pull request #9312: [FLINK-13436][end-to-end-tests] Add TPC-H queries as E2E tests URL: https://github.com/apache/flink/pull/9312#discussion_r309651788 ## File path: flink-end-to-end-tests/test-scripts/test-data/tpch/query/q1.sql ## @@

[jira] [Commented] (FLINK-13493) BoundedBlockingSubpartition only notifies onConsumedSubpartition when all the readers are empty

[ https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998 ] zhijiang commented on FLINK-13493: -- Thanks for the clarification [~azagrebin]! I agree it should be no

[GitHub] [flink] GJL commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

GJL commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r309651091 ## File path:

[jira] [Commented] (FLINK-13521) Allow set configuration in SQL CLI

[ https://issues.apache.org/jira/browse/FLINK-13521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897993#comment-16897993 ] Jark Wu commented on FLINK-13521: - Thanks. We will prepare a PR soon. > Allow set configuration in SQL

[GitHub] [flink] zhijiangW commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type

zhijiangW commented on issue #9272: [FLINK-13435] Remove ShuffleDescriptor.ReleaseType and make release semantics fixed per partition type URL: https://github.com/apache/flink/pull/9272#issuecomment-517242829 Thanks for the explanation @azagrebin ! I understand it, wish the

[jira] [Commented] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897991#comment-16897991 ] Jiangjie Qin commented on FLINK-13527: -- Cool, I'll assign the ticket to you then. > Instable

[jira] [Assigned] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13527: Assignee: vinoyang (was: Jiangjie Qin) > Instable KafkaProducerExactlyOnceITCase due to

[GitHub] [flink] pnowojski commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

pnowojski commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r309646392 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask

pnowojski commented on a change in pull request #9271: [FLINK-13384][1.9][runtime] Fix back pressure sampling for SourceStreamTask URL: https://github.com/apache/flink/pull/9271#discussion_r309646392 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #9024: [FLINK-13119] add blink table config to documentation

wuchong commented on a change in pull request #9024: [FLINK-13119] add blink table config to documentation URL: https://github.com/apache/flink/pull/9024#discussion_r309646202 ## File path: flink-docs/src/main/java/org/apache/flink/docs/configuration/ConfigOptionsDocGenerator.java

[jira] [Updated] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-9925: Fix Version/s: (was: 1.9.0) > ClientTest.testSimpleRequests fails on Travis >

[jira] [Closed] (FLINK-9925) ClientTest.testSimpleRequests fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-9925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9925. --- Resolution: Cannot Reproduce > ClientTest.testSimpleRequests fails on Travis >

[GitHub] [flink] zentol commented on a change in pull request #9024: [FLINK-13119] add blink table config to documentation

zentol commented on a change in pull request #9024: [FLINK-13119] add blink table config to documentation URL: https://github.com/apache/flink/pull/9024#discussion_r309645033 ## File path: flink-docs/src/main/java/org/apache/flink/docs/configuration/ConfigOptionsDocGenerator.java

[GitHub] [flink] flinkbot commented on issue #9320: [FLINK-13531] Do not print log and call 'release' if no requests should be evicted from the shared slot

flinkbot commented on issue #9320: [FLINK-13531] Do not print log and call 'release' if no requests should be evicted from the shared slot URL: https://github.com/apache/flink/pull/9320#issuecomment-517239112 ## CI report: * 187030df57d4fc62a2d121ddda3a4047a390f576 : PENDING

<    1   2   3   4   5   6   >