vinoyang created FLINK-15939:
Summary: Move runtime.clusterframework.overlays package into
flink-mesos module
Key: FLINK-15939
URL: https://issues.apache.org/jira/browse/FLINK-15939
Project: Flink
vinoyang created FLINK-15810:
Summary: Add more description for
FlinkKafkaProducerMigrationOperatorTest
Key: FLINK-15810
URL: https://issues.apache.org/jira/browse/FLINK-15810
Project: Flink
vinoyang created FLINK-15725:
Summary: Update FlinkKinesisConsumerMigrationTest to restore from
1.10 savepoint
Key: FLINK-15725
URL: https://issues.apache.org/jira/browse/FLINK-15725
Project: Flink
vinoyang created FLINK-15724:
Summary: Update AbstractNonKeyedOperatorRestoreTestBase to restore
from 1.10 savepoint
Key: FLINK-15724
URL: https://issues.apache.org/jira/browse/FLINK-15724
Project: Flink
vinoyang created FLINK-15722:
Summary: Update TypeSerializerSnapshotMigrationITCase to restore
from 1.10 savepoint
Key: FLINK-15722
URL: https://issues.apache.org/jira/browse/FLINK-15722
Project: Flink
vinoyang created FLINK-15723:
Summary: Update AbstractKeyedOperatorRestoreTestBase to restore
from 1.10 savepoint
Key: FLINK-15723
URL: https://issues.apache.org/jira/browse/FLINK-15723
Project: Flink
vinoyang created FLINK-15721:
Summary: Update StatefulJobWBroadcastStateMigrationITCase to
restore from 1.10 savepoint
Key: FLINK-15721
URL: https://issues.apache.org/jira/browse/FLINK-15721
Project:
vinoyang created FLINK-15720:
Summary: Update StatefulJobWBroadcastStateMigrationITCase.scala to
restore from 1.10 savepoint
Key: FLINK-15720
URL: https://issues.apache.org/jira/browse/FLINK-15720
vinoyang created FLINK-15718:
Summary: Update StatefulJobSavepointMigrationITCase to restore
from 1.10 savepoint
Key: FLINK-15718
URL: https://issues.apache.org/jira/browse/FLINK-15718
Project: Flink
vinoyang created FLINK-15716:
Summary: Update WindowOperatorMigrationTest to restore from 1.10
savepoint
Key: FLINK-15716
URL: https://issues.apache.org/jira/browse/FLINK-15716
Project: Flink
vinoyang created FLINK-15717:
Summary: Update StatefulJobSavepointMigrationITCase.scala to
restore from 1.10 savepoint
Key: FLINK-15717
URL: https://issues.apache.org/jira/browse/FLINK-15717
Project:
vinoyang created FLINK-15715:
Summary: Update ContinuousFileProcessingMigrationTest to restore
from 1.10 savepoint
Key: FLINK-15715
URL: https://issues.apache.org/jira/browse/FLINK-15715
Project: Flink
vinoyang created FLINK-15714:
Summary: Update FlinkKafkaProducerMigrationTest to restore from
1.10 savepoint
Key: FLINK-15714
URL: https://issues.apache.org/jira/browse/FLINK-15714
Project: Flink
vinoyang created FLINK-15713:
Summary: Update FlinkKafkaProducerMigrationOperatorTest to restore
from 1.10 savepoint
Key: FLINK-15713
URL: https://issues.apache.org/jira/browse/FLINK-15713
Project: Flink
vinoyang created FLINK-15712:
Summary: Update FlinkKafkaConsumerBaseMigrationTest to restore
from 1.10 savepoint
Key: FLINK-15712
URL: https://issues.apache.org/jira/browse/FLINK-15712
Project: Flink
vinoyang created FLINK-15711:
Summary: Update FlinkKafkaProducer011MigrationTest to restore from
1.10 savepoint
Key: FLINK-15711
URL: https://issues.apache.org/jira/browse/FLINK-15711
Project: Flink
vinoyang created FLINK-15710:
Summary: Update BucketingSinkMigrationTest to restore from 1.10
savepoint
Key: FLINK-15710
URL: https://issues.apache.org/jira/browse/FLINK-15710
Project: Flink
vinoyang created FLINK-15709:
Summary: Update CEPMigrationTest to restore from 1.10 savepoint
Key: FLINK-15709
URL: https://issues.apache.org/jira/browse/FLINK-15709
Project: Flink
Issue Type:
vinoyang created FLINK-15708:
Summary: Add MigrationVersion.v1_10
Key: FLINK-15708
URL: https://issues.apache.org/jira/browse/FLINK-15708
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-15707:
Summary: Update state migration tests for Flink 1.10
Key: FLINK-15707
URL: https://issues.apache.org/jira/browse/FLINK-15707
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-15681:
Summary: Remove legacy ExecutionAndAllocationFuture class
Key: FLINK-15681
URL: https://issues.apache.org/jira/browse/FLINK-15681
Project: Flink
Issue Type: Wish
vinoyang created FLINK-15618:
Summary: Remove useless JobTimeoutException
Key: FLINK-15618
URL: https://issues.apache.org/jira/browse/FLINK-15618
Project: Flink
Issue Type: Wish
vinoyang created FLINK-15617:
Summary: Remove useless JobRetrievalException
Key: FLINK-15617
URL: https://issues.apache.org/jira/browse/FLINK-15617
Project: Flink
Issue Type: Wish
vinoyang created FLINK-15601:
Summary: Remove useless constant field NUM_STOP_CALL_TRIES in
Execution
Key: FLINK-15601
URL: https://issues.apache.org/jira/browse/FLINK-15601
Project: Flink
vinoyang created FLINK-15558:
Summary: Bump Elasticsearch version from 7.3.2 to 7.5.1 for es7
connector
Key: FLINK-15558
URL: https://issues.apache.org/jira/browse/FLINK-15558
Project: Flink
vinoyang created FLINK-15535:
Summary: Add usage of ProcessFunctionTestHarnesses for testing
documentation
Key: FLINK-15535
URL: https://issues.apache.org/jira/browse/FLINK-15535
Project: Flink
vinoyang created FLINK-15514:
Summary: Bump ES6 connector version from 6.3.1 to 6.8.6
Key: FLINK-15514
URL: https://issues.apache.org/jira/browse/FLINK-15514
Project: Flink
Issue Type: Wish
vinoyang created FLINK-15501:
Summary: Remove the wrong doc of
ExecutionVertexSchedulingRequirements#getExecutionVertexId
Key: FLINK-15501
URL: https://issues.apache.org/jira/browse/FLINK-15501
Project:
vinoyang created FLINK-15362:
Summary: Bump Kafka client version to 2.4.0 for universal Kafka
connector
Key: FLINK-15362
URL: https://issues.apache.org/jira/browse/FLINK-15362
Project: Flink
vinoyang created FLINK-14838:
Summary: Cleanup the description about container number config
option in Scala and python shell doc
Key: FLINK-14838
URL: https://issues.apache.org/jira/browse/FLINK-14838
vinoyang created FLINK-14767:
Summary: Remove TaskManagerOptions#EXIT_ON_FATAL_AKKA_ERROR
Key: FLINK-14767
URL: https://issues.apache.org/jira/browse/FLINK-14767
Project: Flink
Issue Type:
vinoyang created FLINK-14765:
Summary: Remove STATE_UPDATER in Execution
Key: FLINK-14765
URL: https://issues.apache.org/jira/browse/FLINK-14765
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-14720:
Summary: Bring down ExecutionVertex#deployToSlot access modifier
and mark it with @VisibleForTesting annotation
Key: FLINK-14720
URL: https://issues.apache.org/jira/browse/FLINK-14720
vinoyang created FLINK-14655:
Summary: Change Type of Field jobStatusListeners from
CopyOnWriteArrayList to ArrayList
Key: FLINK-14655
URL: https://issues.apache.org/jira/browse/FLINK-14655
Project:
vinoyang created FLINK-14640:
Summary: Change Type of Field currentExecutions from
ConcurrentHashMap to HashMap
Key: FLINK-14640
URL: https://issues.apache.org/jira/browse/FLINK-14640
Project: Flink
vinoyang created FLINK-14612:
Summary: Degenerate the current ConcurrentHashMap type of
intermediateResults to a normal HashMap type.
Key: FLINK-14612
URL: https://issues.apache.org/jira/browse/FLINK-14612
vinoyang created FLINK-14602:
Summary: Degenerate the current ConcurrentHashMap type of tasks to
a normal Hashmap type.
Key: FLINK-14602
URL: https://issues.apache.org/jira/browse/FLINK-14602
Project:
vinoyang created FLINK-14600:
Summary: Degenerate the current AtomicInteger type of
verticesFinished to a normal int type.
Key: FLINK-14600
URL: https://issues.apache.org/jira/browse/FLINK-14600
Project:
vinoyang created FLINK-14583:
Summary: Remove progressLock from ExecutionGraph
Key: FLINK-14583
URL: https://issues.apache.org/jira/browse/FLINK-14583
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-14570:
Summary: KeyedStateBootstrapFunction missed onTimer callback
method to fire timer
Key: FLINK-14570
URL: https://issues.apache.org/jira/browse/FLINK-14570
Project: Flink
vinoyang created FLINK-14554:
Summary: Correct the comment of ExistingSavepoint#readKeyedState
to generate java doc
Key: FLINK-14554
URL: https://issues.apache.org/jira/browse/FLINK-14554
Project: Flink
vinoyang created FLINK-14447:
Summary: Network metrics doc table render confusion
Key: FLINK-14447
URL: https://issues.apache.org/jira/browse/FLINK-14447
Project: Flink
Issue Type: Bug
vinoyang created FLINK-14428:
Summary: Non-consistency key access in KeyedProcessFunction when
use keyed state in both processElement and onTimer method
Key: FLINK-14428
URL:
vinoyang created FLINK-14402:
Summary:
KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator:214->KafkaProducerTestBase.testOneToOneAtLeastOnce
failed on Travis
Key: FLINK-14402
vinoyang created FLINK-14395:
Summary: Refactor ES 6 connector to split table-specific code into
flink-sql-connector-elasticsearch6
Key: FLINK-14395
URL: https://issues.apache.org/jira/browse/FLINK-14395
vinoyang created FLINK-13965:
Summary: Keep hasDeprecatedKeys in ConfigOption and mark it with
@Deprecated annotation
Key: FLINK-13965
URL: https://issues.apache.org/jira/browse/FLINK-13965
Project:
vinoyang created FLINK-13939:
Summary: pyflink ExecutionConfigTests#test_equals_and_hash test
failed
Key: FLINK-13939
URL: https://issues.apache.org/jira/browse/FLINK-13939
Project: Flink
Issue
vinoyang created FLINK-13694:
Summary: Refactor Flink on YARN configuration with relavent
overlay classes
Key: FLINK-13694
URL: https://issues.apache.org/jira/browse/FLINK-13694
Project: Flink
vinoyang created FLINK-13416:
Summary: Refactor documentation of CLI option for yarn cluster mode
Key: FLINK-13416
URL: https://issues.apache.org/jira/browse/FLINK-13416
Project: Flink
Issue
vinoyang created FLINK-13240:
Summary: Wrong check argument error message in the constructor of
QueryableStateConfiguration
Key: FLINK-13240
URL: https://issues.apache.org/jira/browse/FLINK-13240
vinoyang created FLINK-13186:
Summary: Remove dispatcherRetrievalService and
dispatcherLeaderRetriever from RestClusterClient
Key: FLINK-13186
URL: https://issues.apache.org/jira/browse/FLINK-13186
vinoyang created FLINK-13158:
Summary: Remove WebMonitor interface from webmonitor package
Key: FLINK-13158
URL: https://issues.apache.org/jira/browse/FLINK-13158
Project: Flink
Issue Type:
vinoyang created FLINK-13146:
Summary: GET request of: org/apache/avro/avro/1.8.2/avro-1.8.2.jar
from google-maven-central failed
Key: FLINK-13146
URL: https://issues.apache.org/jira/browse/FLINK-13146
vinoyang created FLINK-13143:
Summary: Clear CheckpointExceptionHandler relevant classes
Key: FLINK-13143
URL: https://issues.apache.org/jira/browse/FLINK-13143
Project: Flink
Issue Type:
vinoyang created FLINK-13136:
Summary: Fix documentation error about stop job with restful api
Key: FLINK-13136
URL: https://issues.apache.org/jira/browse/FLINK-13136
Project: Flink
Issue Type:
vinoyang created FLINK-13079:
Summary: Make window state queryable
Key: FLINK-13079
URL: https://issues.apache.org/jira/browse/FLINK-13079
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-13050:
Summary: Counting more checkpoint failure reason in
CheckpointFailureManager
Key: FLINK-13050
URL: https://issues.apache.org/jira/browse/FLINK-13050
Project: Flink
vinoyang created FLINK-12976:
Summary: Bump Kafka client version to 2.3.0 for universal Kafka
connector
Key: FLINK-12976
URL: https://issues.apache.org/jira/browse/FLINK-12976
Project: Flink
vinoyang created FLINK-12811:
Summary: flink-table-planner-blink compile error
Key: FLINK-12811
URL: https://issues.apache.org/jira/browse/FLINK-12811
Project: Flink
Issue Type: Bug
vinoyang created FLINK-12793:
Summary: Add localKeyBy API to DataStream
Key: FLINK-12793
URL: https://issues.apache.org/jira/browse/FLINK-12793
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-12792:
Summary: Support states mergence for local aggregation
Key: FLINK-12792
URL: https://issues.apache.org/jira/browse/FLINK-12792
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-12791:
Summary: Introduce LocalKeyedStateHandle interface and implement
LocalKeyedKeyGroupsStateHandle / LocalKeyedIncrementalKeyedStateHandle
Key: FLINK-12791
URL:
vinoyang created FLINK-12790:
Summary: Implement KeyScope enum to distinguish LocalKeyBy and
general keyBy
Key: FLINK-12790
URL: https://issues.apache.org/jira/browse/FLINK-12790
Project: Flink
vinoyang created FLINK-12786:
Summary: Implement local aggregation in Flink
Key: FLINK-12786
URL: https://issues.apache.org/jira/browse/FLINK-12786
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-12683:
Summary: Provide task manager's location information for
checkpoint acknowledge message to improve the checkpoint log message
Key: FLINK-12683
URL:
vinoyang created FLINK-12542:
Summary: Kafka011ITCase#testAutoOffsetRetrievalAndCommitToKafka
test failed
Key: FLINK-12542
URL: https://issues.apache.org/jira/browse/FLINK-12542
Project: Flink
vinoyang created FLINK-12540:
Summary:
Kafka011ProducerExactlyOnceITCase#testExactlyOnceCustomOperator
Key: FLINK-12540
URL: https://issues.apache.org/jira/browse/FLINK-12540
Project: Flink
vinoyang created FLINK-12528:
Summary: Remove progressLock in ExecutionGraph
Key: FLINK-12528
URL: https://issues.apache.org/jira/browse/FLINK-12528
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-12527:
Summary: Remove GLOBAL_VERSION_UPDATER in ExecutionGraph
Key: FLINK-12527
URL: https://issues.apache.org/jira/browse/FLINK-12527
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-12526:
Summary: Remove STATE_UPDATER in ExecutionGraph
Key: FLINK-12526
URL: https://issues.apache.org/jira/browse/FLINK-12526
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-12514:
Summary: Refactor the failure checkpoint counting mechanism with
ordered checkpoint id
Key: FLINK-12514
URL: https://issues.apache.org/jira/browse/FLINK-12514
Project: Flink
vinoyang created FLINK-12512:
Summary: TableSourceTest#testNestedProject test failed
Key: FLINK-12512
URL: https://issues.apache.org/jira/browse/FLINK-12512
Project: Flink
Issue Type:
vinoyang created FLINK-12364:
Summary: Introduce a CheckpointFailureManager to centralized
manage checkpoint failure
Key: FLINK-12364
URL: https://issues.apache.org/jira/browse/FLINK-12364
Project: Flink
vinoyang created FLINK-12363:
Summary: Refactor legacy rest handlers
Key: FLINK-12363
URL: https://issues.apache.org/jira/browse/FLINK-12363
Project: Flink
Issue Type: Task
vinoyang created FLINK-12362:
Summary: Add container number config option for Flink on yarn job
cluster mode
Key: FLINK-12362
URL: https://issues.apache.org/jira/browse/FLINK-12362
Project: Flink
vinoyang created FLINK-12244:
Summary: SynchronousCheckpointITCase hang up
Key: FLINK-12244
URL: https://issues.apache.org/jira/browse/FLINK-12244
Project: Flink
Issue Type: Test
vinoyang created FLINK-12209:
Summary: Refactor failure handling with CheckpointFailureManager
Key: FLINK-12209
URL: https://issues.apache.org/jira/browse/FLINK-12209
Project: Flink
Issue Type:
vinoyang created FLINK-12196:
Summary: FlinkKafkaProducerITCase#testRunOutOfProducersInThePool
throws NPE
Key: FLINK-12196
URL: https://issues.apache.org/jira/browse/FLINK-12196
Project: Flink
vinoyang created FLINK-12190:
Summary: Fix NPE throwed by
FlinkKinesisConsumerMigrationTest#writeSnapshot
Key: FLINK-12190
URL: https://issues.apache.org/jira/browse/FLINK-12190
Project: Flink
vinoyang created FLINK-12152:
Summary: Make the vcore that Application Master used configurable
for Flink on YARN
Key: FLINK-12152
URL: https://issues.apache.org/jira/browse/FLINK-12152
Project: Flink
vinoyang created FLINK-12025:
Summary: Support FOR SYSTEM_TIME AS OF in temporal table
Key: FLINK-12025
URL: https://issues.apache.org/jira/browse/FLINK-12025
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-12008:
Summary: Support read a whole directory or multiple input data
files for read apis of HadoopInputs
Key: FLINK-12008
URL: https://issues.apache.org/jira/browse/FLINK-12008
vinoyang created FLINK-12003:
Summary: Revert the config option about mapreduce.output.basename
in HadoopOutputFormatBase
Key: FLINK-12003
URL: https://issues.apache.org/jira/browse/FLINK-12003
Project:
vinoyang created FLINK-11818:
Summary: Provide pipe transformation function for DataSet API
Key: FLINK-11818
URL: https://issues.apache.org/jira/browse/FLINK-11818
Project: Flink
Issue Type:
vinoyang created FLINK-11782:
Summary: Enhance TaskManager log visualization by listing all log
files for Flink web UI
Key: FLINK-11782
URL: https://issues.apache.org/jira/browse/FLINK-11782
Project:
vinoyang created FLINK-11770:
Summary: Update FlinkKinesisConsumerMigrationTest for 1.8
Key: FLINK-11770
URL: https://issues.apache.org/jira/browse/FLINK-11770
Project: Flink
Issue Type:
vinoyang created FLINK-11768:
Summary: Update TypeSerializerSnapshotMigrationITCase for Flink 1.8
Key: FLINK-11768
URL: https://issues.apache.org/jira/browse/FLINK-11768
Project: Flink
Issue
vinoyang created FLINK-11767:
Summary: Update TypeSerializerSnapshotMigrationTestBase and
subclasses for 1.8
Key: FLINK-11767
URL: https://issues.apache.org/jira/browse/FLINK-11767
Project: Flink
vinoyang created FLINK-11766:
Summary: Update Java / Scala StatefulJobSavepointMigrationITCase
for 1.8
Key: FLINK-11766
URL: https://issues.apache.org/jira/browse/FLINK-11766
Project: Flink
vinoyang created FLINK-11765:
Summary: Update Java / Scala
StatefulJobWBroadcastStateMigrationITCase for 1.7
Key: FLINK-11765
URL: https://issues.apache.org/jira/browse/FLINK-11765
Project: Flink
vinoyang created FLINK-11764:
Summary: Update BucketingSinkMigrationTest for Flink 1.8
Key: FLINK-11764
URL: https://issues.apache.org/jira/browse/FLINK-11764
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-11762:
Summary: Update WindowOperatorMigrationTest for 1.8
Key: FLINK-11762
URL: https://issues.apache.org/jira/browse/FLINK-11762
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-11763:
Summary: Update AbstractKeyedOperatorRestoreTestBase for 1.9
Key: FLINK-11763
URL: https://issues.apache.org/jira/browse/FLINK-11763
Project: Flink
Issue Type:
vinoyang created FLINK-11761:
Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.8
Key: FLINK-11761
URL: https://issues.apache.org/jira/browse/FLINK-11761
Project: Flink
Issue Type:
vinoyang created FLINK-11760:
Summary: Update CEPMigrationTest for 1.8
Key: FLINK-11760
URL: https://issues.apache.org/jira/browse/FLINK-11760
Project: Flink
Issue Type: Test
vinoyang created FLINK-11759:
Summary: Update AbstractNonKeyedOperatorRestoreTestBase for 1.8
Key: FLINK-11759
URL: https://issues.apache.org/jira/browse/FLINK-11759
Project: Flink
Issue Type:
vinoyang created FLINK-11758:
Summary: Update ContinuousFileProcessingMigrationTest for 1.8
Key: FLINK-11758
URL: https://issues.apache.org/jira/browse/FLINK-11758
Project: Flink
Issue Type:
vinoyang created FLINK-11737:
Summary: Support MultipleOutputs output
Key: FLINK-11737
URL: https://issues.apache.org/jira/browse/FLINK-11737
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-11735:
Summary: Provide HadoopReduceCombineFunction for new MapReduce API
Key: FLINK-11735
URL: https://issues.apache.org/jira/browse/FLINK-11735
Project: Flink
Issue
vinoyang created FLINK-11734:
Summary: Provide HadoopReduceFunction for
org.apache.hadoop.mapreduce.Reducer
Key: FLINK-11734
URL: https://issues.apache.org/jira/browse/FLINK-11734
Project: Flink
1 - 100 of 195 matches
Mail list logo
