[jira] [Commented] (FLINK-10273) Access composite type fields after a function

[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605340#comment-16605340 ] Timo Walther commented on FLINK-10273: -- [~walterddr] yes, this only occurs in SQL.

[jira] [Commented] (FLINK-10247) Run MetricQueryService in separate thread pool

[ https://issues.apache.org/jira/browse/FLINK-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605338#comment-16605338 ] Shimin Yang commented on FLINK-10247: - Hi [~till.rohrmann], do you mean that we shou

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605279#comment-16605279 ] ASF GitHub Bot commented on FLINK-7243: --- lvhuyen commented on issue #6483: [FLINK-7

[GitHub] lvhuyen commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

lvhuyen commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-418967608 @HuangZhenQiu Here is the schema of that parquet file, printed in Zeppelin. > root > |-- metrics_date: timestamp (nullable

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605208#comment-16605208 ] ASF GitHub Bot commented on FLINK-7243: --- HuangZhenQiu commented on issue #6483: [FL

[GitHub] HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

HuangZhenQiu commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-418951266 @lvhuyen Thanks for using parquet input format and give me feedback. So the type timstamp is logic type in parquet. It is in

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605112#comment-16605112 ] Rong Rong commented on FLINK-10273: --- I was able to reproduce it on SQL but not Table A

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605106#comment-16605106 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on issue #6657: [

[GitHub] isunjin commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource…

isunjin commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6657#issuecomment-418925630 I have put the the document here, note that the document not only include this issue, but includes oth

[jira] [Commented] (FLINK-8035) Unable to submit job when HA is enabled

[ https://issues.apache.org/jira/browse/FLINK-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16605052#comment-16605052 ] Jason Kania commented on FLINK-8035: This issue affects more than just submission. Ma

[GitHub] zentol closed pull request #6664: [hotfix][docs] Remove redundant word in javadocs

zentol closed pull request #6664: [hotfix][docs] Remove redundant word in javadocs URL: https://github.com/apache/flink/pull/6664 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a forei

[jira] [Closed] (FLINK-9150) Prepare for Java 10

[ https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-9150. --- Resolution: Duplicate The issue raised here is a duplicate of https://issues.apache.org/jira

[jira] [Commented] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway

[ https://issues.apache.org/jira/browse/FLINK-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604897#comment-16604897 ] ASF GitHub Bot commented on FLINK-10193: GJL commented on issue #6601: [FLINK-10

[GitHub] GJL commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint

GJL commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint URL: https://github.com/apache/flink/pull/6601#issuecomment-418868217 @jelmerk Should be merged soon. We did not have much time recently due to Flink Forward. -

[jira] [Comment Edited] (FLINK-9150) Prepare for Java 10

[ https://issues.apache.org/jira/browse/FLINK-9150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16473198#comment-16473198 ] Ted Yu edited comment on FLINK-9150 at 9/5/18 8:09 PM: --- Similar err

[GitHub] walterddr commented on issue #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream

walterddr commented on issue #6521: [FLINK-5315][table] Adding support for distinct operation for table API on DataStream URL: https://github.com/apache/flink/pull/6521#issuecomment-418836009 @fhueske @hequn8128 just updated based on the feedback. Please kindly take another look when you h

[jira] [Commented] (FLINK-5315) Support distinct aggregations in table api

[ https://issues.apache.org/jira/browse/FLINK-5315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604772#comment-16604772 ] ASF GitHub Bot commented on FLINK-5315: --- walterddr commented on issue #6521: [FLINK

[jira] [Commented] (FLINK-10267) [State] Fix arbitrary iterator access on RocksDBMapIterator

[ https://issues.apache.org/jira/browse/FLINK-10267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604673#comment-16604673 ] ASF GitHub Bot commented on FLINK-10267: Myasuka commented on a change in pull r

[GitHub] Myasuka commented on a change in pull request #6638: [FLINK-10267][State] Fix arbitrary iterator access on RocksDBMapIterator

Myasuka commented on a change in pull request #6638: [FLINK-10267][State] Fix arbitrary iterator access on RocksDBMapIterator URL: https://github.com/apache/flink/pull/6638#discussion_r215349665 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/

[jira] [Assigned] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright reassigned FLINK-9172: --- Assignee: Eron Wright (was: Rong Rong) > Support external catalog factory that comes defau

[GitHub] tragicjun opened a new pull request #6664: [hotfix][docs] Remove redundant word in javadocs

tragicjun opened a new pull request #6664: [hotfix][docs] Remove redundant word in javadocs URL: https://github.com/apache/flink/pull/6664 This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604589#comment-16604589 ] ASF GitHub Bot commented on FLINK-10261: yanghua commented on a change in pull r

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604591#comment-16604591 ] ASF GitHub Bot commented on FLINK-10261: yanghua commented on a change in pull r

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604590#comment-16604590 ] ASF GitHub Bot commented on FLINK-10261: yanghua commented on a change in pull r

[GitHub] yanghua commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

yanghua commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r215327571 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SortITCase

[GitHub] yanghua commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

yanghua commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r215327606 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/sql/SortITCase

[GitHub] yanghua commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

yanghua commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r215327517 ## File path: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/stream/sql/validation/Sor

[jira] [Commented] (FLINK-10267) [State] Fix arbitrary iterator access on RocksDBMapIterator

[ https://issues.apache.org/jira/browse/FLINK-10267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604586#comment-16604586 ] ASF GitHub Bot commented on FLINK-10267: Myasuka commented on issue #6638: [FLIN

[GitHub] Myasuka commented on issue #6638: [FLINK-10267][State] Fix arbitrary iterator access on RocksDBMapIterator

Myasuka commented on issue #6638: [FLINK-10267][State] Fix arbitrary iterator access on RocksDBMapIterator URL: https://github.com/apache/flink/pull/6638#issuecomment-418780838 @azagrebin Really thanks for your review, and sorry for the late reply since I just have a couple busy days after

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604577#comment-16604577 ] ASF GitHub Bot commented on FLINK-10205: yanghua commented on issue #6657: [

[GitHub] yanghua commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource…

yanghua commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6657#issuecomment-418776835 @isunjin It seems that you don't need to have permission to edit the wiki right away. You can write th

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604542#comment-16604542 ] Rong Rong commented on FLINK-9172: -- [~eronwright] oh absolutely! Please feel free to ass

[jira] [Commented] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

[ https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604528#comment-16604528 ] ASF GitHub Bot commented on FLINK-9735: --- yanghua commented on issue #6660: [FLINK-9

[GitHub] yanghua commented on issue #6660: [FLINK-9735] Potential resource leak in RocksDBStateBackend#getDbOptions

yanghua commented on issue #6660: [FLINK-9735] Potential resource leak in RocksDBStateBackend#getDbOptions URL: https://github.com/apache/flink/pull/6660#issuecomment-418767941 @azagrebin and @StefanRRichter can you review this PR? thanks~ --

[GitHub] TisonKun commented on issue #6644: [hotfix] check correct parameter

TisonKun commented on issue #6644: [hotfix] check correct parameter URL: https://github.com/apache/flink/pull/6644#issuecomment-418762782 thanks @GJL ! cc @zentol @NicoK This is an automated message from the Apache Git

[jira] [Commented] (FLINK-10287) Flink HA Persist Cancelled Job in Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-10287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604505#comment-16604505 ] Sayat Satybaldiyev commented on FLINK-10287: Might be related to https://iss

[jira] [Created] (FLINK-10287) Flink HA Persist Cancelled Job in Zookeeper

Sayat Satybaldiyev created FLINK-10287: -- Summary: Flink HA Persist Cancelled Job in Zookeeper Key: FLINK-10287 URL: https://issues.apache.org/jira/browse/FLINK-10287 Project: Flink Issue

[jira] [Commented] (FLINK-7964) Add Apache Kafka 1.0/1.1 connectors

[ https://issues.apache.org/jira/browse/FLINK-7964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604489#comment-16604489 ] ASF GitHub Bot commented on FLINK-7964: --- pnowojski commented on issue #6577: [FLINK

[GitHub] pnowojski commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors

pnowojski commented on issue #6577: [FLINK-7964] Add Apache Kafka 1.0/1.1 connectors URL: https://github.com/apache/flink/pull/6577#issuecomment-418755545 I’m not sure if auto detecting support for transactions is worth the trouble. It might be as easy as switching to at least once mode, b

[jira] [Commented] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-10286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604477#comment-16604477 ] Sayat Satybaldiyev commented on FLINK-10286: [~GJL] I believe it causes the

[jira] [Updated] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper

[ https://issues.apache.org/jira/browse/FLINK-10286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sayat Satybaldiyev updated FLINK-10286: --- Description: In HA mode Flink 1.6, Flink persist job graph in Zookpeer even if the j

[jira] [Created] (FLINK-10286) Flink Persist Invalid Job Graph in Zookeeper

Sayat Satybaldiyev created FLINK-10286: -- Summary: Flink Persist Invalid Job Graph in Zookeeper Key: FLINK-10286 URL: https://issues.apache.org/jira/browse/FLINK-10286 Project: Flink Issu

[jira] [Commented] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway

[ https://issues.apache.org/jira/browse/FLINK-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604432#comment-16604432 ] ASF GitHub Bot commented on FLINK-10193: jelmerk commented on issue #6601: [FLIN

[GitHub] jelmerk commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint

jelmerk commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint URL: https://github.com/apache/flink/pull/6601#issuecomment-418739345 Any ETA on this ? for non trivial jobs with a lot of state this is critical --

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604402#comment-16604402 ] ASF GitHub Bot commented on FLINK-10205: isunjin commented on issue #6657: [

[GitHub] isunjin commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource…

isunjin commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6657#issuecomment-418730339 I have my document ready, but I don’t have permission to edit the wiki, Stephan, could you grant me th

[GitHub] zentol commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource…

zentol commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6657#issuecomment-418717373 In the JIRA a design document was explicitly requested. Is this accessible anywhere? -

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604351#comment-16604351 ] ASF GitHub Bot commented on FLINK-10205: zentol commented on issue #6657: [F

[jira] [Commented] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604353#comment-16604353 ] ASF GitHub Bot commented on FLINK-10205: zentol commented on issue #6657: [F

[GitHub] zentol commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource…

zentol commented on issue #6657: [FLINK-10205] [JobManager] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6657#issuecomment-418717042 @isunjin Please fill out the PR template. -

[jira] [Updated] (FLINK-10285) Bump shade-plugin to 3.1.1

[ https://issues.apache.org/jira/browse/FLINK-10285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10285: - Summary: Bump shade-plugin to 3.1.1 (was: Bum shade-plugin to 3.1.1) > Bump shade-plugi

[jira] [Created] (FLINK-10285) Bum shade-plugin to 3.1.1

Chesnay Schepler created FLINK-10285: Summary: Bum shade-plugin to 3.1.1 Key: FLINK-10285 URL: https://issues.apache.org/jira/browse/FLINK-10285 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero.

[ https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10284: --- Component/s: Streaming > TumblingEventTimeWindows's offset should can be less than zero. > -

[jira] [Updated] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero.

[ https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-10284: --- Affects Version/s: 1.6.0 > TumblingEventTimeWindows's offset should can be less than zero. > ---

[jira] [Assigned] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero.

[ https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao reassigned FLINK-10284: -- Assignee: Jiayi Liao > TumblingEventTimeWindows's offset should can be less than zero. >

[jira] [Created] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero.

Jiayi Liao created FLINK-10284: -- Summary: TumblingEventTimeWindows's offset should can be less than zero. Key: FLINK-10284 URL: https://issues.apache.org/jira/browse/FLINK-10284 Project: Flink

[jira] [Updated] (FLINK-10111) Test failure because of HAQueryableStateFsBackendITCase#testMapState throws NPE

[ https://issues.apache.org/jira/browse/FLINK-10111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lyndldeng updated FLINK-10111: -- Summary: Test failure because of HAQueryableStateFsBackendITCase#testMapState throws NPE (was: Test f

[jira] [Assigned] (FLINK-10111) Test failure because of HAQueryableStateFsBackendITCase#testMapState thorws NPE

[ https://issues.apache.org/jira/browse/FLINK-10111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lyndldeng reassigned FLINK-10111: - Assignee: lyndldeng > Test failure because of HAQueryableStateFsBackendITCase#testMapState thor

[jira] [Commented] (FLINK-10209) Exclude jdk.tools dependency from hadoop when running with java 9

[ https://issues.apache.org/jira/browse/FLINK-10209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604280#comment-16604280 ] ASF GitHub Bot commented on FLINK-10209: zentol opened a new pull request #6663:

[jira] [Updated] (FLINK-10209) Exclude jdk.tools dependency from hadoop when running with java 9

[ https://issues.apache.org/jira/browse/FLINK-10209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10209: --- Labels: pull-request-available (was: ) > Exclude jdk.tools dependency from hadoop when runn

[GitHub] zentol opened a new pull request #6663: [FLINK-10209][build] Exclude jdk.tools dependency from hadoop

zentol opened a new pull request #6663: [FLINK-10209][build] Exclude jdk.tools dependency from hadoop URL: https://github.com/apache/flink/pull/6663 ## What is the purpose of the change This PR excludes the `jdk.tools` dependency from hadoop when building with java 9. This depende

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

[ https://issues.apache.org/jira/browse/FLINK-10281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604274#comment-16604274 ] ASF GitHub Bot commented on FLINK-10281: yanghua commented on issue #6659: [FLIN

[GitHub] yanghua commented on issue #6659: [FLINK-10281] Table function parse regular expression contains backslash failed

yanghua commented on issue #6659: [FLINK-10281] Table function parse regular expression contains backslash failed URL: https://github.com/apache/flink/pull/6659#issuecomment-418688875 cc @twalthr @fhueske This is an automate

[jira] [Updated] (FLINK-10283) FileCache logs unnecessary warnings

[ https://issues.apache.org/jira/browse/FLINK-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10283: --- Labels: pull-request-available (was: ) > FileCache logs unnecessary warnings >

[jira] [Commented] (FLINK-10283) FileCache logs unnecessary warnings

[ https://issues.apache.org/jira/browse/FLINK-10283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604273#comment-16604273 ] ASF GitHub Bot commented on FLINK-10283: zentol opened a new pull request #6662:

[GitHub] zentol opened a new pull request #6662: [FLINK-10283][runtime] Remove misleading logging in FileCache

zentol opened a new pull request #6662: [FLINK-10283][runtime] Remove misleading logging in FileCache URL: https://github.com/apache/flink/pull/6662 ## What is the purpose of the change Removes a misleading WARN message as createTmpFiles is only called when the DistributedCache was

[jira] [Created] (FLINK-10283) FileCache logs unnecessary warnings

Chesnay Schepler created FLINK-10283: Summary: FileCache logs unnecessary warnings Key: FLINK-10283 URL: https://issues.apache.org/jira/browse/FLINK-10283 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-9172) Support external catalog factory that comes default with SQL-Client

[ https://issues.apache.org/jira/browse/FLINK-9172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604258#comment-16604258 ] Eron Wright commented on FLINK-9172: - [~walterddr] I had some time and put together

[GitHub] zentol closed pull request #6647: [hotfix][docs] Fix error html tag in batch index documentatition

zentol closed pull request #6647: [hotfix][docs] Fix error html tag in batch index documentatition URL: https://github.com/apache/flink/pull/6647 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As

[jira] [Commented] (FLINK-10282) Provide separate thread-pool for REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-10282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604213#comment-16604213 ] ASF GitHub Bot commented on FLINK-10282: zentol opened a new pull request #6661:

[jira] [Updated] (FLINK-10282) Provide separate thread-pool for REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-10282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10282: --- Labels: pull-request-available (was: ) > Provide separate thread-pool for REST endpoint > -

[GitHub] zentol opened a new pull request #6661: FLINK-10282][runtime] Separate RPC and REST thread-pools

zentol opened a new pull request #6661: FLINK-10282][runtime] Separate RPC and REST thread-pools URL: https://github.com/apache/flink/pull/6661 ## What is the purpose of the change With this PR the REST endpoints are given their own thread-pool and don't share it with the Dispatcher

[jira] [Created] (FLINK-10282) Provide separate thread-pool for REST endpoint

Chesnay Schepler created FLINK-10282: Summary: Provide separate thread-pool for REST endpoint Key: FLINK-10282 URL: https://issues.apache.org/jira/browse/FLINK-10282 Project: Flink Issue

[jira] [Commented] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

[ https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604175#comment-16604175 ] ASF GitHub Bot commented on FLINK-9735: --- yanghua opened a new pull request #6660: [

[jira] [Updated] (FLINK-9735) Potential resource leak in RocksDBStateBackend#getDbOptions

[ https://issues.apache.org/jira/browse/FLINK-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-9735: -- Labels: pull-request-available (was: ) > Potential resource leak in RocksDBStateBackend#getDbO

[GitHub] yanghua opened a new pull request #6660: [FLINK-9735] Potential resource leak in RocksDBStateBackend#getDbOptions

yanghua opened a new pull request #6660: [FLINK-9735] Potential resource leak in RocksDBStateBackend#getDbOptions URL: https://github.com/apache/flink/pull/6660 ## What is the purpose of the change *This pull request fix Potential resource leak in RocksDBStateBackend#getDbOptions*

[jira] [Commented] (FLINK-10215) Add configuration of java option for historyserver

[ https://issues.apache.org/jira/browse/FLINK-10215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604150#comment-16604150 ] ASF GitHub Bot commented on FLINK-10215: liuxianjiao commented on issue #6612: [

[GitHub] liuxianjiao commented on issue #6612: [FLINK-10215]Add configuration of java option for historyserver

liuxianjiao commented on issue #6612: [FLINK-10215]Add configuration of java option for historyserver URL: https://github.com/apache/flink/pull/6612#issuecomment-418655574 @tillrohrmann @twalthr can you help review this PR? Thanks. -

[jira] [Commented] (FLINK-7243) Add ParquetInputFormat

[ https://issues.apache.org/jira/browse/FLINK-7243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604138#comment-16604138 ] ASF GitHub Bot commented on FLINK-7243: --- lvhuyen commented on issue #6483: [FLINK-7

[GitHub] lvhuyen commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format

lvhuyen commented on issue #6483: [FLINK-7243][flink-formats] Add parquet input format URL: https://github.com/apache/flink/pull/6483#issuecomment-418650688 Hi Zhenqiu, I tried to read a parquet file using the code in your PR, and got the following error when reading a column of typ

[jira] [Closed] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState

[ https://issues.apache.org/jira/browse/FLINK-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10125. Resolution: Won't Fix > Unclosed ByteArrayDataOutputView in RocksDBMapState >

[jira] [Commented] (FLINK-10125) Unclosed ByteArrayDataOutputView in RocksDBMapState

[ https://issues.apache.org/jira/browse/FLINK-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604128#comment-16604128 ] vinoyang commented on FLINK-10125: -- [~azagrebin] *ByteArrayDataOutputView* was been rep

[jira] [Updated] (FLINK-10281) Table function parse regular expression contains backslash failed

[ https://issues.apache.org/jira/browse/FLINK-10281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10281: --- Labels: pull-request-available (was: ) > Table function parse regular expression contains b

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

[ https://issues.apache.org/jira/browse/FLINK-10281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604103#comment-16604103 ] ASF GitHub Bot commented on FLINK-10281: yanghua opened a new pull request #6659

[GitHub] yanghua opened a new pull request #6659: [FLINK-10281] Table function parse regular expression contains backslash failed

yanghua opened a new pull request #6659: [FLINK-10281] Table function parse regular expression contains backslash failed URL: https://github.com/apache/flink/pull/6659 ## What is the purpose of the change *This pull request fixes Table function parse regular expression contains

[jira] [Commented] (FLINK-10209) Exclude jdk.tools dependency from hadoop when running with java 9

[ https://issues.apache.org/jira/browse/FLINK-10209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604088#comment-16604088 ] Chesnay Schepler commented on FLINK-10209: -- Travis is passing even if we exclud

[jira] [Updated] (FLINK-10150) Chained batch operators interfere with each other other

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10150: - Summary: Chained batch operators interfere with each other other (was: Inconsistent num

[jira] [Closed] (FLINK-10150) Chained batch operators interfere with each other other

[ https://issues.apache.org/jira/browse/FLINK-10150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-10150. Resolution: Fixed master: 93ac95866e4473982a89e563d58ef0e374b3c0ba 1.6: 38f75527335a711ee0

[jira] [Updated] (FLINK-10243) Add option to reduce latency metrics granularity

[ https://issues.apache.org/jira/browse/FLINK-10243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10243: --- Labels: pull-request-available (was: ) > Add option to reduce latency metrics granularity >

[jira] [Commented] (FLINK-10243) Add option to reduce latency metrics granularity

[ https://issues.apache.org/jira/browse/FLINK-10243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16604079#comment-16604079 ] ASF GitHub Bot commented on FLINK-10243: zentol opened a new pull request #6658:

[GitHub] zentol opened a new pull request #6658: [FLINK-10243][metrics] Make latency metrics granularity configurable

zentol opened a new pull request #6658: [FLINK-10243][metrics] Make latency metrics granularity configurable URL: https://github.com/apache/flink/pull/6658 ## What is the purpose of the change This PR makes the latency metric granularity configurable. Let's say we have 2 sources S