link3280 opened a new pull request #7314: [FLINK-11135][YARN] Refactor Hadoop
config loading in HadoopUtils
URL: https://github.com/apache/flink/pull/7314
## What is the purpose of the change
Currently, Hadoop config search order is: `HADOOP_HOME > HADOOP_CONF_DIR >
Flink
[
https://issues.apache.org/jira/browse/FLINK-11135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-11135:
-
Description: Currently, Hadoop config search order is: `HADOOP_HOME >
HADOOP_CONF_DIR > Flink
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r242036662
##
File path:
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r242036662
##
File path:
leesf commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats %
for transaction ID
URL: https://github.com/apache/flink/pull/7262#issuecomment-447745066
@tillrohrmann hi till, could you please merge this pr when you are free.
Thanks
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TisonKun reassigned FLINK-11174:
Assignee: TisonKun
> flink Metrics Prometheus labels support chinese
>
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722731#comment-16722731
]
TisonKun commented on FLINK-11174:
--
I see your concern and agree with you.
FLINK filters the label
[
https://issues.apache.org/jira/browse/FLINK-11078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722729#comment-16722729
]
Yang Wang commented on FLINK-11078:
---
I think this is a very useful feature, especially for running
[
https://issues.apache.org/jira/browse/FLINK-11174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan weiwen updated FLINK-11174:
---
Labels: pull-request-available (was: )
> flink Metrics Prometheus labels support chinese
>
jparkie commented on a change in pull request #6782: [FLINK-9083][Cassandra
Connector] Add async backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#discussion_r242036662
##
File path:
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_r242035345
##
File path:
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_r242035333
##
File path:
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_r242035293
##
File path:
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_r242035232
##
File path:
dianfu commented on issue #7253: [FLINK-11074] [table][tests] Enable harness
tests with RocksdbStateBackend and add harness tests for CollectAggFunction
URL: https://github.com/apache/flink/pull/7253#issuecomment-447734928
@sunjincheng121 @walterddr Thanks a lot for the review and merge.
sunjincheng121 commented on issue #7201: [FLINK-7208] [table] Optimize
Min/MaxWithRetractAggFunction with DataView
URL: https://github.com/apache/flink/pull/7201#issuecomment-447734443
@dianfu the FLINK-11074 has been merged, I am very grateful if you can add
the harness in current PR.
[
https://issues.apache.org/jira/browse/FLINK-11074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-11074.
---
Resolution: Fixed
Fix Version/s: 1.8.0
Fixed in mater:
asfgit closed pull request #7253: [FLINK-11074] [table][tests] Enable harness
tests with RocksdbStateBackend and add harness tests for CollectAggFunction
URL: https://github.com/apache/flink/pull/7253
This is a PR merged from a forked repository.
As GitHub hides the original diff on
Fan weiwen created FLINK-11174:
--
Summary: flink Metrics Prometheus labels support chinese
Key: FLINK-11174
URL: https://issues.apache.org/jira/browse/FLINK-11174
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-11135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-11135:
-
Summary: Refactor Hadoop config loading in HadoopUtils (was: Refactor
Hadoop config loading order)
>
[
https://issues.apache.org/jira/browse/FLINK-11135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-11135:
-
Summary: Refactor Hadoop config loading order (was: Refactor Hadoop config
loading orders)
> Refactor
[
https://issues.apache.org/jira/browse/FLINK-11135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Paul Lin updated FLINK-11135:
-
Description: Currently, Hadoop config search order is: `HADOOP_HOME >
HADOOP_CONF_DIR > Flink
[
https://issues.apache.org/jira/browse/FLINK-11173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11173:
-
Summary: Proctime attribute validation throws an incorrect exception
message (was: Proctime Attribute
[
https://issues.apache.org/jira/browse/FLINK-11173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang updated FLINK-11173:
-
Description:
In {{TableSourceUtil#validateTableSource, when uses DefinedProctimeAttribute}}
vinoyang created FLINK-11173:
Summary: Proctime Attribute validation throws an incorrect
exception message
Key: FLINK-11173
URL: https://issues.apache.org/jira/browse/FLINK-11173
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722668#comment-16722668
]
Hequn Cheng commented on FLINK-11172:
-
[~karmagyz] Good catch! It would be nice if we can ensure the
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242019404
##
File path:
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242015355
##
File path:
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242019417
##
File path:
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242018334
##
File path:
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242019782
##
File path:
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242014642
##
File path:
buptljy commented on issue #7310: [FLINK-10594][table] Add Subsets for CEP
URL: https://github.com/apache/flink/pull/7310#issuecomment-447712484
@dawidwys Thanks for pointing it out. I will figure out the affected clauses
or cases and think about this more deeploy, then update it in JIRA.
zhuzhurk commented on a change in pull request #7255: [FLINK-10945] Use
InputDependencyConstraint to avoid resource dead…
URL: https://github.com/apache/flink/pull/7255#discussion_r242017559
##
File path:
Yangze Guo created FLINK-11172:
--
Summary: Remove the max retention time in StreamQueryConfig
Key: FLINK-11172
URL: https://issues.apache.org/jira/browse/FLINK-11172
Project: Flink
Issue Type:
hequn8128 commented on issue #7209: [FLINK-10977][table] Add UnBounded
FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#issuecomment-447705819
@dianfu Thanks a lot for your review and great suggestions.
I addressed almost all of your comments
dianfu commented on a change in pull request #7209: [FLINK-10977][table] Add
UnBounded FlatAggregate operator to streaming Table API
URL: https://github.com/apache/flink/pull/7209#discussion_r242013108
##
File path:
ifndef-SleePy opened a new pull request #7290: [FLINK-11137] [runtime] Fix
unexpected RegistrationTimeoutException of TaskExecutor
URL: https://github.com/apache/flink/pull/7290
## What is the purpose of the change
* Fix bug about unexpected `RegistrationTimeoutException` of
ifndef-SleePy closed pull request #7290: [FLINK-11137] [runtime] Fix unexpected
RegistrationTimeoutException of TaskExecutor
URL: https://github.com/apache/flink/pull/7290
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
sunjincheng121 commented on issue #7253: [FLINK-11074] [table][tests] Enable
harness tests with RocksdbStateBackend and add harness tests for
CollectAggFunction
URL: https://github.com/apache/flink/pull/7253#issuecomment-447696370
Merging...
[
https://issues.apache.org/jira/browse/FLINK-11170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng reassigned FLINK-11170:
---
Assignee: Hequn Cheng
> Support DISTINCT aggregates in MATCH_RECOGNIZE
>
zentol edited a comment on issue #7292: [FLINK-11101][S3] Ban openjdk.jol
dependencies
URL: https://github.com/apache/flink/pull/7292#issuecomment-447669712
The current exclusion in the sahde-plugin has in no actual effect since the
openjdk dependency is already excluded in the dependency
zentol commented on issue #7292: [FLINK-11101][S3] Ban openjdk.jol dependencies
URL: https://github.com/apache/flink/pull/7292#issuecomment-447669712
The current exclusion in the sahde-plugin has in no actual effect since the
openjdk dependency is already excluded in the dependency
lamber-ken commented on issue #7279: [hotfix] add hadoop user name to yarn logs
command
URL: https://github.com/apache/flink/pull/7279#issuecomment-447661302
Hi @twalthr, can you please take a look?
This is an automated
lamber-ken edited a comment on issue #7296: [hotfix][web] fix the desc about
restart strategy in web
URL: https://github.com/apache/flink/pull/7296#issuecomment-447661100
Hi @twalthr, can you please take a look?
This is an
lamber-ken commented on issue #7296: [hotfix][web] fix the desc about restart
strategy in web
URL: https://github.com/apache/flink/pull/7296#issuecomment-447661100
Hi @KarmaGYZ, can you please take a look?
This is an
TisonKun commented on issue #7302: [FLINK-11156] [tests] Reconcile
ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9
URL: https://github.com/apache/flink/pull/7302#issuecomment-447653113
I did it with minimum changes. If we prefer testing classes to mockito
style, we can make a
[
https://issues.apache.org/jira/browse/FLINK-11156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-11156:
Assignee: Gary Yao (was: TisonKun)
> ZooKeeperCompletedCheckpointStoreMockitoTest fails with
>
[
https://issues.apache.org/jira/browse/FLINK-11156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-11156:
Assignee: TisonKun (was: Gary Yao)
> ZooKeeperCompletedCheckpointStoreMockitoTest fails with
>
dawidwys commented on issue #7310: [FLINK-10594][table] Add Subsets for CEP
URL: https://github.com/apache/flink/pull/7310#issuecomment-447638405
Hi @buptljy thank you for your contribution,
Unfortunately I am afraid this PR lacks proper design and misses a lot of
details how `SUBSET`
dawidwys commented on issue #7177: [FLINK-7599] [table] Support for aggregates
in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7177#issuecomment-447637511
Thank you very much @twalthr for your help and review! Will merge it once
travis gives green (as I had to rebase)
dawidwys commented on a change in pull request #7177: [FLINK-7599] [table]
Support for aggregates in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7177#discussion_r241977805
##
File path: docs/dev/table/streaming/match_recognize.md
##
@@ -211,6 +211,65 @@ If a
Dawid Wysakowicz created FLINK-11170:
Summary: Support DISTINCT aggregates in MATCH_RECOGNIZE
Key: FLINK-11170
URL: https://issues.apache.org/jira/browse/FLINK-11170
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722462#comment-16722462
]
Sayat Satybaldiyev commented on FLINK-11171:
cc: [~azagrebin], [~srichter]
> Unexpected
Sayat Satybaldiyev created FLINK-11171:
--
Summary: Unexpected timestamp deserialization failure in RocksDB
state backend
Key: FLINK-11171
URL: https://issues.apache.org/jira/browse/FLINK-11171
[
https://issues.apache.org/jira/browse/FLINK-11168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722458#comment-16722458
]
Chesnay Schepler commented on FLINK-11168:
--
I checked a successful build and the test ran for
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972742
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972721
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972710
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972720
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972705
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972709
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972731
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972708
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972719
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972726
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972733
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972700
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972729
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972737
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972739
##
File path:
hequn8128 commented on a change in pull request #6236: [FLINK-9699] [table] Add
api to replace registered table
URL: https://github.com/apache/flink/pull/6236#discussion_r241972740
##
File path:
[
https://issues.apache.org/jira/browse/FLINK-11158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722416#comment-16722416
]
leesf commented on FLINK-11158:
---
[~NicoK] hi, when using and old/non-existing job ID, the request response
73 matches
Mail list logo
