vinoyang created FLINK-11733:
Summary: Provide HadoopMapFunction for
org.apache.hadoop.mapreduce.Mapper
Key: FLINK-11733
URL: https://issues.apache.org/jira/browse/FLINK-11733
Project: Flink
vinoyang created FLINK-11697:
Summary: Add readMapReduceTextFile API for HadoopInputs
Key: FLINK-11697
URL: https://issues.apache.org/jira/browse/FLINK-11697
Project: Flink
Issue Type:
vinoyang created FLINK-11698:
Summary: Add readMapRedTextFile API for HadoopInputs
Key: FLINK-11698
URL: https://issues.apache.org/jira/browse/FLINK-11698
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-11661:
Summary: Implement HadoopReduceCombineFunctionITCase for new
Hadoop API
Key: FLINK-11661
URL: https://issues.apache.org/jira/browse/FLINK-11661
Project: Flink
vinoyang created FLINK-11660:
Summary: Implement HadoopReduceFunctionITCase for new Hadoop API
Key: FLINK-11660
URL: https://issues.apache.org/jira/browse/FLINK-11660
Project: Flink
Issue Type:
vinoyang created FLINK-11659:
Summary: Implement HadoopMapFunctionITCase for new Hadoop API
Key: FLINK-11659
URL: https://issues.apache.org/jira/browse/FLINK-11659
Project: Flink
Issue Type:
vinoyang created FLINK-11658:
Summary: Implement HadoopMapreduceITCase for new Hadoop API
Key: FLINK-11658
URL: https://issues.apache.org/jira/browse/FLINK-11658
Project: Flink
Issue Type:
vinoyang created FLINK-11657:
Summary: Fix deprecated API compatibility issue for
WordCountMapreduceITCase
Key: FLINK-11657
URL: https://issues.apache.org/jira/browse/FLINK-11657
Project: Flink
vinoyang created FLINK-11656:
Summary: Fix deprecated API compatibility issue for
WordCountMapredITCase
Key: FLINK-11656
URL: https://issues.apache.org/jira/browse/FLINK-11656
Project: Flink
vinoyang created FLINK-11639:
Summary: Provide readSequenceFile for Hadoop new API
Key: FLINK-11639
URL: https://issues.apache.org/jira/browse/FLINK-11639
Project: Flink
Issue Type: Test
vinoyang created FLINK-11440:
Summary: AbstractOperatorRestoreTestBase#testMigrationAndRestore
caused IllegalStateException
Key: FLINK-11440
URL: https://issues.apache.org/jira/browse/FLINK-11440
vinoyang created FLINK-11437:
Summary:
EventTimeWindowCheckpointingITCase#testTumblingTimeWindowWithKVStateMaxMaxParallelism
caused CancellationException
Key: FLINK-11437
URL:
vinoyang created FLINK-11432:
Summary: YarnFlinkResourceManagerTest test case timeout
Key: FLINK-11432
URL: https://issues.apache.org/jira/browse/FLINK-11432
Project: Flink
Issue Type: Test
vinoyang created FLINK-11426:
Summary: FlinkKafkaProducerBase test case failed
Key: FLINK-11426
URL: https://issues.apache.org/jira/browse/FLINK-11426
Project: Flink
Issue Type: Test
vinoyang created FLINK-11380:
Summary: YarnFlinkResourceManagerTest test case crashed
Key: FLINK-11380
URL: https://issues.apache.org/jira/browse/FLINK-11380
Project: Flink
Issue Type: Test
vinoyang created FLINK-11286:
Summary: Support to send StreamStatus.IDLE for non-source
operators
Key: FLINK-11286
URL: https://issues.apache.org/jira/browse/FLINK-11286
Project: Flink
Issue
vinoyang created FLINK-11277:
Summary: Queryable state IT test failed
Key: FLINK-11277
URL: https://issues.apache.org/jira/browse/FLINK-11277
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-11229:
Summary: Support ScalarFunction for the where/filter clause.
Key: FLINK-11229
URL: https://issues.apache.org/jira/browse/FLINK-11229
Project: Flink
Issue Type:
vinoyang created FLINK-11209:
Summary: Provide more complete guidance for the log usage
documentation
Key: FLINK-11209
URL: https://issues.apache.org/jira/browse/FLINK-11209
Project: Flink
vinoyang created FLINK-11175:
Summary: The sample code describing the Processing time used in
TableSource is incorrect
Key: FLINK-11175
URL: https://issues.apache.org/jira/browse/FLINK-11175
Project:
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
vinoyang created FLINK-11162:
Summary: Provide a rest API to list all logical operators
Key: FLINK-11162
URL: https://issues.apache.org/jira/browse/FLINK-11162
Project: Flink
Issue Type: New
vinoyang created FLINK-8:
Summary: Refactor and unify rowtime timestamp extractor interface
Key: FLINK-8
URL: https://issues.apache.org/jira/browse/FLINK-8
Project: Flink
Issue Type:
vinoyang created FLINK-11015:
Summary: Remove deprecated methods and classes from all the Kafka
connectors
Key: FLINK-11015
URL: https://issues.apache.org/jira/browse/FLINK-11015
Project: Flink
vinoyang created FLINK-10993:
Summary: Bring bloomfilter as a public API
Key: FLINK-10993
URL: https://issues.apache.org/jira/browse/FLINK-10993
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-10966:
Summary: Optimize the release blocking logic in BarrierBuffer
Key: FLINK-10966
URL: https://issues.apache.org/jira/browse/FLINK-10966
Project: Flink
Issue Type:
vinoyang created FLINK-10940:
Summary: Refactor the maven dependencies of Kafka 0.8 connector
Key: FLINK-10940
URL: https://issues.apache.org/jira/browse/FLINK-10940
Project: Flink
Issue Type:
vinoyang created FLINK-10931:
Summary: Exclude transitive dependence on Kafka-client
Key: FLINK-10931
URL: https://issues.apache.org/jira/browse/FLINK-10931
Project: Flink
Issue Type:
vinoyang created FLINK-10922:
Summary: Refactor the placement of the Flink Kafka connector end
to end test module
Key: FLINK-10922
URL: https://issues.apache.org/jira/browse/FLINK-10922
Project: Flink
vinoyang created FLINK-10891:
Summary: Upgrade Kafka client version to 2.0.1
Key: FLINK-10891
URL: https://issues.apache.org/jira/browse/FLINK-10891
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10872:
Summary: Extend SQL client end-to-end to test KafkaTableSink for
kafka connector 0.11
Key: FLINK-10872
URL: https://issues.apache.org/jira/browse/FLINK-10872
Project: Flink
vinoyang created FLINK-10853:
Summary: Provide end-to-end test for Kafka 0.9 connector
Key: FLINK-10853
URL: https://issues.apache.org/jira/browse/FLINK-10853
Project: Flink
Issue Type: Test
vinoyang created FLINK-10854:
Summary: Provide end-to-end test for Kafka 0.8 connector
Key: FLINK-10854
URL: https://issues.apache.org/jira/browse/FLINK-10854
Project: Flink
Issue Type: Test
vinoyang created FLINK-10840:
Summary: BucketingSink incorrectly clears the pendingFiles List
Key: FLINK-10840
URL: https://issues.apache.org/jira/browse/FLINK-10840
Project: Flink
Issue Type:
vinoyang created FLINK-10801:
Summary: Fix sql client integrate elasticsearch connector test
failure
Key: FLINK-10801
URL: https://issues.apache.org/jira/browse/FLINK-10801
Project: Flink
Issue
vinoyang created FLINK-10798:
Summary: Add the version number of Flink 1.7 to MigrationVersion
Key: FLINK-10798
URL: https://issues.apache.org/jira/browse/FLINK-10798
Project: Flink
Issue Type:
vinoyang created FLINK-10792:
Summary: Extend SQL client end-to-end to test KafkaTableSink for
kafka 0.11 connector
Key: FLINK-10792
URL: https://issues.apache.org/jira/browse/FLINK-10792
Project: Flink
vinoyang created FLINK-10791:
Summary: Provide end-to-end test for Kafka 0.11 connector
Key: FLINK-10791
URL: https://issues.apache.org/jira/browse/FLINK-10791
Project: Flink
Issue Type: Test
vinoyang created FLINK-10771:
Summary: Replace hard code of job graph file path with config
option for FileJobGraphRetriever
Key: FLINK-10771
URL: https://issues.apache.org/jira/browse/FLINK-10771
vinoyang created FLINK-10704:
Summary: Fix sql client end to end test failure
Key: FLINK-10704
URL: https://issues.apache.org/jira/browse/FLINK-10704
Project: Flink
Issue Type: Bug
vinoyang created FLINK-10701:
Summary: Move modern kafka connector module into connector profile
Key: FLINK-10701
URL: https://issues.apache.org/jira/browse/FLINK-10701
Project: Flink
Issue
vinoyang created FLINK-10685:
Summary: Support history server on YARN
Key: FLINK-10685
URL: https://issues.apache.org/jira/browse/FLINK-10685
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-10620:
Summary: Remove the dependency on the version string literal.
Key: FLINK-10620
URL: https://issues.apache.org/jira/browse/FLINK-10620
Project: Flink
Issue Type:
vinoyang created FLINK-10600:
Summary: Provide End-to-end test cases for modern Kafka connectors
Key: FLINK-10600
URL: https://issues.apache.org/jira/browse/FLINK-10600
Project: Flink
Issue
vinoyang created FLINK-10599:
Summary: Provide documentation for the modern kafka connector
Key: FLINK-10599
URL: https://issues.apache.org/jira/browse/FLINK-10599
Project: Flink
Issue Type:
vinoyang created FLINK-10598:
Summary: Maintain modern Kafka connector
Key: FLINK-10598
URL: https://issues.apache.org/jira/browse/FLINK-10598
Project: Flink
Issue Type: Task
vinoyang created FLINK-10558:
Summary: Port YARNHighAvailabilityITCase and
YARNSessionCapacitySchedulerITCase to new code base
Key: FLINK-10558
URL: https://issues.apache.org/jira/browse/FLINK-10558
vinoyang created FLINK-10550:
Summary: Remove LegacyYarnClusterDescriptor
Key: FLINK-10550
URL: https://issues.apache.org/jira/browse/FLINK-10550
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10548:
Summary: Remove LegacyStandaloneClusterDescriptor
Key: FLINK-10548
URL: https://issues.apache.org/jira/browse/FLINK-10548
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10547:
Summary: Remove LegacyCLI
Key: FLINK-10547
URL: https://issues.apache.org/jira/browse/FLINK-10547
Project: Flink
Issue Type: Sub-task
Reporter: vinoyang
vinoyang created FLINK-10527:
Summary: Cleanup constant isNewMode in YarnTestBase
Key: FLINK-10527
URL: https://issues.apache.org/jira/browse/FLINK-10527
Project: Flink
Issue Type: Bug
vinoyang created FLINK-10420:
Summary: Create and drop view in sql client should check the view
created based on the configuration.
Key: FLINK-10420
URL: https://issues.apache.org/jira/browse/FLINK-10420
vinoyang created FLINK-10398:
Summary: Add Tanh math function supported in Table API and SQL
Key: FLINK-10398
URL: https://issues.apache.org/jira/browse/FLINK-10398
Project: Flink
Issue Type:
vinoyang created FLINK-10384:
Summary: Add Sinh math function supported in Table API and SQL
Key: FLINK-10384
URL: https://issues.apache.org/jira/browse/FLINK-10384
Project: Flink
Issue Type:
vinoyang created FLINK-10309:
Summary: Cancel flink job occurs java.net.ConnectException
Key: FLINK-10309
URL: https://issues.apache.org/jira/browse/FLINK-10309
Project: Flink
Issue Type: Bug
vinoyang created FLINK-10281:
Summary: Table function parse regular expression contains
backslash failed
Key: FLINK-10281
URL: https://issues.apache.org/jira/browse/FLINK-10281
Project: Flink
vinoyang created FLINK-10222:
Summary: Table scalar function expression parses error when
function name equals the exists keyword suffix
Key: FLINK-10222
URL: https://issues.apache.org/jira/browse/FLINK-10222
vinoyang created FLINK-10221:
Summary: Flink metrics documentation io section table layout error
Key: FLINK-10221
URL: https://issues.apache.org/jira/browse/FLINK-10221
Project: Flink
Issue
vinoyang created FLINK-10136:
Summary: Add REPEAT supported in Table API and SQL
Key: FLINK-10136
URL: https://issues.apache.org/jira/browse/FLINK-10136
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10111:
Summary: Test failure because of
HAQueryableStateFsBackendITCase#testMapState thorws NPE
Key: FLINK-10111
URL: https://issues.apache.org/jira/browse/FLINK-10111
Project:
vinoyang created FLINK-10105:
Summary: Test failure because of
jobmanager.execution.failover-strategy is outdated
Key: FLINK-10105
URL: https://issues.apache.org/jira/browse/FLINK-10105
Project: Flink
vinoyang created FLINK-10060:
Summary: Add RTRIM supported in Table API and SQL
Key: FLINK-10060
URL: https://issues.apache.org/jira/browse/FLINK-10060
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10059:
Summary: Add LTRIM supported in Table API and SQL
Key: FLINK-10059
URL: https://issues.apache.org/jira/browse/FLINK-10059
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10058:
Summary: Add getStateBackend/setStateBackend API for
PythonStreamExecutionEnvironment
Key: FLINK-10058
URL: https://issues.apache.org/jira/browse/FLINK-10058
Project: Flink
vinoyang created FLINK-10054:
Summary: Add getMaxParallelism/setMaxParallelism API for
PythonStreamExecutionEnvironment
Key: FLINK-10054
URL: https://issues.apache.org/jira/browse/FLINK-10054
Project:
vinoyang created FLINK-10053:
Summary: Add getParallelism API for
PythonStreamExecutionEnvironment
Key: FLINK-10053
URL: https://issues.apache.org/jira/browse/FLINK-10053
Project: Flink
Issue
vinoyang created FLINK-10048:
Summary: Migrate module flink-gelly-examples to flink-examples and
rename it
Key: FLINK-10048
URL: https://issues.apache.org/jira/browse/FLINK-10048
Project: Flink
vinoyang created FLINK-10025:
Summary: Add getCheckpointConfig API for
PythonStreamExecutionEnvironment
Key: FLINK-10025
URL: https://issues.apache.org/jira/browse/FLINK-10025
Project: Flink
vinoyang created FLINK-10024:
Summary: Test enable_checkpoint python API
Key: FLINK-10024
URL: https://issues.apache.org/jira/browse/FLINK-10024
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-10023:
Summary: Enhance Python API for streaming
Key: FLINK-10023
URL: https://issues.apache.org/jira/browse/FLINK-10023
Project: Flink
Issue Type: Task
vinoyang created FLINK-10012:
Summary: Support setStreamTimeCharacteristic for Python API
Key: FLINK-10012
URL: https://issues.apache.org/jira/browse/FLINK-10012
Project: Flink
Issue Type:
vinoyang created FLINK-:
---
Summary: Add ISNUMERIC supported in Table API/SQL
Key: FLINK-
URL: https://issues.apache.org/jira/browse/FLINK-
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-9993:
---
Summary: Wordcount end-to-end test in docker failed
Key: FLINK-9993
URL: https://issues.apache.org/jira/browse/FLINK-9993
Project: Flink
Issue Type: Bug
vinoyang created FLINK-9992:
---
Summary: FsStorageLocationReferenceTest#testEncodeAndDecode failed
in Travis CI
Key: FLINK-9992
URL: https://issues.apache.org/jira/browse/FLINK-9992
Project: Flink
vinoyang created FLINK-9991:
---
Summary: Add regex_replace supported in TableAPI and SQL
Key: FLINK-9991
URL: https://issues.apache.org/jira/browse/FLINK-9991
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-9990:
---
Summary: Add regex_extract supported in TableAPI and SQL
Key: FLINK-9990
URL: https://issues.apache.org/jira/browse/FLINK-9990
Project: Flink
Issue Type: Sub-task
vinoyang created FLINK-9970:
---
Summary: Add ASCII function for table/sql API
Key: FLINK-9970
URL: https://issues.apache.org/jira/browse/FLINK-9970
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-9961:
---
Summary: Add CHR function for table/sql API
Key: FLINK-9961
URL: https://issues.apache.org/jira/browse/FLINK-9961
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-9929:
---
Summary: Add log10 mathematical function for table/sql API
Key: FLINK-9929
URL: https://issues.apache.org/jira/browse/FLINK-9929
Project: Flink
Issue Type: New
vinoyang created FLINK-9928:
---
Summary: Add LOG2 function for table/sql API
Key: FLINK-9928
URL: https://issues.apache.org/jira/browse/FLINK-9928
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-9916:
---
Summary: Add FROM_BASE64 function for table/sql API
Key: FLINK-9916
URL: https://issues.apache.org/jira/browse/FLINK-9916
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-9915:
---
Summary: Add TO_BASE64 support function in table/sql API
Key: FLINK-9915
URL: https://issues.apache.org/jira/browse/FLINK-9915
Project: Flink
Issue Type: New Feature
vinoyang created FLINK-9914:
---
Summary: Flink docker information in official website is out of
date and should be update
Key: FLINK-9914
URL: https://issues.apache.org/jira/browse/FLINK-9914
Project: Flink
vinoyang created FLINK-9841:
---
Summary: Web UI only show partial taskmanager log
Key: FLINK-9841
URL: https://issues.apache.org/jira/browse/FLINK-9841
Project: Flink
Issue Type: Bug
Affects
vinoyang created FLINK-9837:
---
Summary: Display the job description in the Flink web UI
Key: FLINK-9837
URL: https://issues.apache.org/jira/browse/FLINK-9837
Project: Flink
Issue Type: Improvement
vinoyang created FLINK-9694:
---
Summary: potentially NPE in CompositeTypeSerializerConfigSnapshot
constructor
Key: FLINK-9694
URL: https://issues.apache.org/jira/browse/FLINK-9694
Project: Flink
vinoyang created FLINK-9521:
---
Summary: Add build plugin to package table example jar
Key: FLINK-9521
URL: https://issues.apache.org/jira/browse/FLINK-9521
Project: Flink
Issue Type: Bug
vinoyang created FLINK-9519:
---
Summary: table example jar did not copy into example dir
Key: FLINK-9519
URL: https://issues.apache.org/jira/browse/FLINK-9519
Project: Flink
Issue Type: Bug
vinoyang created FLINK-9452:
---
Summary: Flink 1.5 document version title shows snapshot
Key: FLINK-9452
URL: https://issues.apache.org/jira/browse/FLINK-9452
Project: Flink
Issue Type: Bug
vinoyang created FLINK-9387:
---
Summary: Several log message errors in queryable-state module
Key: FLINK-9387
URL: https://issues.apache.org/jira/browse/FLINK-9387
Project: Flink
Issue Type:
vinoyang created FLINK-9352:
---
Summary: In Standalone checkpoint recover mode many jobs with same
checkpoint interval cause IO pressure
Key: FLINK-9352
URL: https://issues.apache.org/jira/browse/FLINK-9352
vinoyang created FLINK-9350:
---
Summary: Parameter baseInterval has wrong check message in
CheckpointCoordinator constructor
Key: FLINK-9350
URL: https://issues.apache.org/jira/browse/FLINK-9350
Project:
vinoyang created FLINK-9342:
---
Summary: conflicted url path pattern about
SubtaskCurrentAttemptDetailsHeaders and AggregatedSubtaskMetricsHeaders
Key: FLINK-9342
URL: https://issues.apache.org/jira/browse/FLINK-9342
vinoyang created FLINK-9153:
---
Summary: TaskManagerRunner should support rpc port range
Key: FLINK-9153
URL: https://issues.apache.org/jira/browse/FLINK-9153
Project: Flink
Issue Type: Bug
vinoyang created FLINK-8792:
---
Summary: bad semantic of method
MessageQueryParameter.convertStringToValue
Key: FLINK-8792
URL: https://issues.apache.org/jira/browse/FLINK-8792
Project: Flink
101 - 195 of 195 matches
Mail list logo
