[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831429#comment-16831429
]
Yu Yang commented on FLINK-12389:
-
[~fhue...@gmail.com] could you share any pointers on
[
https://issues.apache.org/jira/browse/FLINK-12389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831429#comment-16831429
]
Yu Yang edited comment on FLINK-12389 at 5/2/19 6:30 AM:
-
[~fhue
Yu Yang created FLINK-12389:
---
Summary: flink codegen set String type for ByteBuffer fields
Key: FLINK-12389
URL: https://issues.apache.org/jira/browse/FLINK-12389
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-12342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831427#comment-16831427
]
Zhenqiu Huang commented on FLINK-12342:
---
As using the config and set it to 3000 mi
HuangZhenQiu commented on issue #8306: [FLINK-12342] Add fast-heartbeat-delay
yarn config for jobs with large number of containers
URL: https://github.com/apache/flink/pull/8306#issuecomment-488563188
@tillrohrmann @rmetzger
As using the config and set it to 3000 milliseconds, the job
bowenli86 commented on issue #8329: [FLINK-12239][hive] Support table related
operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#issuecomment-488562799
Thanks @xuefuz for reviewing! I've addressed the comments.
Would also be great to have @KurtYo
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280257423
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apac
bowenli86 commented on issue #8325: [hotfix] [table] Refactor
GenericInMemoryCatalogTest to prepare for moving common tests to CatalogTestBase
URL: https://github.com/apache/flink/pull/8325#issuecomment-488559175
This is the first time I merged a PR and I'm still trying to figure out the
r
[
https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831421#comment-16831421
]
Rong Rong edited comment on FLINK-11909 at 5/2/19 5:40 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831421#comment-16831421
]
Rong Rong edited comment on FLINK-11909 at 5/2/19 5:39 AM:
---
I
[
https://issues.apache.org/jira/browse/FLINK-11909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831421#comment-16831421
]
Rong Rong commented on FLINK-11909:
---
I took some time to look at the {{AsyncFunction}}
bowenli86 merged pull request #8325: [hotfix] [table] Refactor
GenericInMemoryCatalogTest to prepare for moving common tests to CatalogTestBase
URL: https://github.com/apache/flink/pull/8325
This is an automated message from
[
https://issues.apache.org/jira/browse/FLINK-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang resolved FLINK-10758.
-
Resolution: Done
The actual work is captured in FLINK-11476. Thus, I close this in favor of
FLI
[
https://issues.apache.org/jira/browse/FLINK-10618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuefu Zhang resolved FLINK-10618.
-
Resolution: Done
This JIRA seems to be a hive-level proposal, while most of the actual work is
flinkbot edited a comment on issue #8324: [FLINK-11921][table] Upgrade to
calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-488032392
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull reques
walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-488551197
@flinkbot attention @twalthr
This is an automated message from the Apache
walterddr commented on issue #8324: [FLINK-11921][table] Upgrade to calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-488551100
@flinkbot attention @twalthr could you kindly take a look when you have time?
--
walterddr edited a comment on issue #8324: [FLINK-11921][table] Upgrade to
calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-488551100
@flinkbot attention @twalthr
This is an automated message from
walterddr removed a comment on issue #8324: [FLINK-11921][table] Upgrade to
calcite 1.19
URL: https://github.com/apache/flink/pull/8324#issuecomment-488551100
@flinkbot attention @twalthr
This is an automated message fro
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280287299
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apac
flinkbot edited a comment on issue #8330: [FLINK-12388][docs] Update the
production readiness checklist
URL: https://github.com/apache/flink/pull/8330#issuecomment-488536697
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review
sjwiesman commented on issue #8330: [FLINK-12388][docs] Update the production
readiness checklist
URL: https://github.com/apache/flink/pull/8330#issuecomment-488536823
@flinkbot attention @fhueske
This is an automated messag
flinkbot commented on issue #8330: [FLINK-12388][docs] Update the production
readiness checklist
URL: https://github.com/apache/flink/pull/8330#issuecomment-488536697
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your p
[
https://issues.apache.org/jira/browse/FLINK-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12388:
---
Labels: pull-request-available (was: )
> Update the production readiness checklist
> -
sjwiesman opened a new pull request #8330: [FLINK-12388][docs] Update the
production readiness checklist
URL: https://github.com/apache/flink/pull/8330
## What is the purpose of the change
The production readiness checklist has grown organically over the years, and
while it
[
https://issues.apache.org/jira/browse/FLINK-12388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Seth Wiesman updated FLINK-12388:
-
Summary: Update the production readiness checklist (was: Update the
production readyness check
Seth Wiesman created FLINK-12388:
Summary: Update the production readyness checklist
Key: FLINK-12388
URL: https://issues.apache.org/jira/browse/FLINK-12388
Project: Flink
Issue Type: Improv
Mukesh Jha created FLINK-12387:
--
Summary: Salesforce
Key: FLINK-12387
URL: https://issues.apache.org/jira/browse/FLINK-12387
Project: Flink
Issue Type: Test
Reporter: Mukesh Jha
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280238806
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apac
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280257423
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apac
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280257096
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apac
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280256225
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/fl
[
https://issues.apache.org/jira/browse/FLINK-11935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16831327#comment-16831327
]
Julian Hyde commented on FLINK-11935:
-
If the language you are implementing is SQL,
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280248865
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/t
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280248483
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280245883
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280245087
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280244614
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280242198
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280239908
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/
bowenli86 commented on a change in pull request #8329: [FLINK-12239][hive]
Support table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280238806
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apac
xuefuz commented on a change in pull request #8329: [FLINK-12239][hive] Support
table related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#discussion_r280236484
##
File path:
flink-connectors/flink-connector-hive/src/main/java/org/apache/
flinkbot commented on issue #8329: [FLINK-12239][hive] Support table related
operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329#issuecomment-488438750
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communi
[
https://issues.apache.org/jira/browse/FLINK-12239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12239:
---
Labels: pull-request-available (was: )
> Support table related operations in GenericHiveMet
bowenli86 opened a new pull request #8329: [FLINK-12239][hive] Support table
related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8329
## What is the purpose of the change
This PR enables GenericHiveMetastoreCatalog to operate Flink tables by us
Bowen Li created FLINK-12386:
Summary: Support complete mapping between Flink and Hive data types
Key: FLINK-12386
URL: https://issues.apache.org/jira/browse/FLINK-12386
Project: Flink
Issue Type
Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-488354670
I've spoken with @haf through email and it seems the low acknowledge rate is
related to the
xuefuz commented on issue #8314: [FLINK-12365][table] Add stats related catalog
APIs
URL: https://github.com/apache/flink/pull/8314#issuecomment-488351982
Thanks for the review, @bowenli86 ! I pushed another commit addressing above
review comments. Plus, I will create a followup JIRA to ad
bowenli86 commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r280134188
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/stats/CatalogCol
bowenli86 commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r280134823
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/stats/CatalogTab
bowenli86 commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r280133871
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/stats/CatalogCol
bowenli86 commented on a change in pull request #8314: [FLINK-12365][table] Add
stats related catalog APIs
URL: https://github.com/apache/flink/pull/8314#discussion_r280133941
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/stats/CatalogCol
Myasuka commented on issue #8328: [FLINK-12380] Add thread name in the
log4j.properties
URL: https://github.com/apache/flink/pull/8328#issuecomment-488324862
@link3280 This PR is inspired by FLINK-12368 when users want to add sub-task
index information in the source code. Actually, we coul
Matt Dailey created FLINK-12385:
---
Summary: RestClusterClient can hang indefinitely during job
submission
Key: FLINK-12385
URL: https://issues.apache.org/jira/browse/FLINK-12385
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-12384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12384:
---
Description:
{code:java}
[tm] 2019-05-01 13:30:53,316 INFO
org.apache.flink.shaded.zookeeper.org.apache.zo
Henrik created FLINK-12384:
--
Summary: Rolling the etcd servers causes "Connected to an old
server; r-o mode will be unavailable"
Key: FLINK-12384
URL: https://issues.apache.org/jira/browse/FLINK-12384
Projec
Henrik created FLINK-12383:
--
Summary: "Log file environment variable 'log.file' is not set"
despite web.log.path being set
Key: FLINK-12383
URL: https://issues.apache.org/jira/browse/FLINK-12383
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12382:
---
Description:
I'm testing zetcd + session jobs in k8s, and testing what happens when I kill
both the job-clu
[
https://issues.apache.org/jira/browse/FLINK-12382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12382:
---
Description:
I'm testing zetcd + session jobs in k8s, and testing what happens when I kill
both the job-clu
Henrik created FLINK-12382:
--
Summary: HA + ResourceManager exception: Fencing token not set
Key: FLINK-12382
URL: https://issues.apache.org/jira/browse/FLINK-12382
Project: Flink
Issue Type: Bug
haf commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-488239680
The checkpoints take e.g. `12528 ms` to write, but they are not large at all:
https://
Leev commented on a change in pull request #8300: [FLINK-11638][docs-zh]
Translate Savepoints page into Chinese
URL: https://github.com/apache/flink/pull/8300#discussion_r279326911
##
File path: docs/ops/state/savepoints.zh.md
##
@@ -25,32 +25,24 @@ under the License.
Xeli commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-488235510
Hi @haf
The connector will acknowledge messages on every successful checkpoint. How
[
https://issues.apache.org/jira/browse/FLINK-12380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12380:
---
Labels: pull-request-available (was: )
> Add thread name in the log4j.properties
>
flinkbot commented on issue #8328: [FLINK-12380] Add thread name in the
log4j.properties
URL: https://github.com/apache/flink/pull/8328#issuecomment-488234756
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull requ
Myasuka opened a new pull request #8328: [FLINK-12380] Add thread name in the
log4j.properties
URL: https://github.com/apache/flink/pull/8328
## What is the purpose of the change
This is inspired by FLINK-12368 when users want to add sub-task index
information in the source code. We
Myasuka commented on issue #8315: [FLINK-12368] add subtask index to
FlinkKafkaConsumerBase logging, wh…
URL: https://github.com/apache/flink/pull/8315#issuecomment-488234179
@stevenzwu I found existing `logback.xml` in Flink already contains `thread
name` information, and I create a jira
flinkbot commented on issue #8327: [FLINK-12333][docs] Add documentation for
all async operations through REST API
URL: https://github.com/apache/flink/pull/8327#issuecomment-488232864
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
[
https://issues.apache.org/jira/browse/FLINK-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12333:
---
Labels: pull-request-available (was: )
> Add documentation for all async operations through
Myasuka opened a new pull request #8327: [FLINK-12333][docs] Add documentation
for all async operations through REST API
URL: https://github.com/apache/flink/pull/8327
## What is the purpose of the change
Improve the description for all async-operations through REST API. `Tri
[
https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12381:
---
Description:
{code:java}
Caused by: org.apache.hadoop.fs.FileAlreadyExistsException:
'gs://example_bucket/f
[
https://issues.apache.org/jira/browse/FLINK-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Henrik updated FLINK-12381:
---
Summary: W/o HA, upon a full restart, checkpointing crashes (was: Without
failover (aka "HA") configured, f
Henrik created FLINK-12381:
--
Summary: Without failover (aka "HA") configured, full restarts'
checkpointing crashes
Key: FLINK-12381
URL: https://issues.apache.org/jira/browse/FLINK-12381
Project: Flink
Yun Tang created FLINK-12380:
Summary: Add thread name in the log4j.properties
Key: FLINK-12380
URL: https://issues.apache.org/jira/browse/FLINK-12380
Project: Flink
Issue Type: Improvement
haf commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source
connector with support for checkpointing (ATLEAST_ONCE)
URL: https://github.com/apache/flink/pull/6594#issuecomment-488227037
@xeli I'm getting pretty bad throughput from the source; about 20 messages
per second with a
75 matches
Mail list logo
