Huang Xingbo created FLINK-14547:
Summary: UDF cannot be in the join condition in blink planner
Key: FLINK-14547
URL: https://issues.apache.org/jira/browse/FLINK-14547
Project: Flink
Issue Ty
Huang Xingbo created FLINK-14573:
Summary: Support time data types in Python user-defined functions
Key: FLINK-14573
URL: https://issues.apache.org/jira/browse/FLINK-14573
Project: Flink
Issu
Huang Xingbo created FLINK-14584:
Summary: Support complex data types in Python user-defined
functions
Key: FLINK-14584
URL: https://issues.apache.org/jira/browse/FLINK-14584
Project: Flink
Huang Xingbo created FLINK-15168:
Summary: Exception is thrown when using kafka source connector
with flink planner
Key: FLINK-15168
URL: https://issues.apache.org/jira/browse/FLINK-15168
Project: Fli
Huang Xingbo created FLINK-13137:
Summary: Remove the legacy flink python docs
Key: FLINK-13137
URL: https://issues.apache.org/jira/browse/FLINK-13137
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-31099:
Summary: Chained WindowOperator throws NPE in PyFlink ThreadMode
Key: FLINK-31099
URL: https://issues.apache.org/jira/browse/FLINK-31099
Project: Flink
Issue
Huang Xingbo created FLINK-27068:
Summary: test_keyed_min_and_max and test_keyed_min_by_and_max_by
failed in py36,37
Key: FLINK-27068
URL: https://issues.apache.org/jira/browse/FLINK-27068
Project: Fl
Huang Xingbo created FLINK-27069:
Summary: Fix the potential memory corruption in Thread Mode
Key: FLINK-27069
URL: https://issues.apache.org/jira/browse/FLINK-27069
Project: Flink
Issue Type
Huang Xingbo created FLINK-27159:
Summary: Support first_value/last_value in the Table API
Key: FLINK-27159
URL: https://issues.apache.org/jira/browse/FLINK-27159
Project: Flink
Issue Type: S
Huang Xingbo created FLINK-27282:
Summary: Fix the bug of wrong positions mapping in RowCoder
Key: FLINK-27282
URL: https://issues.apache.org/jira/browse/FLINK-27282
Project: Flink
Issue Type
Huang Xingbo created FLINK-27297:
Summary: Add the
StreamExecutionEnvironment#getExecutionEnvironment(Configuration) method in
PyFlink
Key: FLINK-27297
URL: https://issues.apache.org/jira/browse/FLINK-27297
Huang Xingbo created FLINK-27403:
Summary: Align existing feature engineering algorithms in ML
Python API
Key: FLINK-27403
URL: https://issues.apache.org/jira/browse/FLINK-27403
Project: Flink
Huang Xingbo created FLINK-27404:
Summary: Add algorithms completeness test in ML Python API
Key: FLINK-27404
URL: https://issues.apache.org/jira/browse/FLINK-27404
Project: Flink
Issue Type:
Huang Xingbo created FLINK-27575:
Summary: Support PyFlink in Python3.9
Key: FLINK-27575
URL: https://issues.apache.org/jira/browse/FLINK-27575
Project: Flink
Issue Type: New Feature
Huang Xingbo created FLINK-27602:
Summary: Add docs in Python ML
Key: FLINK-27602
URL: https://issues.apache.org/jira/browse/FLINK-27602
Project: Flink
Issue Type: Sub-task
Componen
Huang Xingbo created FLINK-27674:
Summary: Elasticsearch6SinkE2ECase test hangs
Key: FLINK-27674
URL: https://issues.apache.org/jira/browse/FLINK-27674
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-27691:
Summary: RankHarnessTest.
testUpdateRankWithRowNumberSortKeyDropsToNotLast test failed with result
mismatch
Key: FLINK-27691
URL: https://issues.apache.org/jira/browse/FLINK-2769
Huang Xingbo created FLINK-27695:
Summary: KafkaTransactionLogITCase failed on azure due to Could
not find a valid Docker environment
Key: FLINK-27695
URL: https://issues.apache.org/jira/browse/FLINK-27695
Huang Xingbo created FLINK-27701:
Summary: HashMapStateBackendWindowITCase.
testAggregateWindowStateReader failed with Not all required tasks are
currently running
Key: FLINK-27701
URL: https://issues.apache.org
Huang Xingbo created FLINK-27703:
Summary:
FileChannelManagerImplTest.testDirectoriesCleanupOnKillWithoutCallerHook failed
with The marker file was not found within 1 msecs
Key: FLINK-27703
URL: https://issue
Huang Xingbo created FLINK-27715:
Summary: Add more Python ML examples
Key: FLINK-27715
URL: https://issues.apache.org/jira/browse/FLINK-27715
Project: Flink
Issue Type: Sub-task
Co
Huang Xingbo created FLINK-27716:
Summary: Add Python API docs in ML
Key: FLINK-27716
URL: https://issues.apache.org/jira/browse/FLINK-27716
Project: Flink
Issue Type: Sub-task
Comp
Huang Xingbo created FLINK-27744:
Summary: CheckPubSubEmulatorTest.testPull failed with
AssertionError
Key: FLINK-27744
URL: https://issues.apache.org/jira/browse/FLINK-27744
Project: Flink
Huang Xingbo created FLINK-27745:
Summary: ClientUtilsTest.uploadAndSetUserArtifacts failed with
NoClassDefFoundError
Key: FLINK-27745
URL: https://issues.apache.org/jira/browse/FLINK-27745
Project: F
Huang Xingbo created FLINK-27751:
Summary: Scala suffix check failed
Key: FLINK-27751
URL: https://issues.apache.org/jira/browse/FLINK-27751
Project: Flink
Issue Type: Bug
Component
Huang Xingbo created FLINK-27764:
Summary: SetOperatorsITCase tests failed
Key: FLINK-27764
URL: https://issues.apache.org/jira/browse/FLINK-27764
Project: Flink
Issue Type: Bug
Com
Huang Xingbo created FLINK-27765:
Summary:
TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure
failed with FlinkJobNotFoundException
Key: FLINK-27765
URL: https://issues.apache.org/jira/bro
Huang Xingbo created FLINK-27774:
Summary: Window Agg doesn't work when used in Batch Table API
Key: FLINK-27774
URL: https://issues.apache.org/jira/browse/FLINK-27774
Project: Flink
Issue Ty
Huang Xingbo created FLINK-27776:
Summary: Throws exception when udaf used in sliding window does
not implement merge method in PyFlink
Key: FLINK-27776
URL: https://issues.apache.org/jira/browse/FLINK-27776
Huang Xingbo created FLINK-27791:
Summary: SlotCountExceedingParallelismTest tests failed with
NoResourceAvailableException
Key: FLINK-27791
URL: https://issues.apache.org/jira/browse/FLINK-27791
Proj
Huang Xingbo created FLINK-27792:
Summary: WindowDistinctAggregateITCase. testTumbleWindow_Rollup
failed with InterruptedException
Key: FLINK-27792
URL: https://issues.apache.org/jira/browse/FLINK-27792
Huang Xingbo created FLINK-27832:
Summary: SplitAggregateITCase tests failed with Could not acquire
the minimum required resources
Key: FLINK-27832
URL: https://issues.apache.org/jira/browse/FLINK-27832
Huang Xingbo created FLINK-27833:
Summary: PulsarSourceITCase.testTaskManagerFailure failed with
AssertionError
Key: FLINK-27833
URL: https://issues.apache.org/jira/browse/FLINK-27833
Project: Flink
Huang Xingbo created FLINK-27869:
Summary: AdaptiveSchedulerITCase. testStopWithSavepointFailOnStop
failed with FAIL_ON_CHECKPOINT_COMPLETE
Key: FLINK-27869
URL: https://issues.apache.org/jira/browse/FLINK-27869
Huang Xingbo created FLINK-27870:
Summary: SemiAntiJoinStreamITCase.
testAntiJoinWithTwoSidesRetraction failed with InterruptedException
Key: FLINK-27870
URL: https://issues.apache.org/jira/browse/FLINK-27870
Huang Xingbo created FLINK-27883:
Summary: KafkaSubscriberTest failed with NPC
Key: FLINK-27883
URL: https://issues.apache.org/jira/browse/FLINK-27883
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-27915:
Summary: WindowJoinITCase.testInnerJoinOnWTFWithOffset failed with
InterruptedException
Key: FLINK-27915
URL: https://issues.apache.org/jira/browse/FLINK-27915
Projec
Huang Xingbo created FLINK-27916:
Summary: HybridSourceReaderTest.testReader failed with
AssertionError
Key: FLINK-27916
URL: https://issues.apache.org/jira/browse/FLINK-27916
Project: Flink
Huang Xingbo created FLINK-27917:
Summary:
PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition
failed with AssertionError
Key: FLINK-27917
URL: https:/
Huang Xingbo created FLINK-27918:
Summary:
SavepointITCase.testStopWithSavepointFailingAfterSnapshotCreation failed with
Expected RuntimeException after snapshot creation
Key: FLINK-27918
URL: https://issues.apac
Huang Xingbo created FLINK-27955:
Summary: Fix the problem of windows installation failure in PyFlink
Key: FLINK-27955
URL: https://issues.apache.org/jira/browse/FLINK-27955
Project: Flink
Is
Huang Xingbo created FLINK-28001:
Summary: PlannerScalaFreeITCase.testImperativeUdaf failed with
Permission denied
Key: FLINK-28001
URL: https://issues.apache.org/jira/browse/FLINK-28001
Project: Flin
Huang Xingbo created FLINK-28002:
Summary: test_connectors.py failed with "object is not an instance
of declaring class" in JDK11
Key: FLINK-28002
URL: https://issues.apache.org/jira/browse/FLINK-28002
Huang Xingbo created FLINK-28176:
Summary: test_es_sink_dynamic failed in jdk11
Key: FLINK-28176
URL: https://issues.apache.org/jira/browse/FLINK-28176
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-28177:
Summary:
Elasticsearch6DynamicSinkITCase.testWritingDocumentsNoPrimaryKey failed with
503 Service Unavailable
Key: FLINK-28177
URL: https://issues.apache.org/jira/browse/FLINK-28
Huang Xingbo created FLINK-28195:
Summary: Annotate Python3.6 as deprecated in PyFlink 1.16
Key: FLINK-28195
URL: https://issues.apache.org/jira/browse/FLINK-28195
Project: Flink
Issue Type:
Huang Xingbo created FLINK-28237:
Summary: Improve the flink-ml python examples in doc
Key: FLINK-28237
URL: https://issues.apache.org/jira/browse/FLINK-28237
Project: Flink
Issue Type: Impro
Huang Xingbo created FLINK-28305:
Summary: SQL Client end-to-end test failed with
ElasticsearchException
Key: FLINK-28305
URL: https://issues.apache.org/jira/browse/FLINK-28305
Project: Flink
Huang Xingbo created FLINK-28326:
Summary: ResultPartitionTest.testIdleAndBackPressuredTime failed
with AssertError
Key: FLINK-28326
URL: https://issues.apache.org/jira/browse/FLINK-28326
Project: Fli
Huang Xingbo created FLINK-28328:
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with
IllegalStateException
Key: FLINK-28328
URL: https://issues.apache.org/jira/browse/FLINK-2
Huang Xingbo created FLINK-28426:
Summary: PyFlink provides M1 wheel package
Key: FLINK-28426
URL: https://issues.apache.org/jira/browse/FLINK-28426
Project: Flink
Issue Type: New Feature
Huang Xingbo created FLINK-28429:
Summary: Reduce pyflink tests time
Key: FLINK-28429
URL: https://issues.apache.org/jira/browse/FLINK-28429
Project: Flink
Issue Type: Improvement
C
Huang Xingbo created FLINK-28440:
Summary: EventTimeWindowCheckpointingITCase.testSlidingTimeWindow
failed with restore
Key: FLINK-28440
URL: https://issues.apache.org/jira/browse/FLINK-28440
Project:
Huang Xingbo created FLINK-28453:
Summary: KafkaSourceLegacyITCase.testBrokerFailure hang on azure
Key: FLINK-28453
URL: https://issues.apache.org/jira/browse/FLINK-28453
Project: Flink
Issue
Huang Xingbo created FLINK-28523:
Summary: LocalRecoveryITCase failed with AssertionError
Key: FLINK-28523
URL: https://issues.apache.org/jira/browse/FLINK-28523
Project: Flink
Issue Type: Bu
Huang Xingbo created FLINK-28525:
Summary: HiveDialectITCase.testTableWithSubDirsInPartitionDir
failed with AssertJMultipleFailuresError
Key: FLINK-28525
URL: https://issues.apache.org/jira/browse/FLINK-28525
Huang Xingbo created FLINK-28529:
Summary:
ChangelogPeriodicMaterializationSwitchStateBackendITCase.testSwitchFromDisablingToEnablingInClaimMode
failed with CheckpointException: Checkpoint expired before completing
Key: FLINK-285
Huang Xingbo created FLINK-28544:
Summary: Elasticsearch6SinkE2ECase failed with no space left on
device
Key: FLINK-28544
URL: https://issues.apache.org/jira/browse/FLINK-28544
Project: Flink
Huang Xingbo created FLINK-28545:
Summary:
FlinkKafkaProducerITCase.testRestoreToCheckpointAfterExceedingProducersPool
failed with TimeoutException: Topic flink-kafka-producer-fail-before-notify not
present in metadata after 6 ms
Huang Xingbo created FLINK-28546:
Summary: Add the release logic for py39 and m1 wheel package
Key: FLINK-28546
URL: https://issues.apache.org/jira/browse/FLINK-28546
Project: Flink
Issue Typ
Huang Xingbo created FLINK-28549:
Summary: Support DataStream PythonProcessOperator in Thread Mode
Key: FLINK-28549
URL: https://issues.apache.org/jira/browse/FLINK-28549
Project: Flink
Issue
Huang Xingbo created FLINK-28557:
Summary:
CheckpointCoordinatorTriggeringTest.discardingTriggeringCheckpointWillExecuteNextCheckpointRequest
Process produced no output for 900 seconds
Key: FLINK-28557
URL: https
Huang Xingbo created FLINK-28559:
Summary: Support DataStream PythonKeyedProcessOperator in Thread
Mode
Key: FLINK-28559
URL: https://issues.apache.org/jira/browse/FLINK-28559
Project: Flink
Huang Xingbo created FLINK-28626:
Summary:
RescaleCheckpointManuallyITCase.testCheckpointRescalingInKeyedState failed with
FileNotFoundException
Key: FLINK-28626
URL: https://issues.apache.org/jira/browse/FLINK-2
Huang Xingbo created FLINK-28627:
Summary: KafkaITCase.testBrokerFailure failed with
TestTimedOutException: test timed out after 6 milliseconds
Key: FLINK-28627
URL: https://issues.apache.org/jira/browse/FLINK
Huang Xingbo created FLINK-28679:
Summary: HiveServer2Endpoint compile failed
Key: FLINK-28679
URL: https://issues.apache.org/jira/browse/FLINK-28679
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-28680:
Summary: No space left on device on Azure e2e_2_ci tests
Key: FLINK-28680
URL: https://issues.apache.org/jira/browse/FLINK-28680
Project: Flink
Issue Type: B
Huang Xingbo created FLINK-28688:
Summary: Support DataStream PythonWindowOperator in Thread Mode
Key: FLINK-28688
URL: https://issues.apache.org/jira/browse/FLINK-28688
Project: Flink
Issue
Huang Xingbo created FLINK-28745:
Summary: Support DataStream PythonCoProcessOperator and
PythonKeyedCoProcessOperator in Thread Mode
Key: FLINK-28745
URL: https://issues.apache.org/jira/browse/FLINK-28745
Huang Xingbo created FLINK-28752:
Summary: Add the json plan support in Python UDFs
Key: FLINK-28752
URL: https://issues.apache.org/jira/browse/FLINK-28752
Project: Flink
Issue Type: New Feat
Huang Xingbo created FLINK-28766:
Summary: UnalignedCheckpointStressITCase.runStressTest failed with
NoSuchFileException
Key: FLINK-28766
URL: https://issues.apache.org/jira/browse/FLINK-28766
Project
Huang Xingbo created FLINK-28767:
Summary: SqlGatewayServiceITCase.testCancelOperation failed with
AssertionFailedError
Key: FLINK-28767
URL: https://issues.apache.org/jira/browse/FLINK-28767
Project:
Huang Xingbo created FLINK-28818:
Summary:
KafkaSinkITCase.testWriteRecordsToKafkaWithExactlyOnceGuarantee failed with
AssertionFailedError
Key: FLINK-28818
URL: https://issues.apache.org/jira/browse/FLINK-28818
Huang Xingbo created FLINK-28836:
Summary: Support broadcast in Thread Mode
Key: FLINK-28836
URL: https://issues.apache.org/jira/browse/FLINK-28836
Project: Flink
Issue Type: New Feature
Huang Xingbo created FLINK-28855:
Summary: ThriftObjectConversions compile failed
Key: FLINK-28855
URL: https://issues.apache.org/jira/browse/FLINK-28855
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-28856:
Summary: YARNHighAvailabilityITCase tests failed with
NoSuchMethodError
Key: FLINK-28856
URL: https://issues.apache.org/jira/browse/FLINK-28856
Project: Flink
Huang Xingbo created FLINK-28860:
Summary: CacheITCase.testBatchProduceCacheStreamConsume failed
Key: FLINK-28860
URL: https://issues.apache.org/jira/browse/FLINK-28860
Project: Flink
Issue T
Huang Xingbo created FLINK-28878:
Summary:
PipelinedRegionSchedulingITCase.testRecoverFromPartitionException failed with
AssertionError
Key: FLINK-28878
URL: https://issues.apache.org/jira/browse/FLINK-28878
Huang Xingbo created FLINK-28879:
Summary: New File Sink s3 end-to-end test failed with Output hash
mismatch
Key: FLINK-28879
URL: https://issues.apache.org/jira/browse/FLINK-28879
Project: Flink
Huang Xingbo created FLINK-28887:
Summary: Fix the bug of custom metrics in Thread Mode
Key: FLINK-28887
URL: https://issues.apache.org/jira/browse/FLINK-28887
Project: Flink
Issue Type: Bug
Huang Xingbo created FLINK-28896:
Summary: Test Flink Release 1.16
Key: FLINK-28896
URL: https://issues.apache.org/jira/browse/FLINK-28896
Project: Flink
Issue Type: Improvement
Com
Huang Xingbo created FLINK-28918:
Summary: Release Testing: Running Python DataStream jobs in Thread
Mode
Key: FLINK-28918
URL: https://issues.apache.org/jira/browse/FLINK-28918
Project: Flink
Huang Xingbo created FLINK-28920:
Summary: Release Testing: Running Python DataStream Window Job
Key: FLINK-28920
URL: https://issues.apache.org/jira/browse/FLINK-28920
Project: Flink
Issue T
Huang Xingbo created FLINK-28921:
Summary: Optimize the Python DataStream Window Documentation
Key: FLINK-28921
URL: https://issues.apache.org/jira/browse/FLINK-28921
Project: Flink
Issue Typ
Huang Xingbo created FLINK-28944:
Summary: Optimize the Python Execution Mode Documentation
Key: FLINK-28944
URL: https://issues.apache.org/jira/browse/FLINK-28944
Project: Flink
Issue Type:
Huang Xingbo created FLINK-28955:
Summary: YARNHighAvailabilityITCase compile failed in hadoop3
Key: FLINK-28955
URL: https://issues.apache.org/jira/browse/FLINK-28955
Project: Flink
Issue Ty
Huang Xingbo created FLINK-28957:
Summary: Optimize Python API doc
Key: FLINK-28957
URL: https://issues.apache.org/jira/browse/FLINK-28957
Project: Flink
Issue Type: Improvement
Com
Huang Xingbo created FLINK-28961:
Summary: Add the doc how to support third party connector in
Python DataStream API
Key: FLINK-28961
URL: https://issues.apache.org/jira/browse/FLINK-28961
Project: Fl
Huang Xingbo created FLINK-28970:
Summary: Add the doc how to use Cython to optimize Python function
Key: FLINK-28970
URL: https://issues.apache.org/jira/browse/FLINK-28970
Project: Flink
Iss
Huang Xingbo created FLINK-28999:
Summary: OperatorCoordinatorHolder.checkpointCoordinatorInternal
Cannot mark for checkpoint
Key: FLINK-28999
URL: https://issues.apache.org/jira/browse/FLINK-28999
P
Huang Xingbo created FLINK-29006:
Summary: PulsarSourceITCase failed with Could not acquire the
minimum required resources.
Key: FLINK-29006
URL: https://issues.apache.org/jira/browse/FLINK-29006
Proj
Huang Xingbo created FLINK-29007:
Summary: UsingRemoteJarITCase failed with NPE in hadoop3
Key: FLINK-29007
URL: https://issues.apache.org/jira/browse/FLINK-29007
Project: Flink
Issue Type: B
Huang Xingbo created FLINK-29008:
Summary: SortMergeResultPartitionTest.testRelease failed with
TestTimedOutException
Key: FLINK-29008
URL: https://issues.apache.org/jira/browse/FLINK-29008
Project: F
Huang Xingbo created FLINK-29009:
Summary: flink-end-to-end-tests-sql compile failed in hadoop3
Key: FLINK-29009
URL: https://issues.apache.org/jira/browse/FLINK-29009
Project: Flink
Issue Ty
Huang Xingbo created FLINK-29018:
Summary: KafkaITCase.testMultipleSourcesOnePartition failed with
TopicExistsException
Key: FLINK-29018
URL: https://issues.apache.org/jira/browse/FLINK-29018
Project:
Huang Xingbo created FLINK-29028:
Summary: Add the missing cache api in Python DataStream API
Key: FLINK-29028
URL: https://issues.apache.org/jira/browse/FLINK-29028
Project: Flink
Issue Type
Huang Xingbo created FLINK-29029:
Summary: Fix the bug of CSV format doesn't work in Thread Mode
Key: FLINK-29029
URL: https://issues.apache.org/jira/browse/FLINK-29029
Project: Flink
Issue T
Huang Xingbo created FLINK-29031:
Summary: FlinkKinesisConsumerTest.testSourceSynchronization failed
with AssertionFailedError
Key: FLINK-29031
URL: https://issues.apache.org/jira/browse/FLINK-29031
P
Huang Xingbo created FLINK-29038:
Summary:
AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteOrderedWithRetry failed
with AssertionError
Key: FLINK-29038
URL: https://issues.apache.org/jira/browse/FLINK-290
Huang Xingbo created FLINK-29054:
Summary: Azure tests failed with Temporary failure resolving
'archive.ubuntu.com'
Key: FLINK-29054
URL: https://issues.apache.org/jira/browse/FLINK-29054
Project: Fli
1 - 100 of 346 matches
Mail list logo
