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

danny0405 commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19 URL: https://github.com/apache/flink/pull/8324#issuecomment-495854327 CALCITE-3055 is a vital regression for VolcanoPlanner, it would be fixed in 1.20.0, i think we should skip 1.19.0 version Calcite, and use

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548639 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548207 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548439 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548474 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287526502 ## File path: flink-connectors/flink-connector-hive/pom.xml ## @@

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548246 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548780 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548230 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548916 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548573 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548805 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548672 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548343 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548859 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

bowenli86 commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287548881 ## File path:

[GitHub] [flink] yanghua commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN

yanghua commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN URL: https://github.com/apache/flink/pull/8438#discussion_r287548190 ## File path:

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

flinkbot 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-495825993 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] bowenli86 opened a new pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file

bowenli86 opened a new pull request #8541: [FLINK-9172][sql-client] Support catalogs in SQL-Client yaml config file URL: https://github.com/apache/flink/pull/8541 ## What is the purpose of the change This PR adds support for **basic** catalog entries in SQL-Client yaml config file,

[jira] [Commented] (FLINK-12622) The process function compiles error in MyProcessWindowFunction in windows.md

[ https://issues.apache.org/jira/browse/FLINK-12622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848003#comment-16848003 ] chaiyongqiang commented on FLINK-12622: --- [https://github.com/apache/flink/pull/8540/commits] >

[jira] [Updated] (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 updated FLINK-9172: Summary: Support catalogs in SQL-Client yaml config file (was: Support external catalogs in SQL-Client)

[jira] [Commented] (FLINK-12297) Clean the closure for OutputTags in PatternStream

[ https://issues.apache.org/jira/browse/FLINK-12297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848002#comment-16848002 ] aitozi commented on FLINK-12297: Hi，[~aljoscha] Since you have noticed this issue, can you take a look

[GitHub] [flink] yanghua commented on issue #8538: [FLINK-11283] Accessing the key when processing connected keyed stream

yanghua commented on issue #8538: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/8538#issuecomment-495824161 There is a failure when downloading kafka_2.11-2.2.0.

[GitHub] [flink] flinkbot commented on issue #8540: Change the return value for process function in MyProcessWindowFunction

flinkbot commented on issue #8540: Change the return value for process function in MyProcessWindowFunction URL: https://github.com/apache/flink/pull/8540#issuecomment-495821941 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] cyq89051127 opened a new pull request #8540: Change the return value for process function in MyProcessWindowFunction

cyq89051127 opened a new pull request #8540: Change the return value for process function in MyProcessWindowFunction URL: https://github.com/apache/flink/pull/8540 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob

[jira] [Created] (FLINK-12622) The process function compiles error in MyProcessWindowFunction in windows.md

chaiyongqiang created FLINK-12622: - Summary: The process function compiles error in MyProcessWindowFunction in windows.md Key: FLINK-12622 URL: https://issues.apache.org/jira/browse/FLINK-12622

[jira] [Updated] (FLINK-12621) Use MiniCluster instead of JobExecutor

[ https://issues.apache.org/jira/browse/FLINK-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang updated FLINK-12621: --- Description: JobExecutor is specifically used for local mode, I don't think we need to introduce

[jira] [Assigned] (FLINK-12621) Use MiniCluster instead of JobExecutor

[ https://issues.apache.org/jira/browse/FLINK-12621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang reassigned FLINK-12621: -- Assignee: Jeff Zhang > Use MiniCluster instead of JobExecutor >

[jira] [Created] (FLINK-12621) Use MiniCluster instead of JobExecutor

Jeff Zhang created FLINK-12621: -- Summary: Use MiniCluster instead of JobExecutor Key: FLINK-12621 URL: https://issues.apache.org/jira/browse/FLINK-12621 Project: Flink Issue Type: Improvement

[GitHub] [flink] zorro786 commented on a change in pull request #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods

zorro786 commented on a change in pull request #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#discussion_r287540914 ## File path:

[GitHub] [flink] zorro786 commented on a change in pull request #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods

zorro786 commented on a change in pull request #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#discussion_r287540080 ## File path:

[GitHub] [flink] zorro786 commented on issue #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods

zorro786 commented on issue #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#issuecomment-495814478 retest This is an automated message from

[GitHub] [flink] zorro786 commented on issue #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods

zorro786 commented on issue #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#issuecomment-495814469 Thanks for review and fixing the issues @tillrohrmann Tests failing here: ```

[GitHub] [flink] zorro786 commented on issue #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods

zorro786 commented on issue #8154: [FLINK-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#issuecomment-495814490 test This is an automated message from the

[GitHub] [flink] xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287533827 ## File path:

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend

sunjincheng121 commented on a change in pull request #8472: [FLINK-12327][python] Adds support to submit Python Table API job in CliFrontend URL: https://github.com/apache/flink/pull/8472#discussion_r287532751 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287528948 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287527460 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables

xuefuz commented on a change in pull request #8536: [FLINK-12568][hive] Implement TableSink and OutputFormat to write Hive tables URL: https://github.com/apache/flink/pull/8536#discussion_r287526558 ## File path:

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

Mike Kaplinskiy created FLINK-12620: --- Summary: Deadlock in task deserialization Key: FLINK-12620 URL: https://issues.apache.org/jira/browse/FLINK-12620 Project: Flink Issue Type: Bug

[jira] [Resolved] (FLINK-12416) Docker build script fails on symlink creation ln -s

[ https://issues.apache.org/jira/browse/FLINK-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12416. --- Resolution: Fixed Fix Version/s: 1.8.1 1.9.0 Fixed via 1.9.0:

[jira] [Resolved] (FLINK-12375) flink-container job jar does not have read permissions

[ https://issues.apache.org/jira/browse/FLINK-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12375. --- Resolution: Fixed Fix Version/s: 1.8.1 1.9.0 Fixed via 1.9.0:

[GitHub] [flink] tillrohrmann closed pull request #8391: [FLINK-12416][FLINK-12375] Fix docker build scripts on Flink-1.8

tillrohrmann closed pull request #8391: [FLINK-12416][FLINK-12375] Fix docker build scripts on Flink-1.8 URL: https://github.com/apache/flink/pull/8391 This is an automated message from the Apache Git Service. To respond to

[GitHub] [flink] tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods

tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods URL: https://github.com/apache/flink/pull/8534#discussion_r287437037 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods

tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods URL: https://github.com/apache/flink/pull/8534#discussion_r287437184 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods

tillrohrmann commented on a change in pull request #8534: [FLINK-12614][yarn] Refactor test to not do assertions in @After methods URL: https://github.com/apache/flink/pull/8534#discussion_r287437317 ## File path:

[jira] [Comment Edited] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847710#comment-16847710 ] Yun Tang edited comment on FLINK-12546 at 5/24/19 4:42 PM: --- [~knaufk] Thanks

[jira] [Commented] (FLINK-12546) Base Docker images on `library/flink`

[ https://issues.apache.org/jira/browse/FLINK-12546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847710#comment-16847710 ] Yun Tang commented on FLINK-12546: -- [~knaufk] Thanks for your interpretation, and I would agree with

[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-495702974 @fhueske @twalthr could you take a look? This is an automated message from

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847702#comment-16847702 ] vinoyang commented on FLINK-10855: -- [~yunta] I think [~till.rohrmann] and I have reached an agreement

[GitHub] [flink] tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r287433479 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r287432149 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r287433179 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials

tillrohrmann commented on a change in pull request #7895: [FLINK-11126][YARN][security] Filter out AMRMToken in TaskManager‘s credentials URL: https://github.com/apache/flink/pull/7895#discussion_r287431982 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java

[GitHub] [flink] lamber-ken commented on issue #8265: [FLINK-12302][runtime] Fixed the wrong finalStatus of yarn application when application finished

lamber-ken commented on issue #8265: [FLINK-12302][runtime] Fixed the wrong finalStatus of yarn application when application finished URL: https://github.com/apache/flink/pull/8265#issuecomment-495695056 > Thanks, I'll take a look @lamber-ken you're welcome, if have any question,

[jira] [Commented] (FLINK-10713) RestartIndividualStrategy does not restore state

[ https://issues.apache.org/jira/browse/FLINK-10713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847683#comment-16847683 ] Yun Tang commented on FLINK-10713: -- Since new scheduling strategy is already started in FLINK-10429 , I

[GitHub] [flink] tillrohrmann commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN

tillrohrmann commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN URL: https://github.com/apache/flink/pull/8438#discussion_r287425485 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN

tillrohrmann commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN URL: https://github.com/apache/flink/pull/8438#discussion_r287425131 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN

tillrohrmann commented on a change in pull request #8438: [FLINK-12152] Make the vcore that Application Master used configurable for Flink on YARN URL: https://github.com/apache/flink/pull/8438#discussion_r287425587 ## File path:

[jira] [Commented] (FLINK-10855) CheckpointCoordinator does not delete checkpoint directory of late/failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10855?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847677#comment-16847677 ] Yun Tang commented on FLINK-10855: -- Thanks [~yanghua] to start this Jira again. I just wonder whether a

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287419849 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287419923 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287419036 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287419668 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287419507 ## File path:

[GitHub] [flink] eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

eaglewatcherwb commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r287422649 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287421208 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client

tillrohrmann commented on a change in pull request #8484: [FLINK-12547] Add connection and socket timeouts for the blob client URL: https://github.com/apache/flink/pull/8484#discussion_r287419709 ## File path:

[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=16847669#comment-16847669 ] Cliff Resnick commented on FLINK-11947: --- Does the deescalation from Blocker mean that this will

[GitHub] [flink] Aitozi commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

Aitozi commented on issue #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-495687292 Hi @pnowojski , what is the reason for the second point ? > This is not true for

[jira] [Commented] (FLINK-12426) TM occasionally hang in deploying state

[ https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847653#comment-16847653 ] Till Rohrmann commented on FLINK-12426: --- Could it be that FLINK-12547 tries to solve the same

[jira] [Updated] (FLINK-12547) Deadlock when the task thread downloads jars using BlobClient

[ https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-12547: -- Component/s: (was: Runtime / Operators) Runtime / Coordination >

[GitHub] [flink] tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods

tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#discussion_r287414640 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods

tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#discussion_r287414688 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods

tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#discussion_r287414860 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods

tillrohrmann commented on a change in pull request #8154: [Flink-12167] Reset context classloader in run and getOptimizedPlan methods URL: https://github.com/apache/flink/pull/8154#discussion_r287414740 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology

tillrohrmann commented on a change in pull request #8446: [FLINK-12414] [runtime] Implement ExecutionGraph to SchedulingTopology URL: https://github.com/apache/flink/pull/8446#discussion_r287402622 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #8537: [FLINK-12115][fs] Add support for AzureFS

tillrohrmann commented on a change in pull request #8537: [FLINK-12115][fs] Add support for AzureFS URL: https://github.com/apache/flink/pull/8537#discussion_r287400354 ## File path: flink-filesystems/flink-azure-fs-hadoop/pom.xml ## @@ -119,17 +111,69 @@ under the

[GitHub] [flink] flinkbot commented on issue #8539: [FLINK-12617] [container] StandaloneJobClusterEntrypoint defaults to random JobID for non-HA setups

flinkbot commented on issue #8539: [FLINK-12617] [container] StandaloneJobClusterEntrypoint defaults to random JobID for non-HA setups URL: https://github.com/apache/flink/pull/8539#issuecomment-495666848 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I

[jira] [Updated] (FLINK-12617) StandaloneJobClusterEntrypoint should default to random JobID for non-HA setups

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

[GitHub] [flink] flinkbot commented on issue #8538: [FLINK-11283] Accessing the key when processing connected keyed stream

flinkbot commented on issue #8538: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/8538#issuecomment-495666295 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] knaufk opened a new pull request #8539: [FLINK-12617] [container] StandaloneJobClusterEntrypoint defaults to random JobID for non-HA setups

knaufk opened a new pull request #8539: [FLINK-12617] [container] StandaloneJobClusterEntrypoint defaults to random JobID for non-HA setups URL: https://github.com/apache/flink/pull/8539 ## What is the purpose of the change ## Brief change log * StandaloneJobClusterEntrypoint

[GitHub] [flink] aljoscha opened a new pull request #8538: [FLINK-11283] Accessing the key when processing connected keyed stream

aljoscha opened a new pull request #8538: [FLINK-11283] Accessing the key when processing connected keyed stream URL: https://github.com/apache/flink/pull/8538 Cleaned up and rebased version of #7470, for running Travis tests.

[GitHub] [flink] pnowojski commented on issue #8455: [FLINK-12284][Network, Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode

pnowojski commented on issue #8455: [FLINK-12284][Network,Metrics]Fix the incorrect inputBufferUsage metric in credit-based network mode URL: https://github.com/apache/flink/pull/8455#issuecomment-495661903 > The current inputBufferUsage is only reflecting the usage of floating buffers,

[GitHub] [flink] zentol commented on a change in pull request #8537: [FLINK-12115][fs] Add support for AzureFS

zentol commented on a change in pull request #8537: [FLINK-12115][fs] Add support for AzureFS URL: https://github.com/apache/flink/pull/8537#discussion_r287392198 ## File path: flink-filesystems/flink-azure-fs-hadoop/pom.xml ## @@ -119,17 +111,69 @@ under the License.

[jira] [Commented] (FLINK-12222) 'start-scala-shell -a ' doesn't ship jars to yarn container

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847597#comment-16847597 ] Jeff Zhang commented on FLINK-1: Sorry [~Zentol]  It is due to my environment issue, I will

[jira] [Closed] (FLINK-12222) 'start-scala-shell -a ' doesn't ship jars to yarn container

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Zhang closed FLINK-1. -- Resolution: Invalid > 'start-scala-shell -a ' doesn't ship jars to yarn container >

[jira] [Commented] (FLINK-12297) Clean the closure for OutputTags in PatternStream

[ https://issues.apache.org/jira/browse/FLINK-12297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847590#comment-16847590 ] Aljoscha Krettek commented on FLINK-12297: -- {{OutputTag}} needs to be an anonymous inner class

[jira] [Updated] (FLINK-11107) Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-11107: - Summary: Avoid memory stateBackend to create arbitrary folders under HA path when no

[jira] [Updated] (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 ] Aljoscha Krettek updated FLINK-11947: - Priority: Critical (was: Blocker) > Support MapState key / value schema evolution for

[GitHub] [flink] piyushnarang commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS

piyushnarang commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS URL: https://github.com/apache/flink/pull/8537#issuecomment-495638250 Thanks for spinning this up @tillrohrmann, will review and chime in. This

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r287368246 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS

tillrohrmann commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS URL: https://github.com/apache/flink/pull/8537#issuecomment-495633301 @shuai-xu do you have time to test the Azure FS implementation? This is an

[GitHub] [flink] flinkbot commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS

flinkbot commented on issue #8537: [FLINK-12115][fs] Add support for AzureFS URL: https://github.com/apache/flink/pull/8537#issuecomment-495632841 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] [flink] tillrohrmann opened a new pull request #8537: [FLINK-12115][fs] Add support for AzureFS

tillrohrmann opened a new pull request #8537: [FLINK-12115][fs] Add support for AzureFS URL: https://github.com/apache/flink/pull/8537 This PR is based on #8117. It decreases the dependency footprint and adds a proper NOTICE file to it. cc @piyushnarang

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r287362965 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r287362924 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r287362596 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface

azagrebin commented on a change in pull request #8362: [FLINK-11391] Introduce shuffle master interface URL: https://github.com/apache/flink/pull/8362#discussion_r287359019 ## File path:

[jira] [Commented] (FLINK-12456) Wrong CharType convertion in type_utils.py

[ https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847539#comment-16847539 ] Dian Fu commented on FLINK-12456: - [~lzljs3620320]  Thanks a lot for reporting this issue. Good catch!

  1   2   3   >