[jira] [Updated] (FLINK-13376) FileInputFormat can not be used in batch mode of blink-planner

[ https://issues.apache.org/jira/browse/FLINK-13376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13376: - Priority: Blocker (was: Major) > FileInputFormat can not be used in batch mode of

[GitHub] [flink] TisonKun commented on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan"

TisonKun commented on issue #9176: [hotfix][client] Fix PreviewPlanEnvironment missing set up field "plan" URL: https://github.com/apache/flink/pull/9176#issuecomment-514062316 cc @aljoscha This is an automated message from

[GitHub] [flink] flinkbot edited a comment on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

flinkbot edited a comment on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-513459343 ## CI report: * 0bbaac120acf9042279412e19d4317134821092f : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

flinkbot edited a comment on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api URL: https://github.com/apache/flink/pull/9203#issuecomment-514046368 ## CI report: * f5e680b52e6a85e85642fc22a41724c5a452505c : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration

flinkbot edited a comment on issue #8303: [FLINK-12343] [flink-yarn] add file replication config for yarn configuration URL: https://github.com/apache/flink/pull/8303#issuecomment-511684151 ## CI report: * 6a7ca58b4a04f6dce250045e021702e67e82b893 : FAILURE

[jira] [Updated] (FLINK-13376) FileInputFormat can not be used in batch mode of blink-planner

[ https://issues.apache.org/jira/browse/FLINK-13376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-13376: - Summary: FileInputFormat can not be used in batch mode of blink-planner (was: FileInputFormat

[jira] [Commented] (FLINK-13376) FileInputFormat can not be used in batch mode of blink-planner

[ https://issues.apache.org/jira/browse/FLINK-13376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890686#comment-16890686 ] Jingsong Lee commented on FLINK-13376: -- CC: [~TsReaper] [~sunhaibotb] [~pnowojski] What do you

[jira] [Created] (FLINK-13376) FileInputFormat can not be used in blink-planner

Jingsong Lee created FLINK-13376: Summary: FileInputFormat can not be used in blink-planner Key: FLINK-13376 URL: https://issues.apache.org/jira/browse/FLINK-13376 Project: Flink Issue Type:

[GitHub] [flink] TsReaper commented on issue #9197: [FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner

TsReaper commented on issue #9197: [FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner URL: https://github.com/apache/flink/pull/9197#issuecomment-514059159 Travis passed:

[GitHub] [flink] xintongsong commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

xintongsong commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#discussion_r306133278 ## File path:

[GitHub] [flink] wuchong closed pull request #9150: [FLINK-13227][docs-zh] Translate "asyncio" page into Chinese

wuchong closed pull request #9150: [FLINK-13227][docs-zh] Translate "asyncio" page into Chinese URL: https://github.com/apache/flink/pull/9150 This is an automated message from the Apache Git Service. To respond to the

[jira] [Resolved] (FLINK-13227) Translate "Asynchronous I/O for External Data Access" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13227. - Resolution: Fixed Fix Version/s: 1.10.0 Merged in 1.10.0:

[GitHub] [flink] flinkbot edited a comment on issue #9173: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese

flinkbot edited a comment on issue #9173: [FLINK-13037][docs-zh] Translate "Concepts -> Glossary" page into Chinese URL: https://github.com/apache/flink/pull/9173#issuecomment-513163906 ## CI report: * 14f3c3b418f898c987e26ea8613a682064c03f20 : SUCCESS

[GitHub] [flink] wuchong commented on issue #9150: [FLINK-13227][docs-zh] Translate "asyncio" page into Chinese

wuchong commented on issue #9150: [FLINK-13227][docs-zh] Translate "asyncio" page into Chinese URL: https://github.com/apache/flink/pull/9150#issuecomment-514057391 Merging... This is an automated message from the Apache

[jira] [Commented] (FLINK-13353) Wrong definition of REPLACE planner expression

[ https://issues.apache.org/jira/browse/FLINK-13353?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890679#comment-16890679 ] Jark Wu commented on FLINK-13353: - So, let's remove the 2nd arg constructor in this issue? > Wrong

[jira] [Commented] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890678#comment-16890678 ] Jark Wu commented on FLINK-13343: - Sure [~highfei2...@126.com], I will have a look in the next days. >

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] xuefuz commented on issue #9149: [FLINK-13303][hive] Add e2e test for hive connector

xuefuz commented on issue #9149: [FLINK-13303][hive] Add e2e test for hive connector URL: https://github.com/apache/flink/pull/9149#issuecomment-514055344 Hi @twalthr , Given that Bowen is on the leave, we are short of bandwidth at the moment. Thus, we have to push this back for a while.

[jira] [Comment Edited] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890664#comment-16890664 ] Jeff Yang edited comment on FLINK-13343 at 7/23/19 5:03 AM: Hi,[~jark], I 

[GitHub] [flink] flinkbot edited a comment on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

flinkbot edited a comment on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#issuecomment-511360277 ## CI report: * b6bb574fbe0e3421adb07aef7ffd1c8068675a74 : FAILURE

[jira] [Commented] (FLINK-13375) Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

[ https://issues.apache.org/jira/browse/FLINK-13375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890666#comment-16890666 ] Jark Wu commented on FLINK-13375: - Yes [~jinyu.zj]. But that is another issue, we can discuss that in a

[jira] [Comment Edited] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890664#comment-16890664 ] Jeff Yang edited comment on FLINK-13343 at 7/23/19 4:25 AM: Hi,[~jark], I 

[jira] [Commented] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890664#comment-16890664 ] Jeff Yang commented on FLINK-13343: --- Hi,[~jark], I have resolved, thanks. Please take a look this

[jira] [Updated] (FLINK-13343) Translate "Contribute Code" page into Chinese

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

[GitHub] [flink] wuchong commented on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

wuchong commented on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api URL: https://github.com/apache/flink/pull/9203#issuecomment-514048343 cc @twalthr @aljoscha @dawidwys . We can review and discuss config option names in this pull

[GitHub] [flink] flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-513776716 ## CI report: * 39f1f2911dfb5a323793447715276aa727bfe5dc : FAILURE

[GitHub] [flink] guoweiM commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN.

guoweiM commented on a change in pull request #9106: [FLINK-13184][yarn] Support launching task executors with multi-thread on YARN. URL: https://github.com/apache/flink/pull/9106#discussion_r306122204 ## File path:

[GitHub] [flink] flinkbot commented on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

flinkbot commented on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api URL: https://github.com/apache/flink/pull/9203#issuecomment-514046368 ## CI report: * f5e680b52e6a85e85642fc22a41724c5a452505c : PENDING

[GitHub] [flink] wuchong commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

wuchong commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-514045457 I just created a pull request #9203 for config options.

[GitHub] [flink] flinkbot commented on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

flinkbot commented on issue #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api URL: https://github.com/apache/flink/pull/9203#issuecomment-514044693 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help

[jira] [Updated] (FLINK-13375) Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

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

[GitHub] [flink] wuchong opened a new pull request #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

wuchong opened a new pull request #9203: [FLINK-13375][table-api] Move ExecutionConfigOptions and OptimizerConfigOptions to table-api URL: https://github.com/apache/flink/pull/9203 ## What is the purpose of the change This pull request moves `ExecutionConfigOptions` and

[GitHub] [flink] flinkbot edited a comment on issue #9179: [FLINK-13117][table-planner-blink] Do not need to backup and restore …

flinkbot edited a comment on issue #9179: [FLINK-13117][table-planner-blink] Do not need to backup and restore … URL: https://github.com/apache/flink/pull/9179#issuecomment-513163955 ## CI report: * 087517ce553b248c3d35b871ec49d2f27ef6051f : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-513776716 ## CI report: * 39f1f2911dfb5a323793447715276aa727bfe5dc : FAILURE

[jira] [Commented] (FLINK-13375) Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

[ https://issues.apache.org/jira/browse/FLINK-13375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890646#comment-16890646 ] Jing Zhang commented on FLINK-13375: Good proposal. It's better to create `TableConfigOptions` in

[GitHub] [flink] flinkbot edited a comment on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

flinkbot edited a comment on issue #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#issuecomment-511360277 ## CI report: * b6bb574fbe0e3421adb07aef7ffd1c8068675a74 : FAILURE

[jira] [Updated] (FLINK-13375) Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

[ https://issues.apache.org/jira/browse/FLINK-13375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13375: Issue Type: Sub-task (was: Improvement) Parent: FLINK-13267 > Move ExecutionConfigOptions and

[GitHub] [flink] zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option

zhuzhurk commented on a change in pull request #9113: [FLINK-13222] [runtime] Add documentation for failover strategy option URL: https://github.com/apache/flink/pull/9113#discussion_r306112407 ## File path: docs/dev/task_failure_recovery.zh.md ## @@ -260,4 +265,50 @@

[jira] [Created] (FLINK-13375) Move ExecutionConfigOptions and OptimizerConfigOptions to table-api

Jark Wu created FLINK-13375: --- Summary: Move ExecutionConfigOptions and OptimizerConfigOptions to table-api Key: FLINK-13375 URL: https://issues.apache.org/jira/browse/FLINK-13375 Project: Flink

[jira] [Commented] (FLINK-13143) Clear CheckpointExceptionHandler relevant classes

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890637#comment-16890637 ] vinoyang commented on FLINK-13143: -- Hi [~till.rohrmann] Maybe I should not use "*Clear*" keyword here

[jira] [Updated] (FLINK-13143) Refactor CheckpointExceptionHandler relevant classes

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13143: - Summary: Refactor CheckpointExceptionHandler relevant classes (was: Clear CheckpointExceptionHandler

[GitHub] [flink] flinkbot edited a comment on issue #9197: [FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner

flinkbot edited a comment on issue #9197: [FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner URL: https://github.com/apache/flink/pull/9197#issuecomment-513729370 ## CI report: *

[GitHub] [flink] wuchong commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

wuchong commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-514034587 Regarding to the config options, I got some other feedbacks from Timo in #9024. I think we should start a new

[jira] [Commented] (FLINK-13245) Network stack is leaking files

[ https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890630#comment-16890630 ] zhijiang commented on FLINK-13245: -- [~azagrebin] I totally agree with your above point. The first

[GitHub] [flink] flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-513776716 ## CI report: * 39f1f2911dfb5a323793447715276aa727bfe5dc : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] dianfu commented on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

dianfu commented on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-514031131 @WeiZhong94 Thanks a lot for the update. LGTM to me. +1 from my side.

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

Zhenghua Gao created FLINK-13374: Summary: flink-table-planner-blink compile failed for scala-2.12 on travis Key: FLINK-13374 URL: https://issues.apache.org/jira/browse/FLINK-13374 Project: Flink

[GitHub] [flink] WeiZhong94 commented on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

WeiZhong94 commented on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-514030799 @dianfu Thanks a lot for your review! I have addressed your comments.

[GitHub] [flink] godfreyhe commented on a change in pull request #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

godfreyhe commented on a change in pull request #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#discussion_r306107863 ## File path:

[GitHub] [flink] wuchong commented on issue #9024: [FLINK-13119] add blink table config to documentation

wuchong commented on issue #9024: [FLINK-13119] add blink table config to documentation URL: https://github.com/apache/flink/pull/9024#issuecomment-514029686 @twalthr Sure. It makes sense to continue this before we reach a consensus.

[GitHub] [flink] beyond1920 commented on issue #9193: [FLINK-13318][table-planner-blink] Fix Blink planner tests failing on Scala 2.12 by setting SerialVersionUID of UDF explicitly

beyond1920 commented on issue #9193: [FLINK-13318][table-planner-blink] Fix Blink planner tests failing on Scala 2.12 by setting SerialVersionUID of UDF explicitly URL: https://github.com/apache/flink/pull/9193#issuecomment-514029207 +1 to wuchong's opinion. In fact, we don't need to

[jira] [Commented] (FLINK-11696) Avoid to send mkdir requests to DFS from task side

[ https://issues.apache.org/jira/browse/FLINK-11696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890622#comment-16890622 ] frank wang commented on FLINK-11696: We will assemble your code and adopt scenario 2 in our

[jira] [Commented] (FLINK-11696) Avoid to send mkdir requests to DFS from task side

[ https://issues.apache.org/jira/browse/FLINK-11696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890620#comment-16890620 ] frank wang commented on FLINK-11696: We have also encountered similar problems. We originally had

[GitHub] [flink] wuchong commented on issue #9193: [FLINK-13318][table-planner-blink] Fix Blink planner tests failing on Scala 2.12 by setting SerialVersionUID of UDF explicitly

wuchong commented on issue #9193: [FLINK-13318][table-planner-blink] Fix Blink planner tests failing on Scala 2.12 by setting SerialVersionUID of UDF explicitly URL: https://github.com/apache/flink/pull/9193#issuecomment-514028089 Hi @twalthr , this is because 1. we print the

[GitHub] [flink] flinkbot edited a comment on issue #9179: [FLINK-13117][table-planner-blink] Do not need to backup and restore …

flinkbot edited a comment on issue #9179: [FLINK-13117][table-planner-blink] Do not need to backup and restore … URL: https://github.com/apache/flink/pull/9179#issuecomment-513163955 ## CI report: * 087517ce553b248c3d35b871ec49d2f27ef6051f : FAILURE

[jira] [Commented] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890617#comment-16890617 ] Jeff Yang commented on FLINK-13343: --- Hi,[~jark],It is done,but there are some sentence do not

[jira] [Updated] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Yang updated FLINK-13343: -- Attachment: image-2019-07-23-10-16-30-283.png > Translate "Contribute Code" page into Chinese >

[GitHub] [flink] wuchong commented on issue #9150: [FLINK-13227][docs-zh] Translate "asyncio" page into Chinese

wuchong commented on issue #9150: [FLINK-13227][docs-zh] Translate "asyncio" page into Chinese URL: https://github.com/apache/flink/pull/9150#issuecomment-514025654 Do you have any other comments @klion26 ? This is an

[GitHub] [flink] flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases

flinkbot edited a comment on issue #9180: [FLINK-13331][table-planner-blink] Add CachedMiniCluster to share cluster between ITCases URL: https://github.com/apache/flink/pull/9180#issuecomment-513163961 ## CI report: * f563446dc5923ef86883f03f5fe899c4ffc92c57 : FAILURE

[GitHub] [flink] wuchong closed pull request #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer resto

wuchong closed pull request #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[jira] [Resolved] (FLINK-13323) Add tests for complex data formats

[ https://issues.apache.org/jira/browse/FLINK-13323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13323. - Resolution: Fixed Fixed in 1.9.0: 2f4ff4e775b13cac48ee3a369d4eff2368a49de7 > Add tests for complex

[GitHub] [flink] wuchong commented on issue #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restor

wuchong commented on issue #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[GitHub] [flink] klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… URL: https://github.com/apache/flink/pull/9188#discussion_r306102808 ## File path: docs/dev/connectors/cassandra.zh.md ## @@ -43,77 +43,68 @@ To use

[GitHub] [flink] klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… URL: https://github.com/apache/flink/pull/9188#discussion_r306103036 ## File path: docs/dev/connectors/cassandra.zh.md ## @@ -130,9 +121,8 @@ CREATE

[GitHub] [flink] klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… URL: https://github.com/apache/flink/pull/9188#discussion_r306101739 ## File path: docs/dev/connectors/cassandra.zh.md ## @@ -43,77 +43,68 @@ To use

[jira] [Resolved] (FLINK-13304) Fix implementation of getString and getBinary method in NestedRow

[ https://issues.apache.org/jira/browse/FLINK-13304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13304. - Resolution: Fixed Fixed in 1.9.0: b62e22c40ea49936981ad3c8ccd0a2564bc88d86 > Fix implementation of

[GitHub] [flink] klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… URL: https://github.com/apache/flink/pull/9188#discussion_r306100200 ## File path: docs/dev/connectors/cassandra.zh.md ## @@ -43,77 +43,68 @@ To use

[GitHub] [flink] klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… URL: https://github.com/apache/flink/pull/9188#discussion_r306102986 ## File path: docs/dev/connectors/cassandra.zh.md ## @@ -43,77 +43,68 @@ To use

[GitHub] [flink] klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into…

klion26 commented on a change in pull request #9188: [FLINK-12940][docs-zh] Translate Apache Cassandra Connector page into… URL: https://github.com/apache/flink/pull/9188#discussion_r306101635 ## File path: docs/dev/connectors/cassandra.zh.md ## @@ -43,77 +43,68 @@ To use

[jira] [Resolved] (FLINK-13322) Fix serializer snapshot recovery in BaseArray and BaseMap serializers.

[ https://issues.apache.org/jira/browse/FLINK-13322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu resolved FLINK-13322. - Resolution: Fixed Fixed in 1.9.0: 56e45c8397bdaf3a8dec45164021c54db5b47e7e > Fix serializer snapshot

[jira] [Updated] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Yang updated FLINK-13343: -- Attachment: image-2019-07-23-10-09-48-805.png > Translate "Contribute Code" page into Chinese >

[GitHub] [flink] xintongsong commented on issue #9022: [FLINK-13127] Fix --yarnship classpath

xintongsong commented on issue #9022: [FLINK-13127] Fix --yarnship classpath URL: https://github.com/apache/flink/pull/9022#issuecomment-514024113 Hi @dmvk, Thanks for opening this PR. I think this is a helpful contribution. A few comments: 1. I think it would be better if you could

[jira] [Updated] (FLINK-13343) Translate "Contribute Code" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Yang updated FLINK-13343: -- Attachment: image-2019-07-23-10-07-20-921.png > Translate "Contribute Code" page into Chinese >

[GitHub] [flink] wuchong commented on issue #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restor

wuchong commented on issue #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[GitHub] [flink] flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

flinkbot edited a comment on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-513776716 ## CI report: * 39f1f2911dfb5a323793447715276aa727bfe5dc : FAILURE

[GitHub] [flink] godfreyhe commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

godfreyhe commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-514022957 > From what I see,

[GitHub] [flink] wuchong commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

wuchong commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-514022773 > Some general feedback regarding `ExecutionConfigOptions`. We are now moving it to the API module. We should

[GitHub] [flink] WeiZhong94 commented on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

WeiZhong94 commented on issue #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#issuecomment-514022086 @sunjincheng121 Thanks a lot for your review! I have combined these test cases into one in the

[GitHub] [flink] wuchong commented on a change in pull request #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

wuchong commented on a change in pull request #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#discussion_r306099800 ## File path:

[GitHub] [flink] KurtYoung commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

KurtYoung commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-51401 > Some general feedback regarding `ExecutionConfigOptions`. We are now moving it to the API module. We

[GitHub] [flink] KurtYoung commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes

KurtYoung commented on issue #9185: [FLINK-13266] [table] Relocate blink planner classes to avoid class clashes URL: https://github.com/apache/flink/pull/9185#issuecomment-514019072 > From what I see,

[GitHub] [flink] flinkbot edited a comment on issue #9197: [FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner

flinkbot edited a comment on issue #9197: [FLINK-13075][table-planner-blink] Project pushdown rule shouldn't require the TableSource return a modified schema in blink planner URL: https://github.com/apache/flink/pull/9197#issuecomment-513729370 ## CI report: *

[jira] [Commented] (FLINK-13242) StandaloneResourceManagerTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890585#comment-16890585 ] Xintong Song commented on FLINK-13242: -- [~azagrebin] I agree. The purpose of scheduling to invoke

[GitHub] [flink] KurtYoung closed pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

KurtYoung closed pull request #9101: [FLINK-13221][Table SQL / Planner] Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs URL: https://github.com/apache/flink/pull/9101 This

[jira] [Closed] (FLINK-13221) Blink planner should set ScheduleMode to LAZY_FROM_SOURCES_WITH_BATCH_SLOT_REQUEST for batch jobs

[ https://issues.apache.org/jira/browse/FLINK-13221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-13221. -- Resolution: Fixed merged in 1.10.0: d5cb1b9e5aefdc73026985f67a991f099e8f4364 merged in 1.9.0: 

[GitHub] [flink] TsReaper commented on issue #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer resto

TsReaper commented on issue #9154: [FLINK-13304][FLINK-13322][FLINK-13323][table-runtime-blink] Fix implementation of getString and getBinary method in NestedRow, fix serializer restore in BaseArray/Map serializer and add tests for complex data formats URL:

[GitHub] [flink] dianfu commented on a change in pull request #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

dianfu commented on a change in pull request #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#discussion_r306092023 ## File path: flink-python/pyflink/common/configuration.py ## @@

[GitHub] [flink] dianfu commented on a change in pull request #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java.

dianfu commented on a change in pull request #9199: [FLINK-13368][python] Add Configuration Class for Python Table API to Align with Java. URL: https://github.com/apache/flink/pull/9199#discussion_r306092320 ## File path: flink-python/pyflink/common/configuration.py ## @@

[jira] [Assigned] (FLINK-12887) Schedule UnfencedMessage would lost envelope info

[ https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi reassigned FLINK-12887: Assignee: TisonKun (was: Xiaogang Shi) > Schedule UnfencedMessage would lost envelope

[jira] [Assigned] (FLINK-12887) Schedule UnfencedMessage would lost envelope info

[ https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xiaogang Shi reassigned FLINK-12887: Assignee: Xiaogang Shi > Schedule UnfencedMessage would lost envelope info >

[jira] [Comment Edited] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887694#comment-16887694 ] TisonKun edited comment on FLINK-11843 at 7/23/19 12:58 AM: [~till.rohrmann]

[jira] [Comment Edited] (FLINK-11843) Dispatcher fails to recover jobs if leader change happens during JobManagerRunner termination

[ https://issues.apache.org/jira/browse/FLINK-11843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887694#comment-16887694 ] TisonKun edited comment on FLINK-11843 at 7/23/19 12:58 AM: [~till.rohrmann]

[GitHub] [flink] flinkbot edited a comment on issue #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

flinkbot edited a comment on issue #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9202#issuecomment-513957292 ## CI report: * 1a4870b8e0293f353cb895279b898421e84cc353 : FAILURE

[GitHub] [flink] sjwiesman closed pull request #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

sjwiesman closed pull request #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9202 This is an automated message from the Apache Git Service. To respond

[GitHub] [flink] flinkbot commented on issue #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

flinkbot commented on issue #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9202#issuecomment-513957292 ## CI report: * 1a4870b8e0293f353cb895279b898421e84cc353 : PENDING

[GitHub] [flink] flinkbot commented on issue #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

flinkbot commented on issue #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9202#issuecomment-513955281 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] sjwiesman opened a new pull request #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough

sjwiesman opened a new pull request #9202: [FLINK-12746][docs] Getting Started - DataStream Example Walkthrough URL: https://github.com/apache/flink/pull/9202 ## What is the purpose of the change As part of FLIP-42 we want to add a datastream walkthrough that new users can use to

[jira] [Commented] (FLINK-12746) Getting Started - Project Setup and DataStream Example Walkthrough

[ https://issues.apache.org/jira/browse/FLINK-12746?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890472#comment-16890472 ] Seth Wiesman commented on FLINK-12746: -- I'm moving the restructuring into a different ticket:

  1   2   3   4   5   >