[jira] [Created] (FLINK-12218) Report more record information in IOMetrics for Speculative Schedule

BoWang created FLINK-12218: -- Summary: Report more record information in IOMetrics for Speculative Schedule Key: FLINK-12218 URL: https://issues.apache.org/jira/browse/FLINK-12218 Project: Flink Iss

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819778#comment-16819778 ] Yingjie Cao commented on FLINK-12070: - I'd like to perform a test to compare the per

[jira] [Updated] (FLINK-11309) Make SpillableSubpartition repeatably read to enable

[ https://issues.apache.org/jira/browse/FLINK-11309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang updated FLINK-11309: --- Issue Type: Sub-task (was: Bug) Parent: FLINK-10644 > Make SpillableSubpartition repeatably read to

[jira] [Comment Edited] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819774#comment-16819774 ] BoWang edited comment on FLINK-10644 at 4/17/19 6:49 AM: - Thanks

[jira] [Assigned] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] BoWang reassigned FLINK-10644: -- Assignee: BoWang (was: ryantaocer) > Batch Job: Speculative execution >

[jira] [Commented] (FLINK-10644) Batch Job: Speculative execution

[ https://issues.apache.org/jira/browse/FLINK-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819774#comment-16819774 ] BoWang commented on FLINK-10644: Thanks [~greghogan] for the comments. 1) we use severa

[GitHub] [flink] zhijiangW edited a comment on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes

zhijiangW edited a comment on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes URL: https://github.com/apache/flink/pull/8181#issuecomment-483946313 After further thinking through this issue, the current created local/remote counte

[jira] [Updated] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

[ https://issues.apache.org/jira/browse/FLINK-12216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12216: --- Labels: pull-request-available (was: ) > Respect the number of bytes from input parameters

[GitHub] [flink] flinkbot commented on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete…

flinkbot commented on issue #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete… URL: https://github.com/apache/flink/pull/8194#issuecomment-483957785 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to revi

[GitHub] [flink] liyafan82 opened a new pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete…

liyafan82 opened a new pull request #8194: [FLINK-12216][Runtime]Respect the number of bytes from input paramete… URL: https://github.com/apache/flink/pull/8194 …rs in HybridMemorySegment ## What is the purpose of the change Fix some bugs in class HybridMemorySegment.

[GitHub] [flink] kpapadopoul commented on issue #8186: [FLINK-12198] Flink JDBC Connector: Update existing JDBCInputFormat t…

kpapadopoul commented on issue #8186: [FLINK-12198] Flink JDBC Connector: Update existing JDBCInputFormat t… URL: https://github.com/apache/flink/pull/8186#issuecomment-483957756 I agree with you, @walterddr. I tried to be compliant with the 'setFetchSize' implementation. I will fix it imm

[GitHub] [flink] flinkbot commented on issue #8193: [hotfix] load globalConfiguration from configurationDir

flinkbot commented on issue #8193: [hotfix] load globalConfiguration from configurationDir URL: https://github.com/apache/flink/pull/8193#issuecomment-483957340 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull re

[GitHub] [flink] Tom-Goong opened a new pull request #8193: [hotfix] load globalConfiguration from configurationDir

Tom-Goong opened a new pull request #8193: [hotfix] load globalConfiguration from configurationDir URL: https://github.com/apache/flink/pull/8193 ## What is the purpose of the change the configuration and the configDir may dismatch ## Brief change log load globalConfiguration

[jira] [Assigned] (FLINK-12198) Flink JDBC Connector: Update existing JDBCInputFormat to support setting auto-commit mode of DB connection

[ https://issues.apache.org/jira/browse/FLINK-12198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantinos Papadopoulos reassigned FLINK-12198: - Assignee: Konstantinos Papadopoulos > Flink JDBC Connector: Upd

[GitHub] [flink] flinkbot edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

flinkbot edited a comment on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-474185108 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the commu

[GitHub] [flink] sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

sunjincheng121 commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-483952943 @xuefuz thanks for the update! +1 to merged. @flinkbot approve all Best, Jinc

[GitHub] [flink] flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483933291 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[GitHub] [flink] flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

flinkbot edited a comment on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483933291 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I h

[jira] [Commented] (FLINK-12068) Backtrack fail over regions if intermediate results are unavailable

[ https://issues.apache.org/jira/browse/FLINK-12068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819761#comment-16819761 ] Zhu Zhu commented on FLINK-12068: - Per discussion with [~Zentol], I will work on the imp

[GitHub] [flink] dawidwys commented on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

dawidwys commented on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483952144 @flinkbot approve all This i

[jira] [Assigned] (FLINK-12068) Backtrack fail over regions if intermediate results are unavailable

[ https://issues.apache.org/jira/browse/FLINK-12068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu reassigned FLINK-12068: --- Assignee: Zhu Zhu > Backtrack fail over regions if intermediate results are unavailable > -

[jira] [Closed] (FLINK-12174) Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

[ https://issues.apache.org/jira/browse/FLINK-12174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-12174. Resolution: Fixed Fix Version/s: 1.9.0 Implemented in 9d0951ecf2466e7b27e41b2fa894a

[GitHub] [flink] dawidwys merged pull request #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences

dawidwys merged pull request #8162: [FLINK-12174][table] Introduce FlinkAggregateExtractProjectRule and remove extractFieldReferences URL: https://github.com/apache/flink/pull/8162 This is an automated message from the Apach

[GitHub] [flink] sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface

sunhaibotb commented on a change in pull request #8124: [FLINK-11877] Implement the runtime handling of the InputSelectable interface URL: https://github.com/apache/flink/pull/8124#discussion_r276090295 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/p

[GitHub] [flink] JingsongLi commented on issue #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch

JingsongLi commented on issue #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch URL: https://github.com/apache/flink/pull/8184#issuecomment-483947351 @wuchong Deduplicated cases and move some ITCases to expression test and Merge Class to Accelerate Testing ---

[GitHub] [flink] zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes

zhijiangW commented on issue #8181: [FLINK-12199][network] Refactor IOMetrics to not distinguish between local/remote in/out bytes URL: https://github.com/apache/flink/pull/8181#issuecomment-483946313 After further thinking through this issue, the current created local/remote counter would

[GitHub] [flink] JingsongLi commented on issue #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch

JingsongLi commented on issue #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch URL: https://github.com/apache/flink/pull/8184#issuecomment-483933526 > The changes to lpad and rpad looks good to me. > > Btw, I would suggest to move tests in `BuiltInFunctionsI

[GitHub] [flink] flinkbot commented on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

flinkbot commented on issue #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192#issuecomment-483933291 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-12217) OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

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

[GitHub] [flink] hequn8128 opened a new pull request #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

hequn8128 opened a new pull request #8192: [FLINK-12217][table] OperationTreeBuilder.map() should perform ExpressionResolver.resolve() URL: https://github.com/apache/flink/pull/8192 ## What is the purpose of the change This pull request fixes the problem for OperationTreeBuilder.

[GitHub] [flink] JingsongLi commented on a change in pull request #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch

JingsongLi commented on a change in pull request #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch URL: https://github.com/apache/flink/pull/8184#discussion_r276075315 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table

[GitHub] [flink] zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483932037 Considering my above comments, I added the `TaskManagerMetricGroup#close` during `TaskManagerS

[jira] [Created] (FLINK-12217) OperationTreeBuilder.map() should perform ExpressionResolver.resolve()

Hequn Cheng created FLINK-12217: --- Summary: OperationTreeBuilder.map() should perform ExpressionResolver.resolve() Key: FLINK-12217 URL: https://issues.apache.org/jira/browse/FLINK-12217 Project: Flink

[jira] [Commented] (FLINK-12189) Fix bugs and typos in memory management related code

[ https://issues.apache.org/jira/browse/FLINK-12189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819706#comment-16819706 ] Liya Fan commented on FLINK-12189: -- To make the PR easier to understand to review, I ha

[jira] [Updated] (FLINK-11915) DataInputViewStream skip returns wrong value

[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-11915: - Affects Version/s: 1.6.3 1.6.4 1.7.2

[jira] [Created] (FLINK-12216) Respect the number of bytes from input parameters in HybridMemorySegment

Liya Fan created FLINK-12216: Summary: Respect the number of bytes from input parameters in HybridMemorySegment Key: FLINK-12216 URL: https://issues.apache.org/jira/browse/FLINK-12216 Project: Flink

[jira] [Assigned] (FLINK-11915) DataInputViewStream skip returns wrong value

[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu reassigned FLINK-11915: Assignee: Biao Liu > DataInputViewStream skip returns wrong value > -

[jira] [Commented] (FLINK-11915) DataInputViewStream skip returns wrong value

[ https://issues.apache.org/jira/browse/FLINK-11915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819704#comment-16819704 ] Biao Liu commented on FLINK-11915: -- Hi Andrew, Thank you for reporting and analyzing.

[GitHub] [flink] KurtYoung commented on a change in pull request #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate

KurtYoung commented on a change in pull request #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate URL: https://github.com/apache/flink/pull/8176#discussion_r276071517 ## File path: flink-table/flin

[GitHub] [flink] KurtYoung commented on a change in pull request #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate

KurtYoung commented on a change in pull request #8176: [FLINK-12192] [table-planner-blink] Add support for generating optimized logical plan for grouping sets and distinct aggregate URL: https://github.com/apache/flink/pull/8176#discussion_r276071545 ## File path: flink-table/flin

[GitHub] [flink] KurtYoung commented on a change in pull request #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch

KurtYoung commented on a change in pull request #8184: [FLINK-12211][table-planner-blink] Add more it cases to blink batch URL: https://github.com/apache/flink/pull/8184#discussion_r276068467 ## File path: flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/

[jira] [Closed] (FLINK-12185) Add support for generating optimized logical plan for join on stream

[ https://issues.apache.org/jira/browse/FLINK-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12185. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed in 963799964d83c1e61dd053d50348ceb1df812699 > Add

[GitHub] [flink] KurtYoung merged pull request #8165: [FLINK-12185] [table-planner-blink] Add support for generating optimized logical plan for join on stream

KurtYoung merged pull request #8165: [FLINK-12185] [table-planner-blink] Add support for generating optimized logical plan for join on stream URL: https://github.com/apache/flink/pull/8165 This is an automated message from t

[jira] [Updated] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-12215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-12215: Description: Currently, we are heavily using DataStream's {{KeyedProcessFunction}} when implementing Blin

[jira] [Assigned] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime

[ https://issues.apache.org/jira/browse/FLINK-12215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-12215: --- Assignee: Jark Wu > Introduce SqlProcessFunction for blink streaming runtime >

[jira] [Created] (FLINK-12215) Introduce SqlProcessFunction for blink streaming runtime

Jark Wu created FLINK-12215: --- Summary: Introduce SqlProcessFunction for blink streaming runtime Key: FLINK-12215 URL: https://issues.apache.org/jira/browse/FLINK-12215 Project: Flink Issue Type: Ne

[GitHub] [flink] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276039489 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoi

[GitHub] [flink] liyafan82 commented on issue #8183: [FLINK-12210][Runtime]Fix the bug of redundant removing of '\r'

liyafan82 commented on issue #8183: [FLINK-12210][Runtime]Fix the bug of redundant removing of '\r' URL: https://github.com/apache/flink/pull/8183#issuecomment-483905987 > I think you should add some tests to illustrate the specific situation? Good point. Thanks a lot. I will provide

[GitHub] [flink] JingsongLi commented on issue #8183: [FLINK-12210][Runtime]Fix the bug of redundant removing of '\r'

JingsongLi commented on issue #8183: [FLINK-12210][Runtime]Fix the bug of redundant removing of '\r' URL: https://github.com/apache/flink/pull/8183#issuecomment-483904353 I think you should add some tests to illustrate the specific situation? ---

[GitHub] [flink] liyafan82 commented on a change in pull request #8183: [FLINK-12210][Runtime]Fix the bug of redundant removing of '\r'

liyafan82 commented on a change in pull request #8183: [FLINK-12210][Runtime]Fix the bug of redundant removing of '\r' URL: https://github.com/apache/flink/pull/8183#discussion_r276051242 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputVi

[jira] [Commented] (FLINK-11936) Remove AuxiliaryConverter pull-in from calcite and fix auxiliary converter issue.

[ https://issues.apache.org/jira/browse/FLINK-11936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819636#comment-16819636 ] Rong Rong commented on FLINK-11936: --- Sweet. I also think making it pluggable is a good

[GitHub] [flink] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276039489 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoi

[GitHub] [flink] yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator

yanghua commented on a change in pull request #7571: [FLINK-10724] Refactor failure handling in check point coordinator URL: https://github.com/apache/flink/pull/7571#discussion_r276036342 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointExecu

[jira] [Commented] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819578#comment-16819578 ] Jeff Zhang commented on FLINK-12214: [~till.rohrmann] I think this issue is orthogon

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276006730 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276007745 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276004996 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275995942 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276010581 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276003801 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276004781 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276003882 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276003116 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276006622 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r276002130 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275987317 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275994159 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275991752 ## File path: flink-formats/flink-parquet/src/test/java/org/apache/flink/formats/parquet/ParquetTableSourceITCase.java ##

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275999431 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275988055 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275985795 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[GitHub] [flink] fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source

fhueske commented on a change in pull request #8064: [FLINK-7244] Add parquet table source URL: https://github.com/apache/flink/pull/8064#discussion_r275994008 ## File path: flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java

[jira] [Comment Edited] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819287#comment-16819287 ] Piotr Nowojski edited comment on FLINK-11974 at 4/16/19 7:08 PM: -

[jira] [Commented] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819326#comment-16819326 ] Steve Loughran commented on FLINK-8801: --- * s3a in hadoop 3.1+ lets you see etags as

[jira] [Commented] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819324#comment-16819324 ] Steve Loughran commented on FLINK-8801: --- we cant set times against objects as they

[jira] [Commented] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819318#comment-16819318 ] Till Rohrmann commented on FLINK-12214: --- I think what you need is a better program

[jira] [Comment Edited] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819287#comment-16819287 ] Piotr Nowojski edited comment on FLINK-11974 at 4/16/19 5:14 PM: -

[jira] [Commented] (FLINK-11974) Introduce StreamOperatorSubstitutor to help table perform the whole Operator CodeGen

[ https://issues.apache.org/jira/browse/FLINK-11974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819287#comment-16819287 ] Piotr Nowojski commented on FLINK-11974: I've done a little bit more research an

[jira] [Closed] (FLINK-12195) Incorrect resource time setting causes flink to fail to submit

[ https://issues.apache.org/jira/browse/FLINK-12195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tangshangwen closed FLINK-12195. Resolution: Resolved > Incorrect resource time setting causes flink to fail to submit > --

[GitHub] [flink] haf edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

haf edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-483549547 @becketqin Hi! Any progress? @Xeli Can you e-mail me the other connector you've

[GitHub] [flink] haf edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

haf edited a comment on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-481330654 When I run this code with Flink 1.7, I get this critical error when things crash:

[GitHub] [flink] xuefuz commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other …

xuefuz commented on issue #8007: [FLINK-11474][table] Add ReadableCatalog, ReadableWritableCatalog, and other … URL: https://github.com/apache/flink/pull/8007#issuecomment-483756077 PR is updated based on above discussions: 1. Changed existing exceptions to checked and added a runtim

[GitHub] [flink] zhijiangW edited a comment on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW edited a comment on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483745947 I would double check whether the `TaskManagerMetricGroup` should be closed in `TaskMana

[GitHub] [flink] zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483745947 I would double check whether the `TaskManagerMetricGroup` should be close in `TaskManagerServi

[GitHub] [flink] walterddr commented on a change in pull request #8186: [FLINK-12198] Flink JDBC Connector: Update existing JDBCInputFormat t…

walterddr commented on a change in pull request #8186: [FLINK-12198] Flink JDBC Connector: Update existing JDBCInputFormat t… URL: https://github.com/apache/flink/pull/8186#discussion_r275889475 ## File path: flink-connectors/flink-jdbc/src/test/java/org/apache/flink/api/java/io/jd

[GitHub] [flink] flinkbot edited a comment on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

flinkbot edited a comment on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483741002 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I hel

[GitHub] [flink] flinkbot commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

flinkbot commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483741002 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[GitHub] [flink] zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW commented on issue #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191#issuecomment-483740462 @flinkbot attention @azagrebin --

[jira] [Updated] (FLINK-12213) Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

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

[GitHub] [flink] zhijiangW opened a new pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment

zhijiangW opened a new pull request #8191: [FLINK-12213][network] Pass TaskManagerMetricGroup into constructor of NetworkEnvironment URL: https://github.com/apache/flink/pull/8191 ## What is the purpose of the change *At the moment `NetworkEnvironment#getNetworkBufferPool` is called

[GitHub] [flink] shangwen commented on a change in pull request #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit

shangwen commented on a change in pull request #8189: [FLINK-12195] [YARN] Incorrect resource time setting causes flink to fail to submit URL: https://github.com/apache/flink/pull/8189#discussion_r275892412 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java ###

[jira] [Commented] (FLINK-12195) Incorrect resource time setting causes flink to fail to submit

[ https://issues.apache.org/jira/browse/FLINK-12195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819237#comment-16819237 ] tangshangwen commented on FLINK-12195: -- Thanks [~till.rohrmann]! > Incorrect resou

[jira] [Updated] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Description: Third party library would like to add some hook when submitting jobs. So it would be n

[jira] [Comment Edited] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819215#comment-16819215 ] Jeff Zhang edited comment on FLINK-12214 at 4/16/19 4:22 PM: -

[jira] [Comment Edited] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819215#comment-16819215 ] Jeff Zhang edited comment on FLINK-12214 at 4/16/19 4:18 PM: -

[jira] [Commented] (FLINK-12195) Incorrect resource time setting causes flink to fail to submit

[ https://issues.apache.org/jira/browse/FLINK-12195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819216#comment-16819216 ] Till Rohrmann commented on FLINK-12195: --- Caused by changes introduced with FLINK-8

[jira] [Updated] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Description: Third party library would like to add some hook when submitting jobs. So it would be n

[jira] [Commented] (FLINK-12195) Incorrect resource time setting causes flink to fail to submit

[ https://issues.apache.org/jira/browse/FLINK-12195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819214#comment-16819214 ] Till Rohrmann commented on FLINK-12195: --- The reason why we use the local modificat

[jira] [Updated] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12214: --- Description: Third party library would like to add some hook when submitting jobs. So it would be n

[jira] [Commented] (FLINK-12214) Add JobListener to capture job submission process

[ https://issues.apache.org/jira/browse/FLINK-12214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819215#comment-16819215 ] Jeff Zhang commented on FLINK-12214: Thanks for the comment, [~till.rohrmann]. The b

  1   2   3   >