dianfu commented on a change in pull request #7328: [FLINK-11191][table] Check
for ambiguous columns in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7328#discussion_r242808717
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/da
hequn8128 commented on issue #7241: [FLINK-10780][tests] Update Java / Scala
StatefulJobWBroadcastStateMigrationITCase for 1.7
URL: https://github.com/apache/flink/pull/7241#issuecomment-448494562
The reason for the failure needs to be ascertained. Will update the PR later.
---
[
https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724737#comment-16724737
]
Nagarjun Guraja commented on FLINK-11127:
-
[~spoganshev] I am wondering, modifyi
jparkie commented on issue #6782: [FLINK-9083][Cassandra Connector] Add async
backpressure support to Cassandra Connector
URL: https://github.com/apache/flink/pull/6782#issuecomment-448493973
I removed the lock stuff and updated the docs.
---
Chirag Dewan created FLINK-11198:
Summary: Access to MetricGroup in an AggregateFunction(Non Rich)
Key: FLINK-11198
URL: https://issues.apache.org/jira/browse/FLINK-11198
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-11143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724729#comment-16724729
]
Qi commented on FLINK-11143:
Hi Alex,
I've just found another parameter which may affect jo
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_r242805462
##
File path:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/
Clark commented on a change in pull request #7258: [FLINK-11084]Throw a
hard exception to remind developers while there's no stream node between two
split transformation
URL: https://github.com/apache/flink/pull/7258#discussion_r242805202
##
File path:
flink-streaming-java/src
dianfu commented on a change in pull request #7237: [FLINK-7209] [table]
Support DataView in Tuple and Case Class as the ACC type of AggregateFunction
URL: https://github.com/apache/flink/pull/7237#discussion_r242781277
##
File path:
flink-libraries/flink-table/src/main/scala/org/a
Hequn Cheng created FLINK-11197:
---
Summary: Improve migration test comments about how to generate
snapshots
Key: FLINK-11197
URL: https://issues.apache.org/jira/browse/FLINK-11197
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724634#comment-16724634
]
Paul Lin commented on FLINK-11186:
--
[~tschamberger] For what it's worth, the event time
[
https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724620#comment-16724620
]
Yangze Guo commented on FLINK-11172:
Hi there, after reading the new IncrementalClea
[
https://issues.apache.org/jira/browse/FLINK-10473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724618#comment-16724618
]
Yangze Guo commented on FLINK-10473:
Hi, all. As the discussion in
[FLINK-11172|htt
[
https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9457:
---
Assignee: vinoyang
> Cancel container requests when cancelling pending slot allocations
> --
[
https://issues.apache.org/jira/browse/FLINK-11194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-11194:
Assignee: vinoyang
> missing Scala 2.12 build of HBase connector
> -
hequn8128 commented on issue #7240: [FLINK-10779][tests] Update Java / Scala
StatefulJobSavepointMigrationITCase for 1.7
URL: https://github.com/apache/flink/pull/7240#issuecomment-448437445
@zentol Hi, thanks a lot for the view. Have I missed anything? I followed
the comments in the ITTes
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16724576#comment-16724576
]
Ankur Goenka commented on FLINK-10672:
--
Is this fixed in 1.5.6?
> Task stuck while
Mark Cho created FLINK-11196:
Summary: Extend S3 EntropyInjector to use key replacement (instead
of key removal) when creating checkpoint metadata files
Key: FLINK-11196
URL: https://issues.apache.org/jira/browse/FLIN
[
https://issues.apache.org/jira/browse/FLINK-11196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11196:
---
Labels: pull-request-available (was: )
> Extend S3 EntropyInjector to use key replacement (
markcho opened a new pull request #7333: [FLINK-11196] Extend S3
EntropyInjector to use key replacement (instead of key removal) when creating
checkpoint metadata files.
URL: https://github.com/apache/flink/pull/7333
[FLINK-11196] Extend S3 EntropyInjector to use key replacement (instead o
Mark Cho created FLINK-11195:
Summary: Extend AbstractS3FileSystemFactory.createHadoopFileSystem
to accept URI and Hadoop Configuration
Key: FLINK-11195
URL: https://issues.apache.org/jira/browse/FLINK-11195
[
https://issues.apache.org/jira/browse/FLINK-11195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11195:
---
Labels: pull-request-available (was: )
> Extend AbstractS3FileSystemFactory.createHadoopFil
markcho opened a new pull request #7332: [FLINK-11195] Extend
AbstractS3FileSystemFactory.createHadoopFileSystem to accept URI and Hadoop
Configuration.
URL: https://github.com/apache/flink/pull/7332
[FLINK-11195] Extend AbstractS3FileSystemFactory.createHadoopFileSystem to
accept URI and
bowenli86 opened a new pull request #7331: [FLINK-10168] [Core/DataStream] Add
FileFilter to FileInputFormat and FileModTimeFilter which sets a read start
position for files by modification time
URL: https://github.com/apache/flink/pull/7331
## What is the purpose of the change
The
azagrebin commented on issue #7320: [FLINK-11171] Avoid concurrent usage of
StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#issuecomment-448294733
At the moment `TtlStateSnapshotTransformer` contains non-thread safe
`DataInputDeserializer`. `DataInputDeserializer.se
[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan weiwen updated FLINK-11193:
---
Summary: rockdb customize configuration Covered by jobmaster (was: rockdb
customize configuration C
twalthr commented on issue #7323: [hotfix][docs][sqlClient] add -u option for
sql-client.sh in sqlClient.md
URL: https://github.com/apache/flink/pull/7323#issuecomment-448279867
Yes, this was intentionally undocumented as indicated by `Experimental (for
testing only!)`. We had a discussion
dawidwys commented on a change in pull request #7249: [FLINK-11048] Ability to
programmatically execute streaming pipeline with savepoint restore
URL: https://github.com/apache/flink/pull/7249#discussion_r242605967
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/s
[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11193:
---
Labels: pull-request-available (was: )
> rockdb customize configuration Covered by jobmaste
zicfan opened a new pull request #7330: [FLINK-11193] [state] repair rocksDb
config Covered
URL: https://github.com/apache/flink/pull/7330
## What is the purpose of the change
rockdb customize configuration Covered by jobmaster, if flink-conf.yaml not
set state.backend.rocks
[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan weiwen updated FLINK-11193:
---
Description:
set state backends is rocksdb
set 'state.backend.rocksdb.timer-service.factory' by C
Zhenhao Li created FLINK-11194:
--
Summary: missing Scala 2.12 build of HBase connector
Key: FLINK-11194
URL: https://issues.apache.org/jira/browse/FLINK-11194
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan weiwen updated FLINK-11193:
---
Description:
set state backends is rocksdb
set 'state.backend.rocksdb.timer-service.factory' by C
[
https://issues.apache.org/jira/browse/FLINK-11193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fan weiwen updated FLINK-11193:
---
Description:
set state backends is rocksdb
set 'state.backend.rocksdb.timer-service.factory' by C
Fan weiwen created FLINK-11193:
--
Summary: rockdb customize configuration Covered jobmaster
Key: FLINK-11193
URL: https://issues.apache.org/jira/browse/FLINK-11193
Project: Flink
Issue Type: Bug
Fan weiwen created FLINK-11192:
--
Summary: rockdb customize configuration Covered jobmaster
Key: FLINK-11192
URL: https://issues.apache.org/jira/browse/FLINK-11192
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-10368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-10368:
-
Fix Version/s: (was: 1.5.6)
> 'Kerberized YARN on Docker test' unstable
> --
[
https://issues.apache.org/jira/browse/FLINK-10457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-10457.
Resolution: Fixed
Fixed in
master via: b078c8090203fe55215a7626968a40a985af25ce,
cf88590
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-10672:
-
Fix Version/s: (was: 1.5.6)
> Task stuck while writing output to flink
> ---
zentol commented on issue #7320: [FLINK-11171] Avoid concurrent usage of
StateSnapshotTransformer
URL: https://github.com/apache/flink/pull/7320#issuecomment-448264474
Can you provide an example for a `StateSnapshotTransformer` that is not
thread-safe in itself?
--
[
https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9457:
Fix Version/s: (was: 1.5.6)
> Cancel container requests when cancelling pending slot allocation
[
https://issues.apache.org/jira/browse/FLINK-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9360:
Fix Version/s: (was: 1.5.6)
> HA end-to-end nightly test takes more than 15 min in Travis CI
>
[
https://issues.apache.org/jira/browse/FLINK-9328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9328:
Fix Version/s: (was: 1.5.6)
> RocksDBStateBackend might use PlaceholderStreamStateHandle to res
[
https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-10435:
-
Fix Version/s: (was: 1.5.6)
> Client sporadically hangs after Ctrl + C
> ---
[
https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-11079:
-
Fix Version/s: (was: 1.5.6)
> Update LICENSE and NOTICE files for flnk-storm-examples
>
[
https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-10317:
-
Fix Version/s: (was: 1.5.6)
> Configure Metaspace size by default
>
[
https://issues.apache.org/jira/browse/FLINK-9719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9719:
Fix Version/s: (was: 1.5.6)
> Mesos should use hostname as default jobmanager.rpc.address
> ---
[
https://issues.apache.org/jira/browse/FLINK-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9680:
Fix Version/s: (was: 1.5.6)
> Reduce heartbeat timeout for E2E tests
>
[
https://issues.apache.org/jira/browse/FLINK-9630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9630:
Fix Version/s: (was: 1.5.6)
> Kafka09PartitionDiscoverer cause connection leak on
> TopicAutho
[
https://issues.apache.org/jira/browse/FLINK-7351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-7351:
Fix Version/s: (was: 1.5.6)
> test instability in JobClientActorRecoveryITCase#testJobClientRec
[
https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9525:
Fix Version/s: (was: 1.5.6)
> Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs m
[
https://issues.apache.org/jira/browse/FLINK-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9046:
Fix Version/s: (was: 1.5.6)
> Improve error messages when receiving unexpected messages.
>
[
https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8899:
Fix Version/s: (was: 1.5.6)
> Submitting YARN job with FLIP-6 may lead to
> ApplicationAttempt
[
https://issues.apache.org/jira/browse/FLINK-8822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8822:
Fix Version/s: (was: 1.5.6)
> RotateLogFile may not work well when sed version is below 4.2
> -
[
https://issues.apache.org/jira/browse/FLINK-8247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8247:
Fix Version/s: (was: 1.5.6)
> Support Hadoop-free variant of Flink on Mesos
> -
[
https://issues.apache.org/jira/browse/FLINK-8724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8724:
Fix Version/s: (was: 1.5.6)
> Add BroadcastState examples with predetermined state transitions
[
https://issues.apache.org/jira/browse/FLINK-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8410:
Fix Version/s: (was: 1.5.6)
> Kafka consumer's commitedOffsets gauge metric is prematurely set
[
https://issues.apache.org/jira/browse/FLINK-8722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8722:
Fix Version/s: (was: 1.5.6)
> Refactor BroadcastState examples.
> -
[
https://issues.apache.org/jira/browse/FLINK-8046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8046:
Fix Version/s: (was: 1.5.6)
> ContinuousFileMonitoringFunction wrongly ignores files with exact
tzulitai opened a new pull request #7329: [FLINK-11073] (part 1) Introduce
COMPATIBLE_WITH_RECONFIGURED_SERIALIZER option in
TypeSerializerSchemaCompatibility
URL: https://github.com/apache/flink/pull/7329
## What is the purpose of the change
This commit introduces a new option to t
[
https://issues.apache.org/jira/browse/FLINK-7582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-7582:
Fix Version/s: (was: 1.5.6)
> Rest client may buffer responses indefinitely under heavy laod
>
[
https://issues.apache.org/jira/browse/FLINK-11084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-11084:
-
Fix Version/s: (was: 1.5.6)
> Incorrect ouput after two consecutive split and select
> -
[
https://issues.apache.org/jira/browse/FLINK-9900?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9900:
Fix Version/s: (was: 1.5.6)
> Failed to testRestoreBehaviourWithFaultyStateHandles
> (org.apac
[
https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-10241:
-
Fix Version/s: (was: 1.5.6)
> Reduce performance/stability impact of latency metrics
> -
[
https://issues.apache.org/jira/browse/FLINK-9761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-9761:
Fix Version/s: (was: 1.5.6)
> Potential buffer leak in PartitionRequestClientHandler during job
[
https://issues.apache.org/jira/browse/FLINK-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8902:
Fix Version/s: (was: 1.5.6)
> Re-scaling job sporadically fails with KeeperException
>
[
https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8803:
Fix Version/s: (was: 1.5.6)
> Mini Cluster Shutdown with HA unstable, causing test failures
> -
[
https://issues.apache.org/jira/browse/FLINK-8418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated FLINK-8418:
Fix Version/s: (was: 1.5.6)
> Kafka08ITCase.testStartFromLatestOffsets() times out on Travis
>
[
https://issues.apache.org/jira/browse/FLINK-5758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-5758.
---
Resolution: Duplicate
> Port-range for the web interface via YARN
> -
Zhen-hao closed pull request #7301: [FLINK-11160][Kafka Connector]
URL: https://github.com/apache/flink/pull/7301
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (
Zhen-hao commented on issue #7301: [FLINK-11160][Kafka Connector]
URL: https://github.com/apache/flink/pull/7301#issuecomment-448254703
closing due to duplicated JIRA issue
This is an automated message from the Apache Git Serv
zentol commented on issue #3391: [FLINK-5758] [yarn] support port range for web
monitor
URL: https://github.com/apache/flink/pull/3391#issuecomment-448252805
Subsumed in #7263.
This is an automated message from the Apache Git
zentol closed pull request #3391: [FLINK-5758] [yarn] support port range for
web monitor
URL: https://github.com/apache/flink/pull/3391
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a
zentol closed pull request #7306: [hotfix][docs][udfs.md]fix the example of
user-defined function in udfs.md
URL: https://github.com/apache/flink/pull/7306
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of prove
zentol commented on issue #7323: [hotfix][docs][sqlClient] add -u option for
sql-client.sh in sqlClient.md
URL: https://github.com/apache/flink/pull/7323#issuecomment-448242497
@twalthr Was this intentionally left undocumented?
--
[
https://issues.apache.org/jira/browse/FLINK-11191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11191:
---
Labels: pull-request-available (was: )
> Exception in code generation when ambiguous column
dawidwys opened a new pull request #7328: [FLINK-11191][table] Check for
ambiguous columns in MATCH_RECOGNIZE
URL: https://github.com/apache/flink/pull/7328
## What is the purpose of the change
Added a validation that checks if no ambiguous columns are defined in
`MATCH_RECOGNIZE` c
zentol closed pull request #7326: [hotfix] [docs] Fix typos in documentation
URL: https://github.com/apache/flink/pull/7326
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull
zentol commented on issue #7240: [FLINK-10779][tests] Update Java / Scala
StatefulJobSavepointMigrationITCase for 1.7
URL: https://github.com/apache/flink/pull/7240#issuecomment-448241922
@hequn8128 Please describe how you have generated the snapshots.
-
[
https://issues.apache.org/jira/browse/FLINK-10786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10786.
Resolution: Fixed
Fix Version/s: 1.8.0
master: e954ae865fea57f90fc5b9529c15374b2eb0
Dawid Wysakowicz created FLINK-11191:
Summary: Exception in code generation when ambiguous columns in
MATCH_RECOGNIZE
Key: FLINK-11191
URL: https://issues.apache.org/jira/browse/FLINK-11191
Projec
[
https://issues.apache.org/jira/browse/FLINK-10787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10787.
Resolution: Fixed
Fix Version/s: 1.8.0
master: ab33429f948679b4729aa81439d5cfeb6dd6
klion26 commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r242554475
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/ma
zentol closed pull request #7236: [FLINK-10786] Update CEPMigrationTest for 1.7
URL: https://github.com/apache/flink/pull/7236
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign p
[
https://issues.apache.org/jira/browse/FLINK-10782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10782.
Resolution: Fixed
Fix Version/s: 1.8.0
master: d1e8dd976864581c86d112d4c64f2731f5a3
zentol closed pull request #7234: [FLINK-10787] Update
AbstractNonKeyedOperatorRestoreTestBase for 1.7
URL: https://github.com/apache/flink/pull/7234
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
zentol closed pull request #7233: [FLINK-10782] Update
AbstractKeyedOperatorRestoreTestBase for 1.7
URL: https://github.com/apache/flink/pull/7233
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
A
[
https://issues.apache.org/jira/browse/FLINK-10788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10788.
Resolution: Fixed
Fix Version/s: 1.8.0
master: aeabfc51e1a877c487f662e90fcce4528c42
klion26 commented on a change in pull request #6777: [FLINK-10461] [State
Backends, Checkpointing] Speed up download files when restore from DFS
URL: https://github.com/apache/flink/pull/6777#discussion_r242554475
##
File path:
flink-state-backends/flink-statebackend-rocksdb/src/ma
[
https://issues.apache.org/jira/browse/FLINK-10784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-10784.
Resolution: Fixed
Fix Version/s: 1.8.0
master: 4616c605965860228959f7bcf48177147773
zentol closed pull request #7231: [FLINK-10788] Update
ContinuousFileProcessingMigrationTest for 1.7
URL: https://github.com/apache/flink/pull/7231
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
zentol closed pull request #7230: [FLINK-10784] Update
FlinkKafkaConsumerBaseMigrationTest for 1.7
URL: https://github.com/apache/flink/pull/7230
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As
asicoe commented on issue #4725: [FLINK-7689] [Streaming Connectors] Added
metrics to JDBCOutputFormat in order to be able to m…
URL: https://github.com/apache/flink/pull/4725#issuecomment-448231858
@zentol @pabloem @fhueske I've addressed all the latest comments, simplified
the metrics (g
zentol commented on a change in pull request #7327: [FLINK-11180][tests] Fix
ProcessFailureCancelingITCase.testCancelingOnProcessFailure error by specifying
a free port
URL: https://github.com/apache/flink/pull/7327#discussion_r242546417
##
File path:
flink-tests/src/test/java/org
zentol commented on a change in pull request #7327: [FLINK-11180][tests] Fix
ProcessFailureCancelingITCase.testCancelingOnProcessFailure error by specifying
a free port
URL: https://github.com/apache/flink/pull/7327#discussion_r24254
##
File path:
flink-tests/src/test/java/org
zentol commented on a change in pull request #7327: [FLINK-11180][tests] Fix
ProcessFailureCancelingITCase.testCancelingOnProcessFailure error by specifying
a free port
URL: https://github.com/apache/flink/pull/7327#discussion_r242547140
##
File path:
flink-tests/src/test/java/org
asicoe commented on a change in pull request #4725: [FLINK-7689] [Streaming
Connectors] Added metrics to JDBCOutputFormat in order to be able to m…
URL: https://github.com/apache/flink/pull/4725#discussion_r242546922
##
File path:
flink-connectors/flink-jdbc/src/main/java/org/apach
[
https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-11171:
-
Affects Version/s: 1.6.2
> Unexpected timestamp deserialization failure in RocksDB state
[
https://issues.apache.org/jira/browse/FLINK-11180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-11180:
---
Labels: pull-request-available (was: )
> ProcessFailureCancelingITCase#testCancelingOnProce
hequn8128 opened a new pull request #7327: [FLINK-11180][tests]
[FLINK-11180][tests] Fix
ProcessFailureCancelingITCase.testCancelingOnProcessFailure error by specifying
a free port
URL: https://github.com/apache/flink/pull/7327
## What is the purpose of the change
This pull req
1 - 100 of 162 matches
Mail list logo
