[GitHub] [flink] zhijiangW commented on a change in pull request #8320: [FLINK-12201][network, metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric

zhijiangW commented on a change in pull request #8320: [FLINK-12201][network,metrics] Introduce InputGateWithMetrics in Task to increment numBytesIn metric URL: https://github.com/apache/flink/pull/8320#discussion_r288418365 ## File path: flink-runtime/src/main/java/org/apache/fli

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850556#comment-16850556 ] sunjincheng commented on FLINK-10455: - What is the current situation of this JIRA, i

[GitHub] [flink] dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment

dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment URL: https://github.com/apache/flink/pull/8474#discussion_r288417496 ## File path: flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/python/pi

[GitHub] [flink] zjffdu commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor

zjffdu commented on issue #8546: [FLINK-12621]. Use MiniCluster instead of JobExecutor URL: https://github.com/apache/flink/pull/8546#issuecomment-496809792 @tillrohrmann Thanks for the review. I think we should unify the flink's local client and remote client. This is related with https

[GitHub] [flink] zhijiangW commented on issue #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition

zhijiangW commented on issue #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition URL: https://github.com/apache/flink/pull/7549#issuecomment-496807375 Thanks for the further review @azagrebin ! I pushed a fi

[jira] [Closed] (FLINK-12413) Implement ExecutionFailureHandler

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

[GitHub] [flink] zentol merged pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zentol merged pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Created] (FLINK-12665) Introduce MiniBatchIntervalInferRule and watermark assigner operators

godfrey he created FLINK-12665: -- Summary: Introduce MiniBatchIntervalInferRule and watermark assigner operators Key: FLINK-12665 URL: https://issues.apache.org/jira/browse/FLINK-12665 Project: Flink

[jira] [Commented] (FLINK-11634) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-11634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850542#comment-16850542 ] Jark Wu commented on FLINK-11634: - Hi [~hyl], thanks for taking this issue. However, I w

[jira] [Comment Edited] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

