[GitHub] Aitozi commented on issue #7543: [FLINK-10996]Fix the possible state leak with CEP processing time model

Aitozi commented on issue #7543: [FLINK-10996]Fix the possible state leak with CEP processing time model URL: https://github.com/apache/flink/pull/7543#issuecomment-456022735 Thanks for your reply, I will take a look into that PR these two days.

[GitHub] XuPingyong opened a new pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear

XuPingyong opened a new pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear URL: https://github.com/apache/flink/pull/4267 This is an automated message from the Apache Git Service. To

[GitHub] XuPingyong removed a comment on issue #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear

XuPingyong removed a comment on issue #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear URL: https://github.com/apache/flink/pull/4267#issuecomment-456053593 no need This is an automated message

[GitHub] clarkyzl closed pull request #3473: [FLINK-5833] [table] Support for Hive GenericUDF

clarkyzl closed pull request #3473: [FLINK-5833] [table] Support for Hive GenericUDF URL: https://github.com/apache/flink/pull/3473 This is an automated message from the Apache Git Service. To respond to the message, please

[jira] [Updated] (FLINK-7015) Separate OperatorConfig from StreamConfig

[ https://issues.apache.org/jira/browse/FLINK-7015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7015: -- Labels: pull-request-available (was: ) > Separate OperatorConfig from StreamConfig >

[GitHub] XuPingyong closed pull request #4273: [FLINK-7065] Separate the flink-streaming-java module from flink-clients

XuPingyong closed pull request #4273: [FLINK-7065] Separate the flink-streaming-java module from flink-clients URL: https://github.com/apache/flink/pull/4273 This is an automated message from the Apache Git Service. To

[GitHub] XuPingyong closed pull request #4241: [FLINK-7015] [streaming] separate OperatorConfig from StreamConfig

XuPingyong closed pull request #4241: [FLINK-7015] [streaming] separate OperatorConfig from StreamConfig URL: https://github.com/apache/flink/pull/4241 This is an automated message from the Apache Git Service. To respond to

[GitHub] XuPingyong commented on issue #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear

XuPingyong commented on issue #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear URL: https://github.com/apache/flink/pull/4267#issuecomment-456053593 no need This is an automated message from the

[GitHub] XuPingyong closed pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear

XuPingyong closed pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear URL: https://github.com/apache/flink/pull/4267 This is an automated message from the Apache Git Service. To respond

[jira] [Updated] (FLINK-5833) Support for Hive GenericUDF

[ https://issues.apache.org/jira/browse/FLINK-5833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5833: -- Labels: pull-request-available (was: ) > Support for Hive GenericUDF >

[jira] [Updated] (FLINK-7065) separate the flink-streaming-java module from flink-clients

[ https://issues.apache.org/jira/browse/FLINK-7065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7065: -- Labels: pull-request-available (was: ) > separate the flink-streaming-java module from

[GitHub] godfreyhe closed pull request #4572: [Flink-7243] [connectors] Add ParquetInputFormat

godfreyhe closed pull request #4572: [Flink-7243] [connectors] Add ParquetInputFormat URL: https://github.com/apache/flink/pull/4572 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] godfreyhe closed pull request #3818: [FLINK-5514] [table] Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS

godfreyhe closed pull request #3818: [FLINK-5514] [table] Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS URL: https://github.com/apache/flink/pull/3818 This is an automated message from the Apache

[jira] [Updated] (FLINK-5514) Implement an efficient physical execution for CUBE/ROLLUP/GROUPING SETS

[ https://issues.apache.org/jira/browse/FLINK-5514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5514: -- Labels: pull-request-available (was: ) > Implement an efficient physical execution for

[GitHub] XuPingyong closed pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear

XuPingyong closed pull request #4267: [FLINK-7018][streaming] Refactor streamGraph to make interfaces clear URL: https://github.com/apache/flink/pull/4267 This is an automated message from the Apache Git Service. To respond

[GitHub] godfreyhe closed pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource for partition pruning

godfreyhe closed pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource for partition pruning URL: https://github.com/apache/flink/pull/4667 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-7620) Supports user defined optimization phase

[ https://issues.apache.org/jira/browse/FLINK-7620?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7620: -- Labels: pull-request-available (was: ) > Supports user defined optimization phase >

[jira] [Updated] (FLINK-7018) Refactor streamGraph to make interfaces clear

[ https://issues.apache.org/jira/browse/FLINK-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7018: -- Labels: pull-request-available (was: ) > Refactor streamGraph to make interfaces clear >

[jira] [Updated] (FLINK-6516) using real row count instead of dummy row count when optimizing plan

[ https://issues.apache.org/jira/browse/FLINK-6516?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6516: -- Labels: pull-request-available (was: ) > using real row count instead of dummy row count when

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747810#comment-16747810 ] Dawid Wysakowicz commented on FLINK-11046: -- Hi [~xueyu] Did you manage to make any progress on

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747831#comment-16747831 ] xueyu commented on FLINK-11046: --- Hi, [~dawidwys], sorry that I only writed the codes and didn't write any

[GitHub] zhangxinyu1 commented on issue #6770: [FLINK-10002] [Webfrontend] WebUI shows jm/tm logs more friendly.

zhangxinyu1 commented on issue #6770: [FLINK-10002] [Webfrontend] WebUI shows jm/tm logs more friendly. URL: https://github.com/apache/flink/pull/6770#issuecomment-456045406 Three classes: `JobManagerLogFileHandlerTest.java`, `JobManagerLogListHandlerTest.java`,

[GitHub] Fokko commented on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2

Fokko commented on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2 URL: https://github.com/apache/flink/pull/7497#issuecomment-456021166 Mostly getting ready for Java8> This is an automated

[GitHub] dawidwys commented on issue #7543: [FLINK-10996]Fix the possible state leak with CEP processing time model

dawidwys commented on issue #7543: [FLINK-10996]Fix the possible state leak with CEP processing time model URL: https://github.com/apache/flink/pull/7543#issuecomment-456020369 Hi @Aitozi, First of all I wouldn't say this fixes a bug, but rather introduces a new feature that should be

[GitHub] Fokko commented on issue #7499: [FLINK-11340] Bump commons-configuration from 1.7 to 1.10

Fokko commented on issue #7499: [FLINK-11340] Bump commons-configuration from 1.7 to 1.10 URL: https://github.com/apache/flink/pull/7499#issuecomment-456022861 https://commons.apache.org/proper/commons-configuration/changes-report.html#a1.10

[GitHub] Fokko commented on issue #7498: [FLINK-11339] Bump exec-maven-plugin from 1.5.0 to 1.6.0

Fokko commented on issue #7498: [FLINK-11339] Bump exec-maven-plugin from 1.5.0 to 1.6.0 URL: https://github.com/apache/flink/pull/7498#issuecomment-456022154 https://github.com/mojohaus/exec-maven-plugin/compare/exec-maven-plugin-1.5.0...exec-maven-plugin-1.6.0 Dropped support for

[GitHub] Fokko edited a comment on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2

Fokko edited a comment on issue #7497: [FLINK-11338] Bump maven-enforcer-plugin from 3.0.0-M1 to 3.0.0-M2 URL: https://github.com/apache/flink/pull/7497#issuecomment-456021166 Mostly getting ready for Java8> Failed build is a flaky test:

[GitHub] KurtYoung closed pull request #4940: [FLINK-7959] [table] Split CodeGenerator into CodeGeneratorContext and ExprCodeGenerator.

KurtYoung closed pull request #4940: [FLINK-7959] [table] Split CodeGenerator into CodeGeneratorContext and ExprCodeGenerator. URL: https://github.com/apache/flink/pull/4940 This is an automated message from the Apache Git

[jira] [Updated] (FLINK-7959) Split CodeGenerator into CodeGeneratorContext and ExprCodeGenerator

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

[GitHub] godfreyhe closed pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource for partition pruning

godfreyhe closed pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource for partition pruning URL: https://github.com/apache/flink/pull/4667 This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-5859) support partition pruning on Table API & SQL

[ https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5859: -- Labels: pull-request-available (was: ) > support partition pruning on Table API & SQL >

[GitHub] godfreyhe closed pull request #3860: [FLINK-6516] [table] using real row count instead of dummy row count when optimizing plan

godfreyhe closed pull request #3860: [FLINK-6516] [table] using real row count instead of dummy row count when optimizing plan URL: https://github.com/apache/flink/pull/3860 This is an automated message from the Apache Git

[GitHub] godfreyhe closed pull request #4820: [FLINK-7834] [table] cost model extends network cost and memory cost

godfreyhe closed pull request #4820: [FLINK-7834] [table] cost model extends network cost and memory cost URL: https://github.com/apache/flink/pull/4820 This is an automated message from the Apache Git Service. To respond

[GitHub] godfreyhe closed pull request #4682: [FLINK-7620] [table] Supports user defined optimization phase

godfreyhe closed pull request #4682: [FLINK-7620] [table] Supports user defined optimization phase URL: https://github.com/apache/flink/pull/4682 This is an automated message from the Apache Git Service. To respond to the

[GitHub] godfreyhe opened a new pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource for partition pruning

godfreyhe opened a new pull request #4667: [FLINK-5859] [table] Add PartitionableTableSource for partition pruning URL: https://github.com/apache/flink/pull/4667 ## What is the purpose of the change This pull request adds PartitionableTableSource for partition pruning when

[GitHub] zhangxinyu1 commented on issue #6770: [FLINK-10002] [Webfrontend] WebUI shows jm/tm logs more friendly.

zhangxinyu1 commented on issue #6770: [FLINK-10002] [Webfrontend] WebUI shows jm/tm logs more friendly. URL: https://github.com/apache/flink/pull/6770#issuecomment-456047509 @yanghua @tillrohrmann @ifndef-SleePy Sorry to bother you. Could you please look at this pr if you have time?

[jira] [Commented] (FLINK-6626) Unifying lifecycle management of SubmittedJobGraph- and CompletedCheckpointStore

[ https://issues.apache.org/jira/browse/FLINK-6626?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747808#comment-16747808 ] Till Rohrmann commented on FLINK-6626: -- Sure [~app-tarush]. Before diving into the implementation

[GitHub] wuchong closed pull request #4189: [FLINK-6958] [async] Async I/O hang when the source is bounded and collect timeout

wuchong closed pull request #4189: [FLINK-6958] [async] Async I/O hang when the source is bounded and collect timeout URL: https://github.com/apache/flink/pull/4189 This is an automated message from the Apache Git Service.

[GitHub] Guibo-Pan commented on issue #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL

Guibo-Pan commented on issue #6773: [FLINK-10152] [table] Add reverse function in Table API and SQL URL: https://github.com/apache/flink/pull/6773#issuecomment-455989720 @twalthr @xccui @tillrohrmann Is here anyone who can help review this? Thanks~

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249114818 ## File path:

[GitHub] wuchong closed pull request #4145: [FLINK-6938][FLINK-6939] [cep] Not store IterativeCondition with NFA state and support RichFunction interface

wuchong closed pull request #4145: [FLINK-6938][FLINK-6939] [cep] Not store IterativeCondition with NFA state and support RichFunction interface URL: https://github.com/apache/flink/pull/4145 This is an automated message

[jira] [Updated] (FLINK-6958) Async I/O timeout not work

[ https://issues.apache.org/jira/browse/FLINK-6958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6958: -- Labels: pull-request-available (was: ) > Async I/O timeout not work >

[GitHub] fhueske commented on issue #6873: [hotfix] Add Review Progress section to PR description template.

fhueske commented on issue #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#issuecomment-456085278 I think if we modify the review checklist in place (i.e., update it in the PR description) this is almost automatically

[GitHub] hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion

hequn8128 commented on a change in pull request #6787: [FLINK-8577][table] Implement proctime DataStream to Table upsert conversion URL: https://github.com/apache/flink/pull/6787#discussion_r249476414 ## File path:

[GitHub] StefanRRichter commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy

StefanRRichter commented on issue #7009: [FLINK-10712] Support to restore state when using RestartPipelinedRegionStrategy URL: https://github.com/apache/flink/pull/7009#issuecomment-456105318 I think I agree with the assessment of the existing operators. About adding a

[jira] [Assigned] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException

[ https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kezhu Wang reassigned FLINK-11326: -- Assignee: Kezhu Wang > Using offsets to adjust windows to timezones UTC-8 throws >

[jira] [Updated] (FLINK-6196) Support dynamic schema in Table Function

[ https://issues.apache.org/jira/browse/FLINK-6196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-6196: -- Labels: pull-request-available (was: ) > Support dynamic schema in Table Function >

[GitHub] clarkyzl closed pull request #3623: [FLINK-6196] [table] Support dynamic schema in Table Function

clarkyzl closed pull request #3623: [FLINK-6196] [table] Support dynamic schema in Table Function URL: https://github.com/apache/flink/pull/3623 This is an automated message from the Apache Git Service. To respond to the

[jira] [Created] (FLINK-11399) Parsing nested ROW()s in SQL

Benoît Paris created FLINK-11399: Summary: Parsing nested ROW()s in SQL Key: FLINK-11399 URL: https://issues.apache.org/jira/browse/FLINK-11399 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-7834) cost model (RelOptCost) extends network cost and memory cost

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

[jira] [Commented] (FLINK-11249) FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer

[ https://issues.apache.org/jira/browse/FLINK-11249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747937#comment-16747937 ] Piotr Nowojski commented on FLINK-11249: I have realised about one more issue. This fix alone

[jira] [Created] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

Hequn Cheng created FLINK-11398: --- Summary: Add a dedicated phase to materialize time indicators for nodes produce updates Key: FLINK-11398 URL: https://issues.apache.org/jira/browse/FLINK-11398

[jira] [Created] (FLINK-11400) JobManagerRunner does not wait for suspension of JobMaster

Till Rohrmann created FLINK-11400: - Summary: JobManagerRunner does not wait for suspension of JobMaster Key: FLINK-11400 URL: https://issues.apache.org/jira/browse/FLINK-11400 Project: Flink

[GitHub] rmetzger commented on issue #6873: [hotfix] Add Review Progress section to PR description template.

rmetzger commented on issue #6873: [hotfix] Add Review Progress section to PR description template. URL: https://github.com/apache/flink/pull/6873#issuecomment-456081384 @zentol: I'm a bit against this `**NOTE: THE REVIEW PROGRESS MUST ONLY BE UPDATED BY AN APACHE FLINK COMMITTER!**`

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249367559 ## File path:

[GitHub] dawidwys commented on a change in pull request #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution …

dawidwys commented on a change in pull request #7436: [FLINK-11071][core] add support for dynamic proxy classes resolution … URL: https://github.com/apache/flink/pull/7436#discussion_r249462832 ## File path: flink-core/src/test/java/org/apache/flink/util/InstantiationUtilTest.java

[jira] [Updated] (FLINK-11398) Add a dedicated phase to materialize time indicators for nodes produce updates

[ https://issues.apache.org/jira/browse/FLINK-11398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11398: Description: As discussed

[GitHub] bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager

bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager URL: https://github.com/apache/flink/pull/7011#issuecomment-456154882 closing this PR in favor of new plan

[GitHub] bowenli86 closed pull request #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager

bowenli86 closed pull request #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager URL: https://github.com/apache/flink/pull/7011 This is an automated message from the

[GitHub] bowenli86 closed pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs

bowenli86 closed pull request #6970: [FLINK-10696][Table API & SQL]Add APIs to ExternalCatalog, CrudExternalCatalog and InMemoryCrudExternalCatalog for views and UDFs URL: https://github.com/apache/flink/pull/6970 This is

[GitHub] bowenli86 closed pull request #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java

bowenli86 closed pull request #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java URL: https://github.com/apache/flink/pull/7012 This is an automated message from the Apache Git Service. To respond to the

[GitHub] bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java

bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java URL: https://github.com/apache/flink/pull/7012#issuecomment-456154851 closing this PR in favor of new plan This is an

[GitHub] bowenli86 commented on issue #6997: [FLINK-10697][Table & SQL] Create an in-memory catalog that stores Flink's meta objects

bowenli86 commented on issue #6997: [FLINK-10697][Table & SQL] Create an in-memory catalog that stores Flink's meta objects URL: https://github.com/apache/flink/pull/6997#issuecomment-456154907 closing this PR in favor of new plan

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249512219 ## File path:

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249368384 ## File path:

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249478973 ## File path:

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249510977 ## File path:

[GitHub] azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

azagrebin commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249482757 ## File path:

[jira] [Commented] (FLINK-11400) JobManagerRunner does not wait for suspension of JobMaster

[ https://issues.apache.org/jira/browse/FLINK-11400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748078#comment-16748078 ] TisonKun commented on FLINK-11400: -- Do you mean introduce a {{recoveryOperation}} in

[GitHub] GJL opened a new pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base

GJL opened a new pull request #7546: [FLINK-11390][tests] Port YARNSessionCapacitySchedulerITCase#testTaskManagerFailure to new code base URL: https://github.com/apache/flink/pull/7546 ## What is the purpose of the change *Port

[jira] [Updated] (FLINK-11401) Allow compression on ParquetBulkWriter

[ https://issues.apache.org/jira/browse/FLINK-11401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11401: --- Labels: pull-request-available (was: ) > Allow compression on ParquetBulkWriter >

[GitHub] Fokko opened a new pull request #7547: [FLINK-11401] Allow setting of compression on ParquetWriter

Fokko opened a new pull request #7547: [FLINK-11401] Allow setting of compression on ParquetWriter URL: https://github.com/apache/flink/pull/7547 ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather

[jira] [Created] (FLINK-11401) Allow compression on ParquetBulkWriter

Fokko Driesprong created FLINK-11401: Summary: Allow compression on ParquetBulkWriter Key: FLINK-11401 URL: https://issues.apache.org/jira/browse/FLINK-11401 Project: Flink Issue Type:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249606898 ## File path:

[GitHub] kezhuw opened a new pull request #7548: [FLINK-11326] Fix forbidden negative offset in window assigners

kezhuw opened a new pull request #7548: [FLINK-11326] Fix forbidden negative offset in window assigners URL: https://github.com/apache/flink/pull/7548 ## What is the purpose of the change Allow negative window offset in window assignment as the javadoc says. ## Brief change log

[jira] [Updated] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11402: Component/s: Local Runtime > User code can fail with an UnsatisfiedLinkError in the presence of

[jira] [Updated] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException

[ https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kezhu Wang updated FLINK-11326: --- Affects Version/s: 1.7.1 > Using offsets to adjust windows to timezones UTC-8 throws >

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249606803 ## File path:

[GitHub] KarmaGYZ commented on issue #7423: [hotfix][docs] Remove the legacy hint in production-ready doc

KarmaGYZ commented on issue #7423: [hotfix][docs] Remove the legacy hint in production-ready doc URL: https://github.com/apache/flink/pull/7423#issuecomment-456233322 @alpinegizmo Thanks for the review. In the stale version, this sentence point to the asynchronous snapshotting.

[GitHub] dianfu closed pull request #7354: [FLINK-11214] [table] Support non mergable aggregates for group windows on batch table

dianfu closed pull request #7354: [FLINK-11214] [table] Support non mergable aggregates for group windows on batch table URL: https://github.com/apache/flink/pull/7354 This is an automated message from the Apache Git

[jira] [Commented] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748241#comment-16748241 ] Ufuk Celebi commented on FLINK-11402: - Similar issue for RocksDB (FLINK-5408) > User code can fail

[jira] [Updated] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11402: Attachment: hello-snappy.tgz > User code can fail with an UnsatisfiedLinkError in the presence of

[jira] [Updated] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

[ https://issues.apache.org/jira/browse/FLINK-11402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-11402: Attachment: hello-snappy-1.0-SNAPSHOT.jar > User code can fail with an UnsatisfiedLinkError in

[GitHub] KarmaGYZ commented on a change in pull request #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc

KarmaGYZ commented on a change in pull request #7260: [hotfix][docs] Fix typo and make improvement in Kafka Connectors doc URL: https://github.com/apache/flink/pull/7260#discussion_r249611548 ## File path: docs/dev/connectors/kafka.md ## @@ -681,13 +681,13 @@ chosen by

[GitHub] stevenzwu commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

stevenzwu commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249606472 ## File path:

[jira] [Updated] (FLINK-11326) Using offsets to adjust windows to timezones UTC-8 throws IllegalArgumentException

[ https://issues.apache.org/jira/browse/FLINK-11326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11326: --- Labels: pull-request-available (was: ) > Using offsets to adjust windows to timezones

[jira] [Created] (FLINK-11402) User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders

Ufuk Celebi created FLINK-11402: --- Summary: User code can fail with an UnsatisfiedLinkError in the presence of multiple classloaders Key: FLINK-11402 URL: https://issues.apache.org/jira/browse/FLINK-11402

[GitHub] stevenzwu commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

stevenzwu commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249607011 ## File path:

[GitHub] stevenzwu commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

stevenzwu commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249607011 ## File path:

[jira] [Closed] (FLINK-11214) Support non mergable aggregates for group windows on batch table

[ https://issues.apache.org/jira/browse/FLINK-11214?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-11214. --- Resolution: Won't Do > Support non mergable aggregates for group windows on batch table >

[GitHub] Clarkkkkk closed pull request #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase

Clark closed pull request #6628: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase URL: https://github.com/apache/flink/pull/6628 This is an automated message from the

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249637422 ## File path:

[jira] [Commented] (FLINK-9920) BucketingSinkFaultToleranceITCase fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748419#comment-16748419 ] Yun Tang commented on FLINK-9920: - Another instance: 

[jira] [Issue Comment Deleted] (FLINK-11374) See more failover and can filter by time range

[ https://issues.apache.org/jira/browse/FLINK-11374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-11374: --- Comment: was deleted (was: agg by vertex !image-2019-01-22-11-42-33-808.png!) > See more failover and can

[jira] [Created] (FLINK-11405) rest api can see exception by start end time filter

lining created FLINK-11405: -- Summary: rest api can see exception by start end time filter Key: FLINK-11405 URL: https://issues.apache.org/jira/browse/FLINK-11405 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11404) web ui add see page and can filter by time

lining created FLINK-11404: -- Summary: web ui add see page and can filter by time Key: FLINK-11404 URL: https://issues.apache.org/jira/browse/FLINK-11404 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-6101) GroupBy fields with arithmetic expression (include UDF) can not be selected

[ https://issues.apache.org/jira/browse/FLINK-6101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln.lee closed FLINK-6101. -- Resolution: Later > GroupBy fields with arithmetic expression (include UDF) can not be selected >

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249637189 ## File path:

[GitHub] alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers

alexeyt820 commented on a change in pull request #6615: [FLINK-8354] [flink-connectors] Add ability to access and provider Kafka headers URL: https://github.com/apache/flink/pull/6615#discussion_r249637189 ## File path:

[jira] [Created] (FLINK-11403) Remove ResultPartitionConsumableNotifier from ResultPartition

zhijiang created FLINK-11403: Summary: Remove ResultPartitionConsumableNotifier from ResultPartition Key: FLINK-11403 URL: https://issues.apache.org/jira/browse/FLINK-11403 Project: Flink Issue

  1   2   >