[jira] [Updated] (FLINK-19248) The main method caused an error: No result found for job, was execute() called before getting the result

[ https://issues.apache.org/jira/browse/FLINK-19248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shiyu Jin updated FLINK-19248: -- Description: *[_Gelly_]* *The main method caused an error: No result found for job, was execute()

[GitHub] [flink] flinkbot commented on pull request #13396: [FLINK-19248] add missing lastJobExecutionResult assignment after job finished in ContexEnvironment

flinkbot commented on pull request #13396: URL: https://github.com/apache/flink/pull/13396#issuecomment-693187999 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will use this comment to track the

[jira] [Updated] (FLINK-19248) The main method caused an error: No result found for job, was execute() called before getting the result

[ https://issues.apache.org/jira/browse/FLINK-19248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19248: --- Labels: pull-request-available (was: ) > The main method caused an error: No result found

[GitHub] [flink] jsycdut opened a new pull request #13396: [FLINK-19248] add missing lastJobExecutionResult assignment after job finished in ContexEnvironment

jsycdut opened a new pull request #13396: URL: https://github.com/apache/flink/pull/13396 ## What is the purpose of the change This pull request fixes [issue FLINK-19248](https://issues.apache.org/jira/browse/FLINK-19248) opened by myself. ## Brief change log -

[jira] [Commented] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196689#comment-17196689 ] Aljoscha Krettek commented on FLINK-19167: -- Thanks for caring and looking at things! It's good

[jira] [Closed] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19167. Resolution: Not A Problem > Proccess Function Example could not work >

[jira] [Commented] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196688#comment-17196688 ] Aljoscha Krettek commented on FLINK-19167: -- Yes, that is correct. > Proccess Function Example

[GitHub] [flink] flinkbot edited a comment on pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

flinkbot edited a comment on pull request #13392: URL: https://github.com/apache/flink/pull/13392#issuecomment-692540614 ## CI report: * bfb82165ec567b63f6f743aec7be913a2a440fa1 UNKNOWN * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the

[jira] [Commented] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196687#comment-17196687 ] Kyle Bendickson commented on FLINK-19255: - Actually, looking at this PR: 

[jira] [Updated] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Bendickson updated FLINK-19255: Description: Currently, we no longer chain Async IO calls. Instead, anything using

[jira] [Updated] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Bendickson updated FLINK-19255: Environment: Any flink job using Async IO post this PR: 

[jira] [Updated] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Bendickson updated FLINK-19255: Description: Currently, we no longer chain Async IO calls. Instead, anything using

[jira] [Updated] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

[ https://issues.apache.org/jira/browse/FLINK-19255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Bendickson updated FLINK-19255: Description: Currently, we no longer chain AsyncIO calls. Instead, anything using AsyncIO

[jira] [Created] (FLINK-19255) Add configuration to make AsyncWaitOperation Chainable

Kyle created FLINK-19255: Summary: Add configuration to make AsyncWaitOperation Chainable Key: FLINK-19255 URL: https://issues.apache.org/jira/browse/FLINK-19255 Project: Flink Issue Type: Task

[jira] [Updated] (FLINK-19230) Support Python UDAF on blink batch planner

[ https://issues.apache.org/jira/browse/FLINK-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19230: Fix Version/s: 1.12.0 > Support Python UDAF on blink batch planner >

[jira] [Assigned] (FLINK-19230) Support Python UDAF on blink batch planner

[ https://issues.apache.org/jira/browse/FLINK-19230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19230: --- Assignee: Wei Zhong > Support Python UDAF on blink batch planner >

[jira] [Commented] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196678#comment-17196678 ] Xintong Song commented on FLINK-19246: -- Another instance:

[jira] [Updated] (FLINK-19169) Support Pandas UDAF in PyFlink (FLIP-137)

[ https://issues.apache.org/jira/browse/FLINK-19169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19169: Issue Type: New Feature (was: Improvement) > Support Pandas UDAF in PyFlink (FLIP-137) >

[jira] [Updated] (FLINK-19229) Support ValueState and Python UDAF on blink stream planner

[ https://issues.apache.org/jira/browse/FLINK-19229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19229: Fix Version/s: 1.12.0 > Support ValueState and Python UDAF on blink stream planner >

[jira] [Assigned] (FLINK-19229) Support ValueState and Python UDAF on blink stream planner

[ https://issues.apache.org/jira/browse/FLINK-19229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19229: --- Assignee: Wei Zhong > Support ValueState and Python UDAF on blink stream planner >

[jira] [Updated] (FLINK-19185) Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139)

[ https://issues.apache.org/jira/browse/FLINK-19185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19185: Issue Type: New Feature (was: Task) > Support General Python User-Defined Aggregate Function Support on

[jira] [Updated] (FLINK-19185) Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139)

[ https://issues.apache.org/jira/browse/FLINK-19185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19185: Fix Version/s: 1.12.0 > Support General Python User-Defined Aggregate Function Support on Table API >

[jira] [Assigned] (FLINK-19173) Add Pandas Batch Group Aggregation Function Operator

[ https://issues.apache.org/jira/browse/FLINK-19173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19173: --- Assignee: Huang Xingbo > Add Pandas Batch Group Aggregation Function Operator >

[jira] [Assigned] (FLINK-19185) Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139)

[ https://issues.apache.org/jira/browse/FLINK-19185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19185: --- Assignee: Wei Zhong > Support General Python User-Defined Aggregate Function Support on Table API

[jira] [Assigned] (FLINK-19169) Support Pandas UDAF in PyFlink (FLIP-137)

[ https://issues.apache.org/jira/browse/FLINK-19169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-19169: --- Assignee: Huang Xingbo > Support Pandas UDAF in PyFlink (FLIP-137) >

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196668#comment-17196668 ] Ying Z commented on FLINK-19244: [~jark] Thanks for your advice, this will lead the user to use format

[GitHub] [flink-playgrounds] shuiqiangchen commented on pull request #16: [FLINK-19145][walkthroughs] Add PyFlink-walkthrough to Flink playground.

shuiqiangchen commented on pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16#issuecomment-693154194 @alpinegizmo Thank you for pointing out the errors in english and other improvements, I have revised the errors and added an extension section to allow users to do

[GitHub] [flink] wangxlong commented on pull request #13392: [FLINK-18713][table-planner-blink] Change duration configOption to duration type

wangxlong commented on pull request #13392: URL: https://github.com/apache/flink/pull/13392#issuecomment-693152530 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-19254) Invalid UTF-8 start byte exception

Jun Zhang created FLINK-19254: - Summary: Invalid UTF-8 start byte exception Key: FLINK-19254 URL: https://issues.apache.org/jira/browse/FLINK-19254 Project: Flink Issue Type: Bug

[GitHub] [flink-docker] zhuzhurk opened a new pull request #40: Add GPG key for 1.11.2 release and update test script

zhuzhurk opened a new pull request #40: URL: https://github.com/apache/flink-docker/pull/40 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

[jira] [Commented] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196649#comment-17196649 ] Jingsong Lee commented on FLINK-18604: -- Fixed in master: 97e7c73653bf013c13404c6dc315c8ed3e5afe4b

[GitHub] [flink] JingsongLi commented on pull request #13276: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

JingsongLi commented on pull request #13276: URL: https://github.com/apache/flink/pull/13276#issuecomment-693147103 @pyscala Can you create a PR for release-1.11? This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-18604) HBase ConnectorDescriptor can not work in Table API

[ https://issues.apache.org/jira/browse/FLINK-18604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18604: - Fix Version/s: 1.11.3 > HBase ConnectorDescriptor can not work in Table API >

[jira] [Comment Edited] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196647#comment-17196647 ] Jark Wu edited comment on FLINK-19244 at 9/16/20, 3:20 AM: --- I think we can add

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196647#comment-17196647 ] Jark Wu commented on FLINK-19244: - I think we can add a check in

[GitHub] [flink] JingsongLi merged pull request #13276: [FLINK-18604][connectors/HBase] HBase ConnectorDescriptor can not work in Table API

JingsongLi merged pull request #13276: URL: https://github.com/apache/flink/pull/13276 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196643#comment-17196643 ] dalongliu commented on FLINK-19207: --- I see, tks! > TtlListState#IteratorWithCleanup support remove

[jira] [Commented] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196641#comment-17196641 ] Dian Fu commented on FLINK-19246: - Another instance: 

[jira] [Comment Edited] (FLINK-18366) Track E2E test durations centrally

[ https://issues.apache.org/jira/browse/FLINK-18366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196638#comment-17196638 ] Dian Fu edited comment on FLINK-18366 at 9/16/20, 3:03 AM: --- Another

[jira] [Commented] (FLINK-18366) Track E2E test durations centrally

[ https://issues.apache.org/jira/browse/FLINK-18366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196638#comment-17196638 ] Dian Fu commented on FLINK-18366: - Another instance(as there is no log, I'm not 100% sure it's caused by

[jira] [Comment Edited] (FLINK-18366) Track E2E test durations centrally

[ https://issues.apache.org/jira/browse/FLINK-18366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196638#comment-17196638 ] Dian Fu edited comment on FLINK-18366 at 9/16/20, 3:02 AM: --- Another

[jira] [Assigned] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19246: --- Assignee: Jark Wu > TableSourceITCase.testStreamScanParallelism fails on private Azure accounts >

[jira] [Commented] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196637#comment-17196637 ] Jark Wu commented on FLINK-19246: - I think the reason is that

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196636#comment-17196636 ] Ying Z commented on FLINK-19244: [~jark] ignoreParseErrors=true will skip this record x = serialize(y)

[jira] [Comment Edited] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196636#comment-17196636 ] Ying Z edited comment on FLINK-19244 at 9/16/20, 2:59 AM: -- [~jark] 

[GitHub] [flink] flinkbot edited a comment on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

flinkbot edited a comment on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-690084042 ## CI report: * 2262989291eff47a2a1c9d5f284eabbef14d6411 Azure:

[jira] [Commented] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196635#comment-17196635 ] Dian Fu commented on FLINK-19253: - cc [~jqin] > SourceReaderTestBase.testAddSplitToExistingFetcher

[jira] [Created] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

Dian Fu created FLINK-19253: --- Summary: SourceReaderTestBase.testAddSplitToExistingFetcher hangs Key: FLINK-19253 URL: https://issues.apache.org/jira/browse/FLINK-19253 Project: Flink Issue Type:

[jira] [Updated] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19253: Labels: test-stability (was: ) > SourceReaderTestBase.testAddSplitToExistingFetcher hangs >

[jira] [Commented] (FLINK-13663) SQL Client end-to-end test for modern Kafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196632#comment-17196632 ] Dian Fu commented on FLINK-13663: - Another instance on master:

[jira] [Updated] (FLINK-19247) Update Chinese documentation after removal of Kafka 0.10 and 0.11

[ https://issues.apache.org/jira/browse/FLINK-19247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-19247: Component/s: chinese-translation > Update Chinese documentation after removal of Kafka 0.10 and 0.11 >

[jira] [Assigned] (FLINK-19247) Update Chinese documentation after removal of Kafka 0.10 and 0.11

[ https://issues.apache.org/jira/browse/FLINK-19247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19247: --- Assignee: Huang Xiao > Update Chinese documentation after removal of Kafka 0.10 and 0.11 >

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196631#comment-17196631 ] Jark Wu commented on FLINK-19244: - Btw, CSV is not a good format to handle nested types. >

[jira] [Commented] (FLINK-19244) CsvRowDataDeserializationSchema throws cast exception : Row length mismatch.

[ https://issues.apache.org/jira/browse/FLINK-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196630#comment-17196630 ] Jark Wu commented on FLINK-19244: - You can try to set {{ignoreParseErrors}} to {{true}}. >

[jira] [Commented] (FLINK-19252) Jaas file created under io.tmp.dirs - folder not created if not exists

[ https://issues.apache.org/jira/browse/FLINK-19252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196629#comment-17196629 ] Yangze Guo commented on FLINK-19252: I think it is a valid issue. One simple solution is to create

[GitHub] [flink] flinkbot edited a comment on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

flinkbot edited a comment on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-690084042 ## CI report: * Unknown: [CANCELED](TBD) Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run travis`

[jira] [Commented] (FLINK-19207) TtlListState#IteratorWithCleanup support remove method

[ https://issues.apache.org/jira/browse/FLINK-19207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196626#comment-17196626 ] Jark Wu commented on FLINK-19207: - [~lsy] I think we only need to do #2. >

[GitHub] [flink] WeiZhong94 commented on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

WeiZhong94 commented on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-693129470 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] SteNicholas edited a comment on pull request #13332: [FLINK-19128][sql-client] Remove the runtime execution configuration in sql-client-defaults.yaml

SteNicholas edited a comment on pull request #13332: URL: https://github.com/apache/flink/pull/13332#issuecomment-687626749 > Hi @SteNicholas , thanks for the contribution. However, I think you misunderstand the purpose of the issue. We don't need to drop the support for `parallellism`,

[GitHub] [flink] WeiZhong94 commented on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

WeiZhong94 commented on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-693126792 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] SteNicholas edited a comment on pull request #13298: [FLINK-19038][table] It doesn't support to call Table.limit() continuously

SteNicholas edited a comment on pull request #13298: URL: https://github.com/apache/flink/pull/13298#issuecomment-685310268 @twalthr @rmetzger Could you please review this pull request? The current behavior of SortOperationFactory are familiar to you. Thanks！

[GitHub] [flink] HuangXingBo commented on pull request #13371: [FLINK-17879][python] update Python row serializer to support RowKind

HuangXingBo commented on pull request #13371: URL: https://github.com/apache/flink/pull/13371#issuecomment-693120581 @WeiZhong94 Thanks a lot for the update. e2e test of Azure CI failed. This is an automated message from

[jira] [Commented] (FLINK-19247) Update Chinese documentation after removal of Kafka 0.10 and 0.11

[ https://issues.apache.org/jira/browse/FLINK-19247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196615#comment-17196615 ] Huang Xiao commented on FLINK-19247: Hi, [~aljoscha]. I'm willing to do this. Could you assign it

[jira] [Created] (FLINK-19252) Jaas file created under io.tmp.dirs - folder not created if not exists

Koala Lam created FLINK-19252: - Summary: Jaas file created under io.tmp.dirs - folder not created if not exists Key: FLINK-19252 URL: https://issues.apache.org/jira/browse/FLINK-19252 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13383: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke [1.10]

flinkbot edited a comment on pull request #13383: URL: https://github.com/apache/flink/pull/13383#issuecomment-692066644 ## CI report: * 75eb7195c13f8641a58870c1ae2861c1302e437c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/184220187) *

[jira] [Created] (FLINK-19251) Avoid confusing queue handling in "SplitReader.handleSplitsChanges()"

Stephan Ewen created FLINK-19251: Summary: Avoid confusing queue handling in "SplitReader.handleSplitsChanges()" Key: FLINK-19251 URL: https://issues.apache.org/jira/browse/FLINK-19251 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13374: [FLINK-19109][streaming] Disallow chaining of ContinuousFileReaderOperator. [1.10]

flinkbot edited a comment on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789 ## CI report: * 858ce532bd1800cb354ae304296db67764aad433 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/183959923) *

[jira] [Comment Edited] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196551#comment-17196551 ] Stephan Ewen edited comment on FLINK-19246 at 9/15/20, 8:58 PM: Have the

[jira] [Commented] (FLINK-19246) TableSourceITCase.testStreamScanParallelism fails on private Azure accounts

[ https://issues.apache.org/jira/browse/FLINK-19246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196551#comment-17196551 ] Stephan Ewen commented on FLINK-19246: -- Have the same problem. The test also passes on my local

[jira] [Commented] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196543#comment-17196543 ] Stephan Ewen commented on FLINK-19249: -- Is this a configuration issue? Can we solve this with a

[jira] [Created] (FLINK-19250) SplitFetcherManager does not propagate errors correctly

Stephan Ewen created FLINK-19250: Summary: SplitFetcherManager does not propagate errors correctly Key: FLINK-19250 URL: https://issues.apache.org/jira/browse/FLINK-19250 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13374: [FLINK-19109][streaming] Disallow chaining of ContinuousFileReaderOperator. [1.10]

flinkbot edited a comment on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789 ## CI report: * 858ce532bd1800cb354ae304296db67764aad433 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/183959923) *

[jira] [Resolved] (FLINK-19221) Exploit LocatableFileStatus from Hadoop

[ https://issues.apache.org/jira/browse/FLINK-19221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-19221. -- Resolution: Fixed Fixed in 1.12.0 (master) via 7375589cc17d801af1306c3bb7563fc539b91d01 >

[jira] [Resolved] (FLINK-19218) Remove inconsistent host logic for LocalFileSystem

[ https://issues.apache.org/jira/browse/FLINK-19218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-19218. -- Resolution: Fixed Fixed in 1.12.0 via 5bcdd7de67bf21bc19c8b5b84f617dacaf7f0c99 > Remove

[jira] [Closed] (FLINK-19221) Exploit LocatableFileStatus from Hadoop

[ https://issues.apache.org/jira/browse/FLINK-19221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-19221. > Exploit LocatableFileStatus from Hadoop > --- > >

[jira] [Closed] (FLINK-19218) Remove inconsistent host logic for LocalFileSystem

[ https://issues.apache.org/jira/browse/FLINK-19218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-19218. > Remove inconsistent host logic for LocalFileSystem >

[jira] [Resolved] (FLINK-17393) Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

[ https://issues.apache.org/jira/browse/FLINK-17393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17393. -- Fix Version/s: 1.12.0 Resolution: Fixed Fixed in 1.12.0 via

[jira] [Closed] (FLINK-17393) Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

[ https://issues.apache.org/jira/browse/FLINK-17393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17393. > Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more > elegantly. >

[jira] [Assigned] (FLINK-17393) Improve the `FutureCompletingBlockingQueue` to wakeup blocking put() more elegantly.

[ https://issues.apache.org/jira/browse/FLINK-17393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen reassigned FLINK-17393: Assignee: Jiangjie Qin > Improve the `FutureCompletingBlockingQueue` to wakeup blocking

[jira] [Closed] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

[ https://issues.apache.org/jira/browse/FLINK-18128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-18128. > CoordinatedSourceITCase.testMultipleSources gets stuck >

[jira] [Resolved] (FLINK-19223) Simplify Availability Future Model in Base Connector

[ https://issues.apache.org/jira/browse/FLINK-19223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-19223. -- Resolution: Fixed Fixed in 1.12.0 via 4ea95782b4c6a2538153d4d16ad3f4839c7de0fb > Simplify

[jira] [Resolved] (FLINK-18128) CoordinatedSourceITCase.testMultipleSources gets stuck

[ https://issues.apache.org/jira/browse/FLINK-18128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-18128. -- Resolution: Fixed Fixed in 1.12.0 (master) via 511857049ba30c8ff0ee56da551fa4a479dc583e >

[jira] [Closed] (FLINK-19223) Simplify Availability Future Model in Base Connector

[ https://issues.apache.org/jira/browse/FLINK-19223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-19223. > Simplify Availability Future Model in Base Connector >

[jira] [Closed] (FLINK-19245) Set default queue capacity for FLIP-27 source handover queue to 2

[ https://issues.apache.org/jira/browse/FLINK-19245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-19245. > Set default queue capacity for FLIP-27 source handover queue to 2 >

[jira] [Resolved] (FLINK-19245) Set default queue capacity for FLIP-27 source handover queue to 2

[ https://issues.apache.org/jira/browse/FLINK-19245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-19245. -- Resolution: Fixed Fixed in 1.12.0 via cef8a587d7fd2fe64cc644da5ed095d82e46f631 > Set default

[GitHub] [flink] asfgit closed pull request #13366: [FLINK-17393][connector/common] Wakeup the SplitFetchers more elegantly.

asfgit closed pull request #13366: URL: https://github.com/apache/flink/pull/13366 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] asfgit closed pull request #13385: [FLINK-18128][FLINK-19223][connectors] Fixes to Connector Base Availability logic

asfgit closed pull request #13385: URL: https://github.com/apache/flink/pull/13385 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] asfgit closed pull request #13394: [FLINK-19221][filesystems] Introduce the LocatedFileStatus to save block location RPC requests.

asfgit closed pull request #13394: URL: https://github.com/apache/flink/pull/13394 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19249: - Fix Version/s: 1.11.3 > Job would wait sometime(~10 min) before failover if some connection

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19249: - Priority: Blocker (was: Major) > Job would wait sometime(~10 min) before failover if some

[jira] [Updated] (FLINK-19249) Job would wait sometime(~10 min) before failover if some connection broken

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen updated FLINK-19249: - Fix Version/s: 1.12.0 > Job would wait sometime(~10 min) before failover if some connection

[GitHub] [flink] flinkbot edited a comment on pull request #13383: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke [1.10]

flinkbot edited a comment on pull request #13383: URL: https://github.com/apache/flink/pull/13383#issuecomment-692066644 ## CI report: * 75eb7195c13f8641a58870c1ae2861c1302e437c Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/184220187) *

[GitHub] [flink] AHeise commented on pull request #13383: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke [1.10]

AHeise commented on pull request #13383: URL: https://github.com/apache/flink/pull/13383#issuecomment-692914561 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] AHeise commented on pull request #13374: [FLINK-19109][streaming] Disallow chaining of ContinuousFileReaderOperator. [1.10]

AHeise commented on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-692910577 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on pull request #13374: [FLINK-19109][streaming] Disallow chaining of ContinuousFileReaderOperator. [1.10]

flinkbot edited a comment on pull request #13374: URL: https://github.com/apache/flink/pull/13374#issuecomment-691175789 ## CI report: * 858ce532bd1800cb354ae304296db67764aad433 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/183959923) *

[jira] [Comment Edited] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196280#comment-17196280 ] tinny cat edited comment on FLINK-19167 at 9/15/20, 4:35 PM: - thank you

[jira] [Comment Edited] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196280#comment-17196280 ] tinny cat edited comment on FLINK-19167 at 9/15/20, 4:29 PM: - thank you

[jira] [Commented] (FLINK-19167) Proccess Function Example could not work

[ https://issues.apache.org/jira/browse/FLINK-19167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17196280#comment-17196280 ] tinny cat commented on FLINK-19167: --- thank you [~aljoscha] [~dwysakowicz] [~twalthr],  I tried the

[GitHub] [flink] flinkbot edited a comment on pull request #13385: [FLINK-18128][FLINK-19223][connectors] Fixes to Connector Base Availability logic

flinkbot edited a comment on pull request #13385: URL: https://github.com/apache/flink/pull/13385#issuecomment-692360622 ## CI report: * 0231272dac19c37325c150946ad3f87416e7b6b5 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13383: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke [1.10]

flinkbot edited a comment on pull request #13383: URL: https://github.com/apache/flink/pull/13383#issuecomment-692066644 ## CI report: * 75eb7195c13f8641a58870c1ae2861c1302e437c Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/184220187) *

  1   2   3   4   >