Xeli commented on a change in pull request #8259: [FLINK-12325][metrics] Fix
bug in statsd exporter when using negative values
URL: https://github.com/apache/flink/pull/8259#discussion_r280971043
##
File path:
flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metric
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969654
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -25,17 +25,16
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969652
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -25,17 +25,16
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969750
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -48,62 +47,52
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969597
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -25,17 +25,16
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969785
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -48,62 +47,52
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969736
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -48,62 +47,52
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969780
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -48,62 +47,52
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969642
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -25,17 +25,16
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969812
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -48,62 +47,52
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969840
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -48,62 +47,52
klion26 commented on a change in pull request #8319: [FLINK-11636] [docs-zh]
Translate "State Schema Evolution" into Chinese
URL: https://github.com/apache/flink/pull/8319#discussion_r280969524
##
File path: docs/dev/stream/state/schema_evolution.zh.md
##
@@ -25,17 +25,16
bowenli86 commented on a change in pull request #8337: [FLINK-12232][hive]
Create HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969694
##
File path:
flink-connectors/flink-connector-hive/src/main/jav
bowenli86 commented on a change in pull request #8337: [FLINK-12232][hive]
Create HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969694
##
File path:
flink-connectors/flink-connector-hive/src/main/jav
flinkbot commented on issue #8340: [FLINK-12395][table] Add more detailed
javadoc for getDescription() and getDetailedDescription() in catalog object
interfaces
URL: https://github.com/apache/flink/pull/8340#issuecomment-489295083
Thanks a lot for your contribution to the Apache Flink proj
bowenli86 commented on issue #8340: [FLINK-12395][table] Add more detailed
javadoc for getDescription() and getDetailedDescription() in catalog object
interfaces
URL: https://github.com/apache/flink/pull/8340#issuecomment-489295088
cc @xuefuz
-
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12395:
---
Labels: pull-request-available (was: )
> Add more detailed javadoc for getDescription() and
bowenli86 opened a new pull request #8340: [FLINK-12395][table] Add more
detailed javadoc for getDescription() and getDetailedDescription() in catalog
object interfaces
URL: https://github.com/apache/flink/pull/8340
## What is the purpose of the change
This PR adds more detailed jav
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12395:
-
Summary: Add more detailed javadoc for getDescription() and
getDetailedDescription() in catalog object i
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12395:
-
Summary: Document description and detailed description in catalog object
interfaces (was: Document desc
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li reassigned FLINK-12395:
Assignee: Bowen Li
> Document description and detailed description in catalog object interfaces
>
xuefuz commented on a change in pull request #8337: [FLINK-12232][hive] Create
HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969214
##
File path:
flink-connectors/flink-connector-hive/src/main/java/o
xuefuz commented on a change in pull request #8337: [FLINK-12232][hive] Create
HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969532
##
File path:
flink-connectors/flink-connector-hive/src/main/java/o
xuefuz commented on a change in pull request #8337: [FLINK-12232][hive] Create
HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969550
##
File path:
flink-connectors/flink-connector-hive/src/main/java/o
xuefuz commented on a change in pull request #8337: [FLINK-12232][hive] Create
HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280968990
##
File path:
flink-connectors/flink-connector-hive/src/main/java/o
xuefuz commented on a change in pull request #8337: [FLINK-12232][hive] Create
HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969275
##
File path:
flink-connectors/flink-connector-hive/src/main/java/o
xuefuz commented on a change in pull request #8337: [FLINK-12232][hive] Create
HiveCatalog and support database related operations in HiveCatalog
URL: https://github.com/apache/flink/pull/8337#discussion_r280969459
##
File path:
flink-connectors/flink-connector-hive/src/main/java/o
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832986#comment-16832986
]
Bowen Li edited comment on FLINK-12395 at 5/4/19 5:05 AM:
--
Agre
[
https://issues.apache.org/jira/browse/FLINK-11637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832987#comment-16832987
]
Congxian Qiu(klion26) commented on FLINK-11637:
---
[~lsy] I'm not working on
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12395:
-
Description: We need to add more javadoc for {{getDescritpion()}} and
{{getDetailedDescription()}} APIs
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16832986#comment-16832986
]
Bowen Li commented on FLINK-12395:
--
Agree to improve the javadoc, as I've also been con
[
https://issues.apache.org/jira/browse/FLINK-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li updated FLINK-12395:
-
Summary: Document description and detailed description in CatalogBaseTable
(was: Reconcile description
[
https://issues.apache.org/jira/browse/FLINK-12240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-12240:
---
Labels: pull-request-available (was: )
> Support view related operations in GenericHiveMeta
flinkbot commented on issue #8339: [FLINK-12240][hive] Support view related
operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339#issuecomment-489287613
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the communit
bowenli86 opened a new pull request #8339: [FLINK-12240][hive] Support view
related operations in GenericHiveMetastoreCatalog
URL: https://github.com/apache/flink/pull/8339
## What is the purpose of the change
This PR added support for views in GenericHiveMetastoreCatalog, operations
flinkbot commented on issue #8338: [BP-1.6][FLINK-12296][StateBackend] Fix
local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8338#issuecomment-489284633
Thanks a lot for your contribution to the Apache Flink project. I'm th
klion26 opened a new pull request #8338: [BP-1.6][FLINK-12296][StateBackend]
Fix local state directory collision with state loss for chained keyed operators
URL: https://github.com/apache/flink/pull/8338
## What is the purpose of the change
cherry-pick #8263 to release-1.6 manually.
Josh Bradt created FLINK-12399:
--
Summary: FilterableTableSource does not use filters on job run
Key: FLINK-12399
URL: https://issues.apache.org/jira/browse/FLINK-12399
Project: Flink
Issue Type:
Bowen Li created FLINK-12398:
Summary: Support partitioned view in catalog API
Key: FLINK-12398
URL: https://issues.apache.org/jira/browse/FLINK-12398
Project: Flink
Issue Type: Sub-task
Chesnay Schepler created FLINK-12397:
Summary: Drop flink-shaded-asm-5
Key: FLINK-12397
URL: https://issues.apache.org/jira/browse/FLINK-12397
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-12390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-12390.
Resolution: Fixed
master: 9975e0393a9e09dbde21ca61f1a5751cc5934411
> Fully migrate to asm
Bowen Li created FLINK-12396:
Summary: KafkaITCase.testOneSourceMultiplePartitions doesn't fail
properly
Key: FLINK-12396
URL: https://issues.apache.org/jira/browse/FLINK-12396
Project: Flink
Is
zentol merged pull request #8332: [FLINK-12390][build] Fully migrate to
flink-shaded-asm-6
URL: https://github.com/apache/flink/pull/8332
This is an automated message from the Apache Git Service.
To respond to the message, p
bowenli86 commented on issue #8214: [FLINK-11476] [table] Create CatalogManager
to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#issuecomment-489180854
Thanks @dawidwys for the feedback! Let's sync up on Monday offline as planned
---
bowenli86 commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r280866583
##
File path:
flink-table/flink-table-planner-blink/src
bowenli86 commented on a change in pull request #8214: [FLINK-11476] [table]
Create CatalogManager to manage multiple catalogs and encapsulate Calcite schema
URL: https://github.com/apache/flink/pull/8214#discussion_r280858643
##
File path:
flink-table/flink-table-planner-blink/src
GJL commented on issue #8332: [FLINK-12390][build] Fully migrate to
flink-shaded-asm-6
URL: https://github.com/apache/flink/pull/8332#issuecomment-489154787
@flinkbot approve all
This is an automated message from the Apache G
sjwiesman commented on a change in pull request #8326: [FLINK-12378][docs]
Consolidate FileSystem Documentation
URL: https://github.com/apache/flink/pull/8326#discussion_r280830610
##
File path: docs/ops/deployment/aws.md
##
@@ -64,81 +64,11 @@ HADOOP_CONF_DIR=/etc/hadoop/
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-489140860
Ok I think I didn't catch the issue as I was using mvn 3.5 and it seems that
the shade plugin behaves a bit differently on it. W
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280777174
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280761093
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280771723
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280769132
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280761548
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280713033
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280786571
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280787008
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280713503
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280795534
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280766308
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280769682
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280777174
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280762347
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSc
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280762928
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/strategy/TestingSc
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280761093
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280703833
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280777824
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
twalthr commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280798765
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink
GJL commented on a change in pull request #8309: [FLINK-12229] [runtime]
Implement LazyFromSourcesScheduling Strategy
URL: https://github.com/apache/flink/pull/8309#discussion_r280775926
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromS
sjwiesman commented on issue #8330: [FLINK-12388][docs] Update the production
readiness checklist
URL: https://github.com/apache/flink/pull/8330#issuecomment-489107895
Thanks for the review, I've updated the JobManager section to be more clear
and also fixed a few other grammar issues I no
StephanEwen edited a comment on issue #8280: [FLINK-12297]Harden ClosureCleaner
to handle the wrapped function
URL: https://github.com/apache/flink/pull/8280#issuecomment-489105632
This PR does a few things at the same time:
1. It recurses into fields, cleaning them.
2. It skips c
StephanEwen commented on issue #8280: [FLINK-12297]Harden ClosureCleaner to
handle the wrapped function
URL: https://github.com/apache/flink/pull/8280#issuecomment-489105632
This PR does a few things at the same time:
1. It recurses into fields, cleaning them.
2. It skips closure
StephanEwen commented on a change in pull request #8282: [FLINK-12338] Update
Apache Avro test to use try-with-resources
URL: https://github.com/apache/flink/pull/8282#discussion_r280777846
##
File path:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroOutpu
StephanEwen commented on a change in pull request #8282: [FLINK-12338] Update
Apache Avro test to use try-with-resources
URL: https://github.com/apache/flink/pull/8282#discussion_r280776846
##
File path:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/AvroKryoS
StephanEwen commented on a change in pull request #8282: [FLINK-12338] Update
Apache Avro test to use try-with-resources
URL: https://github.com/apache/flink/pull/8282#discussion_r280778538
##
File path:
flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/EncoderDe
pnowojski commented on a change in pull request #7688: [FLINK-9816][network]
add option to configure SSL engine provider for TM communication
URL: https://github.com/apache/flink/pull/7688#discussion_r280773729
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/net/
pnowojski commented on a change in pull request #7688: [FLINK-9816][network]
add option to configure SSL engine provider for TM communication
URL: https://github.com/apache/flink/pull/7688#discussion_r280771834
##
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/util/Mes
pnowojski commented on a change in pull request #7688: [FLINK-9816][network]
add option to configure SSL engine provider for TM communication
URL: https://github.com/apache/flink/pull/7688#discussion_r280771141
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/net/
pnowojski commented on a change in pull request #7688: [FLINK-9816][network]
add option to configure SSL engine provider for TM communication
URL: https://github.com/apache/flink/pull/7688#discussion_r280772939
##
File path:
flink-core/src/main/java/org/apache/flink/configuration/S
pnowojski commented on a change in pull request #7688: [FLINK-9816][network]
add option to configure SSL engine provider for TM communication
URL: https://github.com/apache/flink/pull/7688#discussion_r280775627
##
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/net/
piyushnarang commented on issue #8117: [FLINK-12115] [filesystems]: Add support
for AzureFS
URL: https://github.com/apache/flink/pull/8117#issuecomment-489094928
Yeah let me check. I kicked off a `mvn clean install -DskipTests` on my
machine before submitting and that seems to have gone th
flinkbot edited a comment on issue #8285: FLINK- Fix typo in "Window Operator"
documentation
URL: https://github.com/apache/flink/pull/8285#issuecomment-487081426
Thanks a lot for your contribution to the Apache Flink project. I'm the
@flinkbot. I help the community
to review your pull
StephanEwen commented on issue #8285: FLINK- Fix typo in "Window Operator"
documentation
URL: https://github.com/apache/flink/pull/8285#issuecomment-489093278
@flinkbot approve all
This is an automated message from the Apache
StephanEwen commented on issue #8285: FLINK- Fix typo in "Window Operator"
documentation
URL: https://github.com/apache/flink/pull/8285#issuecomment-489093241
Thanks for the patch.
Merging this...
This is an automated
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280736591
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280742847
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280737135
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280764585
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280744074
##
File path:
flink-table/flink-table-common/src/test/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280733755
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280738815
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280755454
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280762367
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280761541
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
dawidwys commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280738605
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flin
zentol commented on issue #8316: [FLINK-12369] [coordination] Implement a
region failover strategy regarding the next version FailoverStrategy interfaces
URL: https://github.com/apache/flink/pull/8316#issuecomment-489086627
We should also add some tests for the `Execution*` classes to ensur
twalthr commented on a change in pull request #8335:
[FLINK-12253][table-common] Setup a class hierarchy for the new logical type
system
URL: https://github.com/apache/flink/pull/8335#discussion_r280763754
##
File path:
flink-table/flink-table-common/src/main/java/org/apache/flink
zentol commented on a change in pull request #8316: [FLINK-12369]
[coordination] Implement a region failover strategy regarding the next version
FailoverStrategy interfaces
URL: https://github.com/apache/flink/pull/8316#discussion_r280747402
##
File path:
flink-runtime/src/test/ja
zentol commented on a change in pull request #8316: [FLINK-12369]
[coordination] Implement a region failover strategy regarding the next version
FailoverStrategy interfaces
URL: https://github.com/apache/flink/pull/8316#discussion_r280752971
##
File path:
flink-runtime/src/main/ja
zentol commented on a change in pull request #8316: [FLINK-12369]
[coordination] Implement a region failover strategy regarding the next version
FailoverStrategy interfaces
URL: https://github.com/apache/flink/pull/8316#discussion_r280758391
##
File path:
flink-runtime/src/main/ja
1 - 100 of 146 matches
Mail list logo