[ https://issues.apache.org/jira/browse/FLINK-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849909#comment-16849909 ] Robert Metzger edited comment on FLINK-12650 at 5/29/19 6:22 AM: -

[jira] [Updated] (FLINK-12650) Redirect Users to Documentation Homepage if Requested Resource Does Not Exist

[ https://issues.apache.org/jira/browse/FLINK-12650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12650: --- Component/s: Documentation > Redirect Users to Documentation Homepage if Requested Resource

[jira] [Assigned] (FLINK-12649) Add a shim layer to support multiple versions of HMS

[ https://issues.apache.org/jira/browse/FLINK-12649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li reassigned FLINK-12649: -- Assignee: Rui Li > Add a shim layer to support multiple versions of HMS > ---

[GitHub] [flink] dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment

dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment URL: https://github.com/apache/flink/pull/8474#discussion_r288399465 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -379,13 +383,97 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment

dianfu commented on a change in pull request #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment URL: https://github.com/apache/flink/pull/8474#discussion_r288398143 ## File path: flink-python/pyflink/table/table_environment.py ## @@ -379,13 +383,97 @@ def

[GitHub] [flink] lirui-apache commented on issue #8536: [FLINK-12568][hive] Implement OutputFormat to write Hive tables

lirui-apache commented on issue #8536: [FLINK-12568][hive] Implement OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#issuecomment-496789599 I have removed the TableSink implementation and updated unit test accordingly. @KurtYoung @xuefuz @bowenli86 pleas

[jira] [Comment Edited] (FLINK-12568) Implement OutputFormat to write Hive tables

[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850513#comment-16850513 ] Rui Li edited comment on FLINK-12568 at 5/29/19 5:22 AM: - Since

[jira] [Created] (FLINK-12664) Implement TableSink to write Hive tables

Rui Li created FLINK-12664: -- Summary: Implement TableSink to write Hive tables Key: FLINK-12664 URL: https://issues.apache.org/jira/browse/FLINK-12664 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-12568) Implement OutputFormat to write Hive tables

[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850513#comment-16850513 ] Rui Li commented on FLINK-12568: Since {{BatchTableSink}} interface hasn't been finalize

[jira] [Updated] (FLINK-12568) Implement OutputFormat to write Hive tables

[ https://issues.apache.org/jira/browse/FLINK-12568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Li updated FLINK-12568: --- Summary: Implement OutputFormat to write Hive tables (was: Implement TableSink and OutputFormat to write Hi

[jira] [Commented] (FLINK-11947) Support MapState key / value schema evolution for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-11947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850506#comment-16850506 ] Tzu-Li (Gordon) Tai commented on FLINK-11947: - Thanks Congxian! I've assigne

[jira] [Assigned] (FLINK-11947) Support MapState key / value schema evolution for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-11947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai reassigned FLINK-11947: --- Assignee: Congxian Qiu(klion26) > Support MapState key / value schema evolu

[jira] [Updated] (FLINK-11947) Support MapState value schema evolution for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-11947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11947: Summary: Support MapState value schema evolution for RocksDB (was: Support MapSta

[jira] [Commented] (FLINK-11947) Support MapState key / value schema evolution for RocksDB

[ https://issues.apache.org/jira/browse/FLINK-11947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850497#comment-16850497 ] Congxian Qiu(klion26) commented on FLINK-11947: --- [~cresny] I'm interested

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850490#comment-16850490 ] Congxian Qiu(klion26) commented on FLINK-12296: --- Thanks for the reminder [

[GitHub] [flink] zhijiangW commented on a change in pull request #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition

zhijiangW commented on a change in pull request #7549: [FLINK-11403][network] Introduce ResultPartitionWithConsumableNotifier in task for notifying consumable result partition URL: https://github.com/apache/flink/pull/7549#discussion_r288389643 ## File path: flink-runtime/src/main

[GitHub] [flink] zhijiangW edited a comment on issue #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

zhijiangW edited a comment on issue #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#issuecomment-496776930 Thanks for the reviews and good suggestions @azagrebin ! Yes, we still rely on some netwo

[GitHub] [flink] zhijiangW commented on issue #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

zhijiangW commented on issue #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#issuecomment-496776930 Thanks for the reviews and good suggestions @azagrebin ! Yes, we still rely on some network opti

[GitHub] [flink] liyafan82 commented on issue #8408: [FLINK-12223][Runtime]HeapMemorySegment.getArray should return null a…

liyafan82 commented on issue #8408: [FLINK-12223][Runtime]HeapMemorySegment.getArray should return null a… URL: https://github.com/apache/flink/pull/8408#issuecomment-496774101 Hi @zentol , would you please take a look at this PR? ---

[GitHub] [flink] tweise commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

tweise commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer URL: https://github.com/apache/flink/pull/8517#discussion_r288382291 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink

[jira] [Assigned] (FLINK-12237) Support Hive table stats related operations in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-12237: Assignee: zjuwangg > Support Hive table stats related operations in HiveCatalog > ---

[jira] [Commented] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850421#comment-16850421 ] sunjincheng commented on FLINK-12296: - Thanks for double check this JIRA, and close

[GitHub] [flink] zhijiangW commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

zhijiangW commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288380985 ## File path: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.j

[GitHub] [flink] zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler

zhuzhurk commented on a change in pull request #8498: [FLINK-12413] [runtime] Implement ExecutionFailureHandler URL: https://github.com/apache/flink/pull/8498#discussion_r287908868 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/failover/flip1/Exec

[GitHub] [flink] zhijiangW commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

zhijiangW commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288375567 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[jira] [Updated] (FLINK-12572) Implement HiveInputFormat to read Hive tables

[ https://issues.apache.org/jira/browse/FLINK-12572?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg updated FLINK-12572: - Summary: Implement HiveInputFormat to read Hive tables (was: Implement TableSource and InputFormat to r

[GitHub] [flink] sunhaibotb commented on issue #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

sunhaibotb commented on issue #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#issuecomment-496761878 Two timeout defaults have been modified. Please check them, thanks. @tillrohrmann --

[jira] [Created] (FLINK-12663) Implement HiveTableSource to read Hive tables

zjuwangg created FLINK-12663: Summary: Implement HiveTableSource to read Hive tables Key: FLINK-12663 URL: https://issues.apache.org/jira/browse/FLINK-12663 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-12663) Implement HiveTableSource to read Hive tables

[ https://issues.apache.org/jira/browse/FLINK-12663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zjuwangg reassigned FLINK-12663: Assignee: zjuwangg > Implement HiveTableSource to read Hive tables >

[jira] [Comment Edited] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850320#comment-16850320 ] Congxian Qiu(klion26) edited comment on FLINK-12296 at 5/29/19 2:42 AM: --

[jira] [Resolved] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator(has states) chained in a single task

[ https://issues.apache.org/jira/browse/FLINK-12296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) resolved FLINK-12296. --- Resolution: Fixed Since the commits have been merged in master, release-1.8,

[GitHub] [flink] zjuwangg commented on a change in pull request #8522: [FLINK-12572][hive]Implement TableSource and InputFormat to read Hive tables

zjuwangg commented on a change in pull request #8522: [FLINK-12572][hive]Implement TableSource and InputFormat to read Hive tables URL: https://github.com/apache/flink/pull/8522#discussion_r288372767 ## File path: flink-connectors/flink-connector-hive/pom.xml ## @@ -58,6 +

[jira] [Closed] (FLINK-9172) Support catalogs in SQL-Client yaml config file

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-9172. --- Resolution: Fixed Fix Version/s: 1.9.0 merged in 1.9.0: d3e5bf69c3d3f105c1ebe7c46bd4a74e5407137f > Su

[jira] [Assigned] (FLINK-12583) Add all format support align with the Java Table API

[ https://issues.apache.org/jira/browse/FLINK-12583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-12583: - Assignee: Wei Zhong > Add all format support align with the Java Table API > --

[GitHub] [flink] bowenli86 closed pull request #7393: [FLINK-9172][table][sql-client] - Support external catalogs in SQL-Client

bowenli86 closed pull request #7393: [FLINK-9172][table][sql-client] - Support external catalogs in SQL-Client URL: https://github.com/apache/flink/pull/7393 This is an automated message from the Apache Git Service. To respo

[GitHub] [flink] zhijiangW commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

zhijiangW commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288370752 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/networ

[jira] [Comment Edited] (FLINK-12662) Flink how jobs for failover in history server as well

[ https://issues.apache.org/jira/browse/FLINK-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850308#comment-16850308 ] vinoyang edited comment on FLINK-12662 at 5/29/19 2:20 AM: --- I

[jira] [Commented] (FLINK-12662) Flink how jobs for failover in history server as well

[ https://issues.apache.org/jira/browse/FLINK-12662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850308#comment-16850308 ] vinoyang commented on FLINK-12662: -- I think this proposal is valuable. > Flink how job

[GitHub] [flink] zhijiangW commented on issue #8496: [FLINK-12571][network] Make NetworkEnvironment#start() return the binded data port

zhijiangW commented on issue #8496: [FLINK-12571][network] Make NetworkEnvironment#start() return the binded data port URL: https://github.com/apache/flink/pull/8496#issuecomment-496757292 Thanks for reviews @azagrebin ! I pushed the fixup commit for adding doc comments and also anot

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850307#comment-16850307 ] Liya Fan commented on FLINK-12620: -- [~mikekap], thanks for the clarification. Would yo

[GitHub] [flink] dianfu commented on issue #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment

dianfu commented on issue #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment URL: https://github.com/apache/flink/pull/8474#issuecomment-496756510 Sounds good. I will rebase the PR. This is an automated messa

[GitHub] [flink] sunjincheng121 commented on issue #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment

sunjincheng121 commented on issue #8474: [FLINK-12409][python] Adds from_elements in TableEnvironment URL: https://github.com/apache/flink/pull/8474#issuecomment-496754379 Thanks for the reply @aljoscha! As we(@aljoscha @dianfu and me) discussed offline, we got a consistent solution

[GitHub] [flink] sunjincheng121 commented on issue #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API

sunjincheng121 commented on issue #8532: [FLINK-12541][REST] Support to submit Python Table API jobs via REST API URL: https://github.com/apache/flink/pull/8532#issuecomment-496751857 @flinkbot attention @tillrohrmann @zentol ---

[jira] [Created] (FLINK-12662) Flink how jobs for failover in history server as well

Su Ralph created FLINK-12662: Summary: Flink how jobs for failover in history server as well Key: FLINK-12662 URL: https://issues.apache.org/jira/browse/FLINK-12662 Project: Flink Issue Type: Imp

[GitHub] [flink] tweise commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer

tweise commented on a change in pull request #8517: [FLINK-10921] [kinesis] Shard watermark synchronization in Kinesis consumer URL: https://github.com/apache/flink/pull/8517#discussion_r288360078 ## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink

[GitHub] [flink] asfgit closed pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file

asfgit closed pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file URL: https://github.com/apache/flink/pull/8541 This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] bowenli86 commented on issue #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file

bowenli86 commented on issue #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file URL: https://github.com/apache/flink/pull/8541#issuecomment-496715854 The CI failure is due to flink-runtime is broken. Merging

[jira] [Created] (FLINK-12661) test failure: RestAPIStabilityTest.testDispatcherRestAPIStability

Bowen Li created FLINK-12661: Summary: test failure: RestAPIStabilityTest.testDispatcherRestAPIStability Key: FLINK-12661 URL: https://issues.apache.org/jira/browse/FLINK-12661 Project: Flink Is

[jira] [Commented] (FLINK-12620) Deadlock in task deserialization

[ https://issues.apache.org/jira/browse/FLINK-12620?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850165#comment-16850165 ] Mike Kaplinskiy commented on FLINK-12620: - With the patch, I'm expecting class i

[GitHub] [flink] tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#discussion_r288287665 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#discussion_r288290783 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#discussion_r288283528 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#discussion_r288288062 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#discussion_r288283226 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment

tillrohrmann commented on a change in pull request #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#discussion_r288287374 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partiti

[GitHub] [flink] walterddr edited a comment on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19

walterddr edited a comment on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#issuecomment-496663881 @danny0405 hmm. I think that's probably a good idea Considering the light-weighted changes I did for this PR. I suggest we c

[GitHub] [flink] walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19

walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#issuecomment-496663881 @danny0405 hmm. I think that's probably a good idea Considering the light-weighted changes I did for this PR. I suggest we commit th

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288273753 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[jira] [Closed] (FLINK-12418) Add input/output format and SerDeLib information when creating Hive table in HiveCatalog

[ https://issues.apache.org/jira/browse/FLINK-12418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-12418. Resolution: Fixed merged in 1.9.0: 97510aaa8444895a0cc4df7461889fb66d5ffc01 > Add input/output format and

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288254960 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288258556 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288242715 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288254960 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[jira] [Commented] (FLINK-9050) Expose operator IO counter metrics

[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850033#comment-16850033 ] Fabian Wollert commented on FLINK-9050: --- any updates on this? > Expose operator IO

[jira] [Comment Edited] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert edited comment on FLINK-10707 at 5/28/19 6:47 PM: -

[jira] [Comment Edited] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert edited comment on FLINK-10707 at 5/28/19 6:46 PM: -

[jira] [Comment Edited] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert edited comment on FLINK-10707 at 5/28/19 6:41 PM: -

[jira] [Comment Edited] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert edited comment on FLINK-10707 at 5/28/19 6:40 PM: -

[jira] [Comment Edited] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert edited comment on FLINK-10707 at 5/28/19 6:40 PM: -

[jira] [Comment Edited] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert edited comment on FLINK-10707 at 5/28/19 6:40 PM: -

[jira] [Commented] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850022#comment-16850022 ] Fabian Wollert commented on FLINK-10707: okay, i got the code now to show what i

[jira] [Updated] (FLINK-10707) Improve Cluster Overview in Flink Dashboard

[ https://issues.apache.org/jira/browse/FLINK-10707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Wollert updated FLINK-10707: --- Attachment: image-2019-05-28-20-38-00-761.png > Improve Cluster Overview in Flink Dashboard

[GitHub] [flink] xuefuz commented on a change in pull request #8548: [FLINK-6962] [table] Add a create table SQL DDL

xuefuz commented on a change in pull request #8548: [FLINK-6962] [table] Add a create table SQL DDL URL: https://github.com/apache/flink/pull/8548#discussion_r288246045 ## File path: flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl ## @@ -0,0 +1,347

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288242715 ## File path: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16850007#comment-16850007 ] Akshay Kanfade commented on FLINK-12607: [~klion26] Sorry, I misread your commen

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288239644 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288239644 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[GitHub] [flink] 1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox)

1u0 commented on a change in pull request #8523: [FLINK-12481][runtime] Invoke timer callback in task thread (via mailbox) URL: https://github.com/apache/flink/pull/8523#discussion_r288235811 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/

[jira] [Commented] (FLINK-12607) Introduce a REST API that returns the maxParallelism of a job

[ https://issues.apache.org/jira/browse/FLINK-12607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849983#comment-16849983 ] Akshay Kanfade commented on FLINK-12607: [~till.rohrmann]. Yes, I will be happy

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288210117 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288210167 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288212692 ## File path: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.j

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288209939 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288223427 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288210019 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288218530 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/networ

[GitHub] [flink] flinkbot commented on issue #8560: [hotfix][hive] make hive-metastore dependency scope to 'provided'

flinkbot commented on issue #8560: [hotfix][hive] make hive-metastore dependency scope to 'provided' URL: https://github.com/apache/flink/pull/8560#issuecomment-496612504 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review yo

[GitHub] [flink] bowenli86 opened a new pull request #8560: [hotfix][hive] make hive-metastore dependency scope to 'provided'

bowenli86 opened a new pull request #8560: [hotfix][hive] make hive-metastore dependency scope to 'provided' URL: https://github.com/apache/flink/pull/8560 ## What is the purpose of the change This PR converts hive-metastore jar dependency scope from 'compile' to 'provide', so that

[jira] [Commented] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849943#comment-16849943 ] Maximilian Michels commented on FLINK-12653: Some more information, these ar

[jira] [Comment Edited] (FLINK-12653) Keyed state backend fails to restore during rescaling

[ https://issues.apache.org/jira/browse/FLINK-12653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849943#comment-16849943 ] Maximilian Michels edited comment on FLINK-12653 at 5/28/19 5:15 PM: -

[GitHub] [flink] asfgit closed pull request #8553: [FLINK-12418][hive] Add input/output format and SerDeLib information when creating Hive table in HiveCatalog

asfgit closed pull request #8553: [FLINK-12418][hive] Add input/output format and SerDeLib information when creating Hive table in HiveCatalog URL: https://github.com/apache/flink/pull/8553 This is an automated message from

  1   2   3   >