diff --git a/taier-ui/src/pages/editor/streamCollection/source/component/tablePreview.tsx b/taier-ui/src/pages/editor/streamCollection/source/component/tablePreview.tsx
index 4afc4c2f2a..861499a469 100644
--- a/taier-ui/src/pages/editor/streamCollection/source/component/tablePreview.tsx
+++ b/taier-ui/src/pages/editor/streamCollection/source/component/tablePreview.tsx
@@ -55,7 +55,11 @@ export class CollapsePreview extends React.Component<CollaProps, any> {
 					const jsonStr = Utils.isJSONStr(item) ? Utils.jsonFormat(item, 4) : item;
 					return (
 						<Panel
-							header={<div className={defaultClass}>{jsonStr || '无数据'}</div>}
+							header={
+								<div className={defaultClass} style={{ width: 500 }}>
+									{jsonStr || '无数据'}
+								</div>
+							}
 							key={`data-preview-${index}`}
 						>
 							<TextArea style={defaultStyle} value={jsonStr} />
diff --git a/taier-ui/src/pages/editor/streamCollection/source/dataPreviewModal.tsx b/taier-ui/src/pages/editor/streamCollection/source/dataPreviewModal.tsx
index 0471a76f3d..724e10fc3a 100644
--- a/taier-ui/src/pages/editor/streamCollection/source/dataPreviewModal.tsx
+++ b/taier-ui/src/pages/editor/streamCollection/source/dataPreviewModal.tsx
@@ -114,6 +114,7 @@ class DataPreviewModal extends React.Component<any, any> {
 				title="数据预览"
 				onCancel={onCancel}
 				maskClosable={false}
+				width={600}
 				footer={[
 					<Button key="back" type="primary" onClick={onCancel}>
 						关闭
diff --git a/taier-ui/src/pages/rightBar/flinkSource/form.tsx b/taier-ui/src/pages/rightBar/flinkSource/form.tsx
index be7883d255..cde28ce177 100644
--- a/taier-ui/src/pages/rightBar/flinkSource/form.tsx
+++ b/taier-ui/src/pages/rightBar/flinkSource/form.tsx
@@ -234,13 +234,13 @@ export default function SourceForm({
 						<Editor
 							style={{ minHeight: 202 }}
 							className="bd"
-							sync
 							options={{
 								fontSize: 12,
 								minimap: {
 									enabled: false,
 								},
 							}}
+							language="plaintext"
 							placeholder={`字段 类型, 比如 id int 一行一个字段${
 								getFieldValue(NAME_FIELD)?.[index].type !==
 								DATA_SOURCE_ENUM.KAFKA_CONFLUENT
@@ -311,7 +311,7 @@ export default function SourceForm({
 							<Editor
 								style={{ minHeight: 202, height: '100%' }}
 								className="bd"
-								sync
+								language='plaintext'
 								placeholder="分区 偏移量，比如pt 2 一行一对值"
 							/>
 						</FormItem>
diff --git a/taier-ui/src/utils/index.ts b/taier-ui/src/utils/index.ts
index f79aed74f1..e38759503c 100644
--- a/taier-ui/src/utils/index.ts
+++ b/taier-ui/src/utils/index.ts
@@ -675,14 +675,22 @@ export function getColumnsByColumnsText(text: string = '') {
 	if (text) {
 		text.split('\n')
 			.filter(Boolean)
-			.forEach((v) => {
-				const asCase = /^\s*(.+)\s+(.+)\s*$/i.exec(v?.trim());
-				if (asCase && !tmpMap[asCase[1]]) {
-					tmpMap[asCase[1]] = true;
-					columns.push({
-						field: asCase[1],
-						type: asCase[2],
-					});
+			.forEach((v = '') => {
+				const asCase = /^.*\w.*\s+as\s+(\w+)$/i.exec(v.trim());
+				if (asCase) {
+					if (!tmpMap[asCase[1]]) {
+						tmpMap[asCase[1]] = true;
+						columns.push({
+							field: asCase[1],
+							type: asCase[2],
+						});
+					}
+				} else {
+					const [field, type] = v.trim().split(' ');
+					if (!tmpMap[field]) {
+						tmpMap[field] = true;
+						columns.push({ field, type });
+					}
 				}
 			});
 	}