[jira] [Updated] (FLINK-17764) Update tips about the default planner when the planner parameter value is not recognized

2020-05-16 Thread xushiwei (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xushiwei updated FLINK-17764: - Summary: Update tips about the default planner when the planner parameter value is not recognized

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-16 Thread GitBox
dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426164273 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-16 Thread GitBox
dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426164192 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-16 Thread GitBox
dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426164192 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-16 Thread GitBox
dawidwys commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426164011 ## File path:

[jira] [Resolved] (FLINK-17699) Reduce scope for SourceOperator arguments and initialize more eagerly

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17699. -- Resolution: Fixed Fixed in 1.11.0 via - 939625f2c84bdce6872548d3df672f492e33a704 > Reduce

[jira] [Closed] (FLINK-17699) Reduce scope for SourceOperator arguments and initialize more eagerly

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17699. > Reduce scope for SourceOperator arguments and initialize more eagerly >

[jira] [Comment Edited] (FLINK-17695) Simplify SourceOperator by using a utility SimpleVersionedListState

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109105#comment-17109105 ] Stephan Ewen edited comment on FLINK-17695 at 5/16/20, 3:32 PM: Fixed in

[jira] [Resolved] (FLINK-17696) Support eager initialization of operators with OperatorEventDispatcher

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17696. -- Resolution: Fixed Fixed in 1.11.0 via - 1c9ed3d846435ef36532e9f193327b30c17b5e11 >

[jira] [Closed] (FLINK-17696) Support eager initialization of operators with OperatorEventDispatcher

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17696. > Support eager initialization of operators with OperatorEventDispatcher >

[jira] [Created] (FLINK-17763) No log files when starting scala-shell

2020-05-16 Thread Jeff Zhang (Jira)
Jeff Zhang created FLINK-17763: -- Summary: No log files when starting scala-shell Key: FLINK-17763 URL: https://issues.apache.org/jira/browse/FLINK-17763 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-17764) Update tips about the default planner when the parameter planner is not recognized

2020-05-16 Thread xushiwei (Jira)
xushiwei created FLINK-17764: Summary: Update tips about the default planner when the parameter planner is not recognized Key: FLINK-17764 URL: https://issues.apache.org/jira/browse/FLINK-17764 Project:

[jira] [Resolved] (FLINK-17695) Simplify SourceOperator by using a utility SimpleVersionedListState

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17695. -- Resolution: Fixed Fixed in 1.11.0 via 1cceb3ee3f109aefaeec440a87651053d0f4c191 (NOTE: The

[jira] [Closed] (FLINK-17695) Simplify SourceOperator by using a utility SimpleVersionedListState

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17695. > Simplify SourceOperator by using a utility SimpleVersionedListState >

[jira] [Closed] (FLINK-17694) Wrong min-length check in SimpleVersionedSerialization

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-17694. > Wrong min-length check in SimpleVersionedSerialization >

[GitHub] [flink] StephanEwen commented on pull request #12155: [various] Cleanups and improvements to the SourceOperators

2020-05-16 Thread GitBox
StephanEwen commented on pull request #12155: URL: https://github.com/apache/flink/pull/12155#issuecomment-629663514 Manually merged in 939625f2c84bdce6872548d3df672f492e33a704 This is an automated message from the Apache

[jira] [Resolved] (FLINK-17694) Wrong min-length check in SimpleVersionedSerialization

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-17694. -- Resolution: Fixed Fixed in 1.11.0 via 3ba9b38cd750d12db759007235cc7f8497ee4170 > Wrong

[GitHub] [flink] StephanEwen closed pull request #12155: [various] Cleanups and improvements to the SourceOperators

2020-05-16 Thread GitBox
StephanEwen closed pull request #12155: URL: https://github.com/apache/flink/pull/12155 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

[jira] [Closed] (FLINK-17028) Introduce a new HBase connector with new property keys

2020-05-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-17028. --- Fix Version/s: 1.11.0 Resolution: Fixed master (1.11.0): 1670f1605db0923bac233f60fc56d41a2da4da70 >

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

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-5763. --- > Make savepoints self-contained and relocatable > -- > >

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

2020-05-16 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-5763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-5763. - Resolution: Fixed Implemented in 1.11 via - 182e6affc631046cc2e4e6a6060a1fb8902e1601 -

[GitHub] [flink] wuchong closed pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

2020-05-16 Thread GitBox
wuchong closed pull request #12178: URL: https://github.com/apache/flink/pull/12178 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] StephanEwen commented on pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

2020-05-16 Thread GitBox
StephanEwen commented on pull request #11722: URL: https://github.com/apache/flink/pull/11722#issuecomment-629663239 Manually merged in c5583c75394972dd4564132e3a0896a7f4f85a19 This is an automated message from the Apache

[GitHub] [flink] StephanEwen commented on pull request #12187: [FLINK-5763][state backends] (follow-up) Make savepoints self-contained and relocatable

2020-05-16 Thread GitBox
StephanEwen commented on pull request #12187: URL: https://github.com/apache/flink/pull/12187#issuecomment-629663290 Manually merged in 4ee41bebc504880c7224ec29ffdd4cf28f5fc218 This is an automated message from the Apache

[GitHub] [flink] StephanEwen closed pull request #11722: [FLINK-5763][state backends] Make savepoints self-contained and relocatable

2020-05-16 Thread GitBox
StephanEwen closed pull request #11722: URL: https://github.com/apache/flink/pull/11722 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

[GitHub] [flink] StephanEwen closed pull request #12187: [FLINK-5763][state backends] (follow-up) Make savepoints self-contained and relocatable

2020-05-16 Thread GitBox
StephanEwen closed pull request #12187: URL: https://github.com/apache/flink/pull/12187 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

[GitHub] [flink] wuchong commented on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

2020-05-16 Thread GitBox
wuchong commented on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629662994 The failed case is KafkaProducerTestBase.testExactlyOnce which is a known issue. Merging this one...

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 9af69eb96e9a0ddaff4937e9d926feff92439f32 Azure:

[GitHub] [flink] tillrohrmann commented on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

2020-05-16 Thread GitBox
tillrohrmann commented on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-629662405 @KarmaGYZ, I've rebased this PR onto the latest version of #11854. This is an automated message from the

[GitHub] [flink] wuchong commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-16 Thread GitBox
wuchong commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426162683 ## File path:

[jira] [Created] (FLINK-17762) Postgres Catalog should pass table's primary key to catalogTable

2020-05-16 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-17762: -- Summary: Postgres Catalog should pass table's primary key to catalogTable Key: FLINK-17762 URL: https://issues.apache.org/jira/browse/FLINK-17762 Project: Flink

[jira] [Closed] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

2020-05-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-17754. -- Assignee: Kurt Young Resolution: Fixed > Walkthrough Table Java nightly end-to-end test failed

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 499722944af576d13757da75f4ad0d08c4538782 Azure:

[GitHub] [flink] flinkbot commented on pull request #12191: [hotfix][flink-core and docs] fix typos

2020-05-16 Thread GitBox
flinkbot commented on pull request #12191: URL: https://github.com/apache/flink/pull/12191#issuecomment-629660388 ## CI report: * a6f640ba12da96bedc6880dbf365d7599716008c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17754) Walkthrough Table Java nightly end-to-end test failed to compile

2020-05-16 Thread Kurt Young (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109095#comment-17109095 ] Kurt Young commented on FLINK-17754: Yes, it's been fixed. We changed some API, these source codes

[GitHub] [flink] wuchong commented on a change in pull request #12184: [FLINK-17027] Introduce a new Elasticsearch 7 connector with new property keys

2020-05-16 Thread GitBox
wuchong commented on a change in pull request #12184: URL: https://github.com/apache/flink/pull/12184#discussion_r426156300 ## File path:

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

2020-05-16 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109093#comment-17109093 ] Jiangjie Qin commented on FLINK-17393: -- [~echauchot] Sorry for the late reply. You are right. This

[jira] [Created] (FLINK-17761) FutureCompletingBlockingQueue should have a capacity limit.

2020-05-16 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-17761: Summary: FutureCompletingBlockingQueue should have a capacity limit. Key: FLINK-17761 URL: https://issues.apache.org/jira/browse/FLINK-17761 Project: Flink

[GitHub] [flink] guoweiM edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-16 Thread GitBox
guoweiM edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629650094 Hi, @aljoscha thanks for your review and suggestion. 1. The reason I used Operator to generate snapshots at the time is that we could use a set of code to generate

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[GitHub] [flink] flinkbot commented on pull request #12191: [hotfix][flink-core and docs] fix typos

2020-05-16 Thread GitBox
flinkbot commented on pull request #12191: URL: https://github.com/apache/flink/pull/12191#issuecomment-629656357 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

[GitHub] [flink] wangxianghu opened a new pull request #12191: [minor][flink-core and docs] fix typos

2020-05-16 Thread GitBox
wangxianghu opened a new pull request #12191: URL: https://github.com/apache/flink/pull/12191 ## What is the purpose of the change *Fix typos in OptimizerOptions.java and docs* ## Brief change log *Fix typos in OptimizerOptions.java and docs* ## Verifying

[GitHub] [flink] KarmaGYZ commented on pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-16 Thread GitBox
KarmaGYZ commented on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-629654637 Rebase to the latest master and resolve conflict. This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

2020-05-16 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-9528. -- Fix Version/s: 1.11.0 Resolution: Fixed This is fixed by FLINK-16887. Test is added in

[GitHub] [flink] flinkbot edited a comment on pull request #12190: [FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12190: URL: https://github.com/apache/flink/pull/12190#issuecomment-629650634 ## CI report: * ba32a1c937bd2452d5ac8018ae4742289d953813 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * abf3481dcb850de081a045ae96d27c335e96e157 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12178: [FLINK-17028][hbase] Introduce a new HBase connector with new property keys

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12178: URL: https://github.com/apache/flink/pull/12178#issuecomment-629283346 ## CI report: * 1b75f1a3cdb3b9fb726c57bfe38d967eb9e60360 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #11854: URL: https://github.com/apache/flink/pull/11854#issuecomment-617586491 ## CI report: * bddb0e274da11bbe99d15c6e0bb55e8d8c0e658a UNKNOWN * dc7a9c5c7d1fac82518815b9277809dfb82ddaac UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 98f223d3937fd0d2611c2878b7c405e28030eda7 Azure:

[GitHub] [flink] becketqin commented on a change in pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

2020-05-16 Thread GitBox
becketqin commented on a change in pull request #12137: URL: https://github.com/apache/flink/pull/12137#discussion_r426157226 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java ## @@ -186,10 +188,18 @@ private void

[GitHub] [flink] pnowojski commented on a change in pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

2020-05-16 Thread GitBox
pnowojski commented on a change in pull request #12186: URL: https://github.com/apache/flink/pull/12186#discussion_r426157143 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java ## @@ -262,7 +262,9 @@ public void

[jira] [Created] (FLINK-17760) Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore

2020-05-16 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-17760: --- Summary: Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore Key: FLINK-17760 URL: https://issues.apache.org/jira/browse/FLINK-17760 Project: Flink

[jira] [Created] (FLINK-17759) Remove RestartIndividualStrategy

2020-05-16 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-17759: --- Summary: Remove RestartIndividualStrategy Key: FLINK-17759 URL: https://issues.apache.org/jira/browse/FLINK-17759 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

2020-05-16 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17758: Component/s: Runtime / Coordination > Remove AdaptedRestartPipelinedRegionStrategyNG >

[GitHub] [flink] curcur edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-16 Thread GitBox
curcur edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629650067 Hey @AHeise , thank you so much again! I believe I've addressed most of the minor issues mentioned in the previous reviews. Please remind me if I miss anything but

[jira] [Created] (FLINK-17758) Remove AdaptedRestartPipelinedRegionStrategyNG

2020-05-16 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-17758: --- Summary: Remove AdaptedRestartPipelinedRegionStrategyNG Key: FLINK-17758 URL: https://issues.apache.org/jira/browse/FLINK-17758 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-17269) Translate new Training Overview

2020-05-16 Thread David Anderson (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Anderson reassigned FLINK-17269: -- Assignee: Yichao Yang > Translate new Training Overview >

[jira] [Updated] (FLINK-15649) Support mounting volumes

2020-05-16 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-15649: - Parent: FLINK-17709 Issue Type: Sub-task (was: New Feature) > Support mounting volumes

[GitHub] [flink] curcur edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-16 Thread GitBox
curcur edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629650067 Hey @AHeise , thank you so much again! I believe I've addressed most of the minor issues mentioned in the previous reviews. Please remind me if I miss anything but

[GitHub] [flink] flinkbot edited a comment on pull request #12186: [FLINK-16383][task] Do not relay notifyCheckpointComplete to closed operators

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12186: URL: https://github.com/apache/flink/pull/12186#issuecomment-629492236 ## CI report: * 25f5493bb635b3876ef629cdfb87b3d7a6aa8fff Azure:

[GitHub] [flink] flinkbot commented on pull request #12190: [FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread GitBox
flinkbot commented on pull request #12190: URL: https://github.com/apache/flink/pull/12190#issuecomment-629650634 ## CI report: * ba32a1c937bd2452d5ac8018ae4742289d953813 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 700825f14b6128048bf2aec22947f30eaef40100 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12029: [FLINK-17451][sql-parser][table-planner-blink][hive] Implement view D…

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12029: URL: https://github.com/apache/flink/pull/12029#issuecomment-625673739 ## CI report: * 9405ea4470dc022ffb514f603396fc6bb2582835 UNKNOWN * abf3481dcb850de081a045ae96d27c335e96e157 Azure:

[GitHub] [flink] guoweiM edited a comment on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-16 Thread GitBox
guoweiM edited a comment on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629650094 Hi, @aljoscha thanks for your review and suggestion. 1. yes you are right I should delete the v1 code in the test. 1. The reason I used Operator to generate

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] guoweiM commented on pull request #12132: [FLINK-17593][Connectors/FileSystem] Support arbitrary recovery mechanism for PartFileWriter

2020-05-16 Thread GitBox
guoweiM commented on pull request #12132: URL: https://github.com/apache/flink/pull/12132#issuecomment-629650094 Hi, @aljoscha thanks for your suggestion. 1. yes you are right I should delete the v1 code in the test. 1. The reason I used Operator to generate snapshots at the time is

[GitHub] [flink] flinkbot edited a comment on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-613252882 ## CI report: * 066795205734add3b142a92c687c98b25253985e UNKNOWN * 6c24e114e622b0130e921d6994aad9a48aa2318b Azure:

[GitHub] [flink] curcur commented on pull request #11725: [FLINK-15670][API] Provide a Kafka Source/Sink pair as KafkaShuffle

2020-05-16 Thread GitBox
curcur commented on pull request #11725: URL: https://github.com/apache/flink/pull/11725#issuecomment-629650067 Hey @AHeise , thank you so much again! I believe I've addressed most of the minor issues mentioned in the previous reviews. Please remind me if I miss anything but for the

[GitHub] [flink] zhuzhurk commented on pull request #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes

2020-05-16 Thread GitBox
zhuzhurk commented on pull request #10883: URL: https://github.com/apache/flink/pull/10883#issuecomment-629649870 Thanks for reviewing, patching and merging these changes! @tillrohrmann This is an automated message from the

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-16 Thread GitBox
KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r426154092 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/externalresource/ExternalResourceUtilsTest.java ## @@ -0,0 +1,247 @@ +/* + *

[GitHub] [flink] zentol commented on a change in pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

2020-05-16 Thread GitBox
zentol commented on a change in pull request #12172: URL: https://github.com/apache/flink/pull/12172#discussion_r426154375 ## File path: flink-end-to-end-tests/test-scripts/common_docker.sh ## @@ -33,8 +33,25 @@ function containers_health_check() { done } -function

[GitHub] [flink] lirui-apache commented on a change in pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

2020-05-16 Thread GitBox
lirui-apache commented on a change in pull request #12108: URL: https://github.com/apache/flink/pull/12108#discussion_r426155122 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/OperationConverterUtils.java ## @@ -0,0

[jira] [Commented] (FLINK-14902) JDBCTableSource support AsyncLookupFunction

2020-05-16 Thread hailong wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14902?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109068#comment-17109068 ] hailong wang commented on FLINK-14902: -- Hi [~jark] [~phoenixjiangnan] [~lzljs3620320] . In my inner

[GitHub] [flink] zentol commented on a change in pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

2020-05-16 Thread GitBox
zentol commented on a change in pull request #12172: URL: https://github.com/apache/flink/pull/12172#discussion_r426154375 ## File path: flink-end-to-end-tests/test-scripts/common_docker.sh ## @@ -33,8 +33,25 @@ function containers_health_check() { done } -function

[GitHub] [flink] zentol commented on a change in pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

2020-05-16 Thread GitBox
zentol commented on a change in pull request #12172: URL: https://github.com/apache/flink/pull/12172#discussion_r426154414 ## File path: flink-end-to-end-tests/test-scripts/container-scripts/docker-compose.test.yml ## @@ -16,15 +16,31 @@ # limitations under the License.

[GitHub] [flink] zentol commented on a change in pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

2020-05-16 Thread GitBox
zentol commented on a change in pull request #12172: URL: https://github.com/apache/flink/pull/12172#discussion_r426154414 ## File path: flink-end-to-end-tests/test-scripts/container-scripts/docker-compose.test.yml ## @@ -16,15 +16,31 @@ # limitations under the License.

[GitHub] [flink] zentol commented on a change in pull request #12172: [FLINK-17656][tests] Migrate docker e2e tests to flink-docker

2020-05-16 Thread GitBox
zentol commented on a change in pull request #12172: URL: https://github.com/apache/flink/pull/12172#discussion_r426154375 ## File path: flink-end-to-end-tests/test-scripts/common_docker.sh ## @@ -33,8 +33,25 @@ function containers_health_check() { done } -function

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

2020-05-16 Thread GitBox
KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r426154092 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/externalresource/ExternalResourceUtilsTest.java ## @@ -0,0 +1,247 @@ +/* + *

[GitHub] [flink] wuchong commented on a change in pull request #12150: [FLINK-17026][kafka] Introduce a new Kafka connect or with new proper…

2020-05-16 Thread GitBox
wuchong commented on a change in pull request #12150: URL: https://github.com/apache/flink/pull/12150#discussion_r426140408 ## File path: flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java ## @@ -0,0

[GitHub] [flink] lirui-apache commented on a change in pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

2020-05-16 Thread GitBox
lirui-apache commented on a change in pull request #12108: URL: https://github.com/apache/flink/pull/12108#discussion_r426153661 ## File path: flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/SqlPartitionUtils.java ## @@ -0,0 +1,61 @@ +/* + * Licensed to

[jira] [Updated] (FLINK-17755) Support side-output of expiring states with TTL.

2020-05-16 Thread Roey Shem Tov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roey Shem Tov updated FLINK-17755: -- Description: When we set a StateTTLConfig to StateDescriptor, then when a record has been

[jira] [Closed] (FLINK-17739) ResultPartitionTest.testInitializeMoreStateThanBuffer is unstable

2020-05-16 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17739. Resolution: Fixed Merged in master: 7796f6e9601cdec3e1377acbfa212e6cfb36f793 >

[jira] [Resolved] (FLINK-15629) Remove LegacyScheduler class and the consequently unused codes after this removal

2020-05-16 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-15629. --- Release Note: Flink no longer supports the legacy scheduler. Hence, setting

[GitHub] [flink] flinkbot edited a comment on pull request #12168: [WIP][FLINK-14255][hive] Integrate hive to streaming file sink

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12168: URL: https://github.com/apache/flink/pull/12168#issuecomment-629179735 ## CI report: * 3d9fae500f937919da069b2d2e973a9369e7795f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12171: [FLINK-17715][sql client] Supports function DDLs in SQL-CLI

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12171: URL: https://github.com/apache/flink/pull/12171#issuecomment-629218919 ## CI report: * c96c7e2cfaa3ca243d8e777b7e1c6c60e62cf0d2 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12176: [FLINK-17029][jdbc]Introduce a new JDBC connector with new property keys

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12176: URL: https://github.com/apache/flink/pull/12176#issuecomment-629283127 ## CI report: * 499722944af576d13757da75f4ad0d08c4538782 Azure:

[GitHub] [flink] tillrohrmann closed pull request #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes

2020-05-16 Thread GitBox
tillrohrmann closed pull request #10883: URL: https://github.com/apache/flink/pull/10883 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

[GitHub] [flink] flinkbot edited a comment on pull request #12145: [FLINK-17428] [table-planner-blink] supports projection push down on new table source interface in blink planner

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12145: URL: https://github.com/apache/flink/pull/12145#issuecomment-628490262 ## CI report: * 700825f14b6128048bf2aec22947f30eaef40100 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12073: [FLINK-17735][table] Add specialized collecting iterator to Blink planner

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12073: URL: https://github.com/apache/flink/pull/12073#issuecomment-626524463 ## CI report: * 424d752d1d5e49c752ccd79561ce5cfcd5ea7d1d UNKNOWN * e85225100da7e5d3f06934fa331c1712a0ed4354 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #12108: [FLINK-17448][sql-parser][table-api-java][table-planner-blink][hive] Implement table DDLs for Hive dialect part2

2020-05-16 Thread GitBox
flinkbot edited a comment on pull request #12108: URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642 ## CI report: * 66bbeb2e19f810744287740e7a691da17ebb8b0c Azure:

[GitHub] [flink] zhijiangW commented on pull request #12182: [FLINK-17739][network][tests] Fix unstable ResultPartitionTest#testInitializeMoreStateThanBuffer

2020-05-16 Thread GitBox
zhijiangW commented on pull request #12182: URL: https://github.com/apache/flink/pull/12182#issuecomment-629644451 Thanks for the review @pnowojski and unrelated failures in azure, merging! This is an automated message from

[GitHub] [flink] flinkbot commented on pull request #12190: [FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread GitBox
flinkbot commented on pull request #12190: URL: https://github.com/apache/flink/pull/12190#issuecomment-62961 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

[GitHub] [flink] zhijiangW merged pull request #12182: [FLINK-17739][network][tests] Fix unstable ResultPartitionTest#testInitializeMoreStateThanBuffer

2020-05-16 Thread GitBox
zhijiangW merged pull request #12182: URL: https://github.com/apache/flink/pull/12182 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

[GitHub] [flink] danny0405 opened a new pull request #12190: [FLINK-17757] Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread GitBox
danny0405 opened a new pull request #12190: URL: https://github.com/apache/flink/pull/12190 …eriazation schema of RowData type Add new factory for Avro RowData format. ## Verifying this change Added UTs. ## Documentation - Does this pull request

[GitHub] [flink] StephanEwen commented on a change in pull request #12137: [FLINK-16177][FLINK-16357][checkpointing] Complete / improve checkpointing for OperatorCoordinators

2020-05-16 Thread GitBox
StephanEwen commented on a change in pull request #12137: URL: https://github.com/apache/flink/pull/12137#discussion_r426152842 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java ## @@ -186,10 +188,18 @@ private void

[jira] [Updated] (FLINK-17757) Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17757: --- Labels: pull-request-available (was: ) > Implement format factory for Avro serialization

[GitHub] [flink] tillrohrmann commented on pull request #10883: [FLINK-15629][runtime] Remove LegacyScheduler class and the consequently unused codes

2020-05-16 Thread GitBox
tillrohrmann commented on pull request #10883: URL: https://github.com/apache/flink/pull/10883#issuecomment-629643788 Failing test case seems to be unrelated. Merging this PR now. This is an automated message from the Apache

[GitHub] [flink] tillrohrmann closed pull request #10899: [FLINK-15668][tests] Remove travis test stages for legacy scheduler

2020-05-16 Thread GitBox
tillrohrmann closed pull request #10899: URL: https://github.com/apache/flink/pull/10899 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

[jira] [Created] (FLINK-17757) Implement format factory for Avro serialization and deseriazation schema of RowData type

2020-05-16 Thread Danny Chen (Jira)
Danny Chen created FLINK-17757: -- Summary: Implement format factory for Avro serialization and deseriazation schema of RowData type Key: FLINK-17757 URL: https://issues.apache.org/jira/browse/FLINK-17757

<    1   2   3   4   5   6   